可以通过设置AWS_ACCESS_KEY_ID和AWS_SECRET_ACCESS_KEY的环境变量来解决此问题。以下是示例代码:
import os from airflow.contrib.hooks.emr_hook import EMRHook from airflow.exceptions import AirflowException
os.environ['AWS_ACCESS_KEY_ID'] = '
emr_hook = EMRHook(emr_conn_id='
step = emr_hook.add_step(
job_flow_id='
if not step: raise AirflowException("Failed to add step to EMR cluster")