GoogleCloudOptions没有的所有选项。选项

Question

因此，我今天的梁工作以以下警告结束：

/usr/local/lib/python2。7/dist包/apache_-beam/runners/dataflow/dataflow_-runner。py:800:BeamDeprecationWarning:自第一个稳定版本以来，选项已被弃用。提及。选项将不受支持

所以据我所知，与其这样做：

self.options = {'project': self.project_name,
               'job_name': self.job_name,
               }

我将不得不谈到这一点：

self.options = PipelineOptions()
        google_cloud_options = self.options.view_as(GoogleCloudOptions)
        google_cloud_options.project = self.project_name
        google_cloud_options.job_name = self.job_name

但有一个问题，很多选项不再可用，例如最大工作人数、设置文件位置。。。

我试图再次检查它的留档，但找不到那些丢失字段的替代品。

如果我只是在新的GoogleCloudOptions中添加了一些注册标签，它会抱怨：

AttributeError:“GoogleCloudOptions”对象没有属性“max\u num\u workers”

那么有人知道这些领域的替代品是什么吗？

非常感谢。

Answer 1

在Apache Beam SDK库的同一模块中，一些选项似乎已移动到WorkerOptions。

工作选项类中的注释：

控制辅助角色池配置的命令行选项。

它包括num\u workers，max\u num\u workers，worker\u machine\u type，还有一些我认为以前在GoogleCloudOptions中出现过的。

从v2开始，模块的源代码见此链接。12: https://beam.apache.org/releases/pydoc/2.12.0/_modules/apache_beam/options/pipeline_options.html#WorkerOptions