只是想知道新版本(3.X)的 python 是否有更多的管道 I/O 和运行时参数。如果我是正确的,那么当前 apache beam 在使用 python 时仅提供基于文件的 IO:textio、avroio、tfrecordio。但对于 Java,我们有更多可用选项,例如基于文件的 IO、BigQueryIO、BigtableIO、PubSubIO 和 SpannerIO。
根据我的要求,我想使用 python 3.X 在 GCP 数据流管道中使用 BigQueryIO,但目前它不可用。有谁知道 apache beam 何时可以提供 ETA 的更新信息吗?
最佳答案
Python 3 的 BigTable 连接器目前已经开发了一段时间。目前,尚无预计到达时间,但您可以按照相关Pull-Request进行操作。从官方 Apache Beam 存储库获取进一步更新。
关于python - 预计 ETA 将使用 python 在 apache beam GCP 数据流管道中利用管道 I/O 和运行时参数?,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/60146887/