我創建了一個 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 的數據流作業時才會收到此錯誤，它在本地運行良好。