googlecloudoptions没有所有<pipeline>选项。

所以我今天的光束工作最后得到了一个警告:

/usr/local/lib/python2.7/dist packages/apache_beam/runners/dataflow/dataflow_runner.py:800:beamdeprecationwarning:自第一个稳定版本以来,选项已弃用。不支持对.options的引用

所以,据我所知,与其这样做,不如这样做:

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中添加了一些注册标签,它会抱怨:

attributeRor:“GoogleCloudOptions”对象没有属性 '最大值工人'

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

谢谢您。