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的任何类型的连接。任何想法?