AttributeError：“RuntimEvalueProvider”对象没有属性“Project ID”
我的管道选项如下
options = PipelineOptions()
options.view_as(SetupOptions).save_main_session = True
importer_options = options.view_as(ImporterOptions)
google_options = options.view_as(GoogleCloudOptions)
with beam.Pipeline(options=options) as p:
p | 'BigQuery Read' >> beam.io.ReadFromBigQuery(
table=importer_options.input_table)
ImportOptions当前接受input_table作为参数。
parser.add_value_provider_argument('--input-table',
help='The bigquery input table in the format dataset.table_name')
但是运行管道会给我一个如下所示的错误
我正在使用下面的命令构建模板。
python-m main
--runner DataflowRunner
--project test-project
--region=europe-west1
--staging_location gs：//test/staging_python
--template_location gs：//test/templates_python/test\
注意-我尝试通过针对input_table提供完全限定的表名来运行管道（意味着，包括项目id)，但这也没有帮助。
共有1个答案
我们也面临着同样的问题，这是自2020年底发布的2.26.0版本以来的一个bug。
创建一个bug报告:https://issues.apache.org/jira/browse/beam-12514
pull请求现在可用:https://github.com/apache/beam/pull/15040
-
问题内容： 我想转换火花数据框架以使用以下代码添加： 详细的错误消息是： 有人知道我在这里做错了吗？谢谢！ 问题答案： 您无法使用数据框，但可以将数据框转换为RDD并通过映射将其映射。在Spark 2.0之前，别名为。使用Spark 2.0，您必须先明确调用。
-
问题内容： 我如何解决此错误，我是从GitHub下载此代码的。 引发错误 请帮我解决这个问题！ 我用了： 我得到这个错误。有人帮我，我只想让它工作为什么这么难？ 问题答案： 我怀疑您从中复制代码的地方启用了急切执行功能，即在程序开始时调用了该位置。 您也可以这样做。希望能有所帮助。 更新：请注意，默认情况下，TensorFlow 2.0中启用了急切执行。因此，以上答案仅适用于TensorFlow
-
问题内容： 下面的代码给出了错误： 码： 问题答案： 从代码中，我可以看到你希望允许用户下载pdf。 现在开始 去 http://localhost:5000
-
问题内容： 当我尝试时，会发生错误： 我找到了带有pyelasticsearch.py 的链接https://github.com/toastdriven/pyelasticsearch/blob/master/pyelasticsearch.py#L424-469，但我不知道它是哪个版本。无论如何，该代码中没有购买我的pyelasticsearch.py。任何人都有相同的经历吗？感谢您的
-
我和cloud composer一起策划了两个数据流工作，它已经工作了一个月了。突然，这两个作业停止工作，并出现以下错误消息： 在作业中，我用存储客户端从google cloud storage下载一个文件。我以为这是因为一些依赖问题。在composer环境中，我安装了google-cloud-storage，但没有指定版本。我尝试指定包的不同版本，但似乎没有任何工作。 谢了！
-
问题内容： 我正在使用Flask开发论坛模板。当我尝试使用表单在浏览器中创建新线程时，SQLAlchemy抛出AttributeError。当我尝试与论坛到线程实现一对多关系以及与线程到用户实现一对多关系时，出现了问题。 models.py 所有新的帖子/主题，并在views.py中处理 views.py 问题答案： 问题是这样的： 你要使用ORM对象，而不是主键列： 该错误表示整数被解释为ORM