Google Dataflow：无法在不同位置读取和写入 BigQuery - Python
Google Dataflow: Cannot read and write in different locations BigQuery - Python
根据 and 问题应该已经解决了，不是吗？
我在做什么：
| 'Read' >> beam.io.Read(beam.io.BigQuerySource(
query='SELECT * FROM XXX.YYY', use_standard_sql=True))
我得到的：
Cannot read and write in different locations: source: EU, destination: US
我尝试过的：
pipeline_options 中的区域：
pipeline_options.view_as(WorkerOptions).zone = 'europe-west1'
Use 演练：
但是其中 none 解决了问题。
额外：
如果您使用：
| 'Read' >> beam.io.Read(beam.io.BigQuerySource(
table='XXX:YYY.Table'))
你可以毫无问题地得到结果
修复更新 google-cloud-bigquery python 包
根据
我在做什么：
| 'Read' >> beam.io.Read(beam.io.BigQuerySource(
query='SELECT * FROM XXX.YYY', use_standard_sql=True))
我得到的：
Cannot read and write in different locations: source: EU, destination: US
我尝试过的：
pipeline_options.view_as(WorkerOptions).zone = 'europe-west1'Use 演练：
但是其中 none 解决了问题。
额外：
如果您使用：
| 'Read' >> beam.io.Read(beam.io.BigQuerySource(
table='XXX:YYY.Table'))
你可以毫无问题地得到结果
修复更新 google-cloud-bigquery python 包