未定义全局名称“bigquery”

Question

我创建了一个 google 数据流作业，但即使我已经导入了所需的变量，我仍然不断收到未定义的全局名称“bigquery”。

这是我的进口清单：

from __future__ import absolute_import

import argparse

import logging

import ast

import json

import apache_beam as beam

from apache_beam.io import ReadFromText, WriteToText 

from apache_beam.options.pipeline_options import PipelineOptions

from apache_beam.options.pipeline_options import SetupOptions

from apache_beam.options.pipeline_options import StandardOptions

from 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编辑：检查评论以查看故障排除、发现和有效的方法。