2017-05-16 64 views
0

在这个example,我看到EmrCreateJobFlowOperator接收是建立在气流UI的AWS/EMR连接:在Airflow UI中,我可以添加aws连接吗?

cluster_creator = EmrCreateJobFlowOperator(
    task_id='create_job_flow', 
    job_flow_overrides=JOB_FLOW_OVERRIDES, 
    aws_conn_id='aws_default', 
    emr_conn_id='emr_conn_id', 
    dag=dag) 

气流UI,在连接的标签,我怎么可以加我的AWS凭据,以使DAG可以提取它们吗?我没有看到AWS的任何类型的连接。任何想法?

回答

1

aws_default从环境变量或~/.aws/credentials中获取凭证。您可以选择您的部署模式来决定要放置密码的位置。

但是,如果你想通过UI添加连接字符串,你可以去管理 - >连接并在那里编辑键。

相关问题