如何使用气流和pass参数触发googledataproc作业

inn6fuwd 于 2021-07-13 发布在 Spark

关注(0)|答案(1)|浏览(386)

作为dag的一部分，我使用下面的代码触发gcp pyspark dataproc作业，

dag=dag,
   gcp_conn_id=gcp_conn_id,
   region=region,
   main=pyspark_script_location_gcs,
   task_id='pyspark_job_1_submit',
   cluster_name=cluster_name,
   job_name="job_1"
)

如何将变量作为参数传递给可以在脚本中访问的pyspark作业？

apache-spark pyspark google-cloud-platform airflow google-cloud-dataproc

来源：https://stackoverflow.com/questions/66136238/how-to-trigger-google-dataproc-job-using-airflow-and-pass-parameter-as-well

1条答案

按热度按时间

wixjitnu1#

你可以使用参数 arguments DataProcPypSparkOperator的名称：
参数（列表）–作业的参数(模板化）

job = DataProcPySparkOperator(
    gcp_conn_id=gcp_conn_id,
    region=region,
    main=pyspark_script_location_gcs,
    task_id='pyspark_job_1_submit',
    cluster_name=cluster_name,
    job_name="job_1",
    arguments=[
        "-arg1=arg1_value", # or just "arg1_value" for non named args
        "-arg2=arg2_value"
    ],
    dag=dag
)

赞(0）回复(0）举报 2021-07-13

我来回答

如何使用气流和pass参数触发googledataproc作业

1条答案

相关问题

热门标签

最新问答