要重新运行带有日期参数的任务,你可以使用airflow backfill
命令。这个命令可以重新运行已完成的任务,并将日期参数传递给任务。
以下是一个示例代码,演示如何在 Apache Airflow 中重新运行带有日期参数的任务:
datetime
库导入了所需的日期和时间函数:from datetime import datetime
# 获取昨天的日期
date_to_run = datetime.now().date() - timedelta(days=1)
airflow backfill
命令来重新运行任务。确保将dag_id
替换为你的DAG的实际ID,并将task_id
替换为你要重新运行的任务的实际ID。还可以根据需要在命令中添加其他参数:import os
# 构建要运行的命令
command = f"airflow backfill dag_id --task_id task_id --start_date {date_to_run} --end_date {date_to_run}"
# 执行命令
os.system(command)
通过以上步骤,你可以重新运行带有日期参数的任务。请确保替换dag_id
和task_id
为实际的DAG和任务ID,并根据需要调整其他参数。