我知道Google Dataflow仅正式支持将Google Cloud Storage、BigQuery、Avro文件或开箱即用的Pub/Sub中的文件作为Dataflow的I/O。
但是由于它有一个自定义源和接收器的API，我想知道，是否有一些MongoDB的管道I/O实现？
现在，我必须将我的数据迁移到BigQuery或编写整个Pipeline I/O实现，然后才能知道Google Dataflow是否是我当前问题的可行解决方案。
我尝试谷歌搜索和查看当前的SDK问题，没有看到任何相关的东西。我甚至开始怀疑我是否错过了谷歌数据流概念和文档中非常基本的东西，这些概念和文档完全否定了使用MongoDB作为数据源的最初想法。
最近将MongoDB连接器添加到Apache Beam（孵化）。请参阅MongoDBIO。
