从酒吧/sub到大查询python的错误流

Question

我难以通过插入这两个：

来创建将酒吧/子来源连接到大查询池的DataFlowRunner作业。

apache_beam.io.gcp.pubsub.PubSubSource
apache_beam.io.gcp.bigquery.BigQuerySink

.py(github上的示例。在删除了第61-70行并指定正确的酒吧/sub和bigquery参数之后，脚本在没有构建管道的情况下没有错误运行。

Sidenote：脚本提到流媒体管道支持在Python中不可用。但是，在梁文档上，它提到apache_beam.io.gcp.pubsub.pubsubsource仅可用于流式传输(在" apache_beam.io.gcp.pubsub模块"下方的第一句话：https：//beam.apache.org/documentation/sdks/sdks/pydoc/pydoc/2.0.0.0.0.0.0.0.0.0.beam.beam.gcp.gcp.html#module-papache_beam.html#module-apache_beam.io.io.io.gcp.pubsub(

Answer 1

您无法在Python DataFlow上流式传输。

监视此变形值以找出当天：

• https://cloud.google.com/dataflow/release-notes/release-notes-python

(很快！(