Google Dataflow：无法在不同位置读写 BigQuery - Python

Question

根据this 和this 的说法，问题应该已经解决了，不是吗？

我在做什么：

| '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

我尝试过的：

• Specified pipeline_options 中的区域：

      pipeline_options.view_as(WorkerOptions).zone = 'europe-west1'
  

• UsedryRun：

但他们都没有解决问题。

额外：

如果你使用：

| 'Read' >> beam.io.Read(beam.io.BigQuerySource(
                 table='XXX:YYY.Table'))

你可以毫无问题地得到结果

Answer 1

修复了更新 google-cloud-bigquery python 包