如何将objectId从bson封装导入到Apache Beam管道中（与Pymongo兼容）？
嗨，我正在使用Google DataFlow中的管道，该管道加载了一些MongoDB文档（带有Pymongo）并进行处理。在某个时候，我需要将ID投入到mongoDB objectid。 为了施放它，我使用了BSON软件包，问题是使用DataFlowRunner未检测到软件包，我不明白为什么，因为我在setup.py中声明了pymongo [srv]。 如果我在设置中声明bson。 我知道Pymongo配备了自己的BSON包，但是如何在Apache Beam管道中提供它？
Hi I'm working on a pipeline in google Dataflow that loads some MongoDB documents (with pymongo) and process it. At some point I need to cast an id to a MongoDB ObjectId.
To cast it I use the bson package, the problem is that with the dataflowRunner is not detecting the package, and I don't understand why because I declared pymongo[srv] in setup.py.
If I declare bson in the setup.py I get an error because the installed bson dependency is not compatible with pymongo.
I know that pymongo comes with its own bson package but how can I make it available inside an Apache Beam pipeline?
如果你对这篇内容有疑问，欢迎到本站社区发帖提问 参与讨论，获取更多帮助，或者扫码二维码加入 Web 技术交流群。
绑定邮箱获取回复消息
由于您还没有绑定你的真实邮箱，如果其他用户或者作者回复了您的评论，将不能在第一时间通知您！
发布评论