python - 尝试写入 BigQuery 时 Apache Beam 中没有属性 'TableReference'

Question

尝试运行此管道时出现此异常:

发生异常:AttributeError 模块“apache_beam.io.gcp.internal.clients.bigquery”没有属性“TableReference”

table_spec='ExporterPlayGround.TEST_STREAM' 
with beam.Pipeline(options=pipeline_options) as p:
        from apache_beam.io.gcp.internal.clients import bigquery
        raw_stream = (
            p | 'Start subscriber' >> beam.io.gcp.pubsub.ReadFromPubSub(subscription=subscription_name)
            | 'Write to Table' >> beam.io.WriteToBigQuery(
                table_spec,
                schema='test_float:FLOAT, test2_float:FLOAT',
                write_disposition=beam.io.BigQueryDisposition.WRITE_APPEND,
                create_disposition=beam.io.BigQueryDisposition.CREATE_IF_NEEDED)
            )

也许我遗漏了一些明显的东西，但我似乎看不出问题是什么，我正在提供文档指向的引用 bigquery。

Answer 1

我最终解决了这个问题，我的错误。我安装了错误的包。 pip install apache-beam 不包括 gcp 支持。我必须使用 pip install apache-beam[gcp]