未定义全局名称“bigquery”

Question

我创建了一个 google 数据流作业，但即使我已经导入了所需的变量，我仍然不断收到未定义的全局名称“bigquery”。这是我的进口清单：from __future__ import absolute_importimport argparseimport loggingimport astimport jsonimport apache_beam as beamfrom apache_beam.io import ReadFromText, WriteToText from apache_beam.options.pipeline_options import PipelineOptionsfrom apache_beam.options.pipeline_options import SetupOptionsfrom apache_beam.options.pipeline_options import StandardOptionsfrom google.cloud import bigquery这是返回错误的类：class CheckExistance(beam.DoFn):    def __init__(self, table):        self.table = table.replace(":", ".")    def process(self, element):        client = bigquery.Client()        date = element['date'].split(" ")[0]        query_job = client.query("""        QUERY """ % (self.table, date))        yield element你们知道是什么导致了这个错误吗？顺便说一句，我只在将其部署到 google 的数据流作业时才会收到此错误，它在本地运行良好。

Answer 1

我猜你需要启用 BigQuery

资源 / 高级 Google 服务 / 启用 BigQuery

编辑：检查评论以查看故障排除、发现和有效的方法。