根据 Beam 文档
Beam
https://beam.apache.org/documentation/io/developing-io-overview/
我需要一个RabbitMQ的消息连接器,就像Java中的那个一样。
https://beam.apache.org/documentation/io/built-in/
到目前为止,在指南中,我还没有看到一种方法可以实现无限的源和汇
https://beam.apache.org/documentation/io/developing-io-python/