是否有 Google 数据流 MongoDB Source/Sink?

Is there a Google Dataflow MongoDB Source/Sink?

我知道 Google Dataflow 只正式支持 I/O Dataflow Google Cloud Storage、BigQuery、Avro 文件或 Pub/Sub 开箱即用的文件.

但是因为它有一个 API for Custom Source and Sink 我想知道 MongoDB 是否有一些管道 I/O 实现?

现在我将不得不将我的数据迁移到 BigQuery 或编写整个管道 I/O 实现,然后才能知道 Google Dataflow 是否是我当前问题的可行解决方案。

我尝试使用谷歌搜索并查看 current SDK issues,但没有看到任何相关内容。我什至开始怀疑我是否错过了 Google 数据流概念和文档中的一些非常基本的东西,这些概念和文档完全否定了使用 MongoDB 作为数据源的最初想法。

最近 MongoDB 连接器被添加到 Apache Beam (incubating). Please see MongoDBIO