我最近开始研究 Amazon MWAA,并且能够设置环境并上传 DAG。当我尝试运行该作业时,它会失败而不会创建任何日志。 失败任务的快照
如果有人可以看一下,将不胜感激:)
下面是 DAG 代码:
from airflow.operators.python_operator import PythonOperator
from datetime import datetime, timedelta
from airflow.operators.sensors import TimeDeltaSensor
import boto3
import json
default_args = {
'owner': 'AM',
'start_date': datetime(2021, 3, 25)
}
glue_client = boto3.client('glue', region_name='us-east-1')
def run_glue_job():
glue_client.start_job_run(JobName='RunJob')
with DAG('runglue', default_args=default_args, schedule_interval=timedelta(days=30)) as dag:
rungluejob = PythonOperator(task_id='task1',python_callable=run_glue_job)
rungluejob