我創(chuàng)建了一個 google 數(shù)據(jù)流作業(yè),但即使我已經(jīng)導入了所需的變量,我仍然不斷收到未定義的全局名稱“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 的數(shù)據(jù)流作業(yè)時才會收到此錯誤,它在本地運行良好。
1 回答

一只名叫tom的貓
TA貢獻1906條經(jīng)驗 獲得超3個贊
我猜你需要啟用 BigQuery
資源 / 高級 Google 服務 / 啟用 BigQuery
編輯:檢查評論以查看故障排除、發(fā)現(xiàn)和有效的方法。
添加回答
舉報
0/150
提交
取消