在此示例中,我看到 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 连接。任何想法?