使用 gcloud 传递数据流作业的参数列表的语法

如何解决使用 gcloud 传递数据流作业的参数列表的语法

今天将我的云 sdk 更新到最新版本后，我无法再正常运行我的数据流作业。到目前为止，我总是用以下方式开始它们：

gcloud dataflow jobs run job_name --gcs-location gs://template_location --parameters from_date="2019-03-01",to_date="2019-04-30"

但在更新之后，此调用导致传递了一个参数 from_date 并包含值 2019-03-01 to_date=2019-04-30（全部一起）。

我尝试在方括号中传递参数列表，但这会导致立即错误。

那么，现在传递参数列表的正确方法是什么？

解决方法

您可以尝试以下选项来通过脚本传递所有参数

PROJECT='YOUR_PROJECT'
BUCKET='YOUR_BUCKET'

def run():
    argv = [
          '--project={0}'.format(PROJECT),'--job_name=YOUR_JOB_NAME','--save_main_session','--staging_location=gs://{0}/staging/'.format(BUCKET),'--temp_location=gs://{0}/staging/'.format(BUCKET),'--region=us-central1','--runner=DataflowRunner'
          '--from_date=2019-03-01'
          '--to_date=2019-04-30'
    ]