You need to enable JavaScript to run this app.
优惠活动
大模型
产品
解决方案
定价
更多

跨MWAA环境触发指定DAG任务无报错但未生效求助

问题原因及解决办法

核心问题:MWAA CLI命令语法错误

你触发单个任务的CLI命令格式完全错误,正确的触发指定任务的MWAA CLI命令格式应为:

tasks trigger <DAG_ID> <TASK_ID> <EXECUTION_DATE>

你当前的body内容是'tasks test test task_1 2023-05-17T16:48:03Z',这里重复写入了DAG IDtest,还漏掉了关键的trigger子命令,导致MWAA无法识别你的操作指令。

修正后的body代码应为:

body = 'tasks trigger test task_1 2023-05-17T16:48:03Z'

额外排查建议

  1. 捕获请求响应定位问题:当前代码未处理requests.post的返回结果,建议添加响应打印逻辑,直接查看MWAA返回的错误信息,快速定位问题:
    response = requests.post(url, data=body, headers=headers)
    print(response.status_code)
    print(response.text)
    
  2. 验证执行时间有效性:确保填写的<EXECUTION_DATE>是目标DAG已存在的执行日期(或符合DAG调度规则的未来日期),虽然你当前的时间格式YYYY-MM-DDTHH:MM:SSZ是正确的,但要确认该时间点对应的DAG实例确实存在。
  3. 确认任务状态限制:如果目标任务处于up_for_retry或failed等状态,可能需要先清除任务历史状态再触发,可搭配tasks clear命令先清理历史记录。

内容的提问来源于stack exchange,提问作者Pedro Alves

相关产品推荐
方舟 Agent Plan

超全模态模型 × Harness 升级,最新支持 Deepseek-V4.1-Flash、GLM-5.3 系列、Doubao-Seedream-5.0-pro、Kimi-K3 (部分), 限时 9.9 元起

最近更新时间:2026.07.21 17:07:51