2

在此示例中,我看到 EmrCreateJobFlowOperator 接收在 Airflow UI 中设置的 aws/emr 连接:

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)

在 Airflow UI 的连接选项卡中,我如何添加我的 AWS 凭证以便 DAG 可以获取它们?我没有看到任何类型的 AWS 连接。任何想法?

4

1 回答 1

3

aws_default环境变量或~/.aws/credentials. 你可以选择你的部署模式来决定你想把秘密放在哪里。

但是,如果您想通过 UI 添加连接字符串,您可以转到 Admin -> Connections 并在那里编辑密钥。

于 2017-05-16T19:43:02.603 回答