如何通过Airflow CLI查看任务日志？UI无日志时的替代方法

完全可以通过Airflow CLI查看特定任务的日志，你需要使用airflow tasks log命令——这是专门用于提取已有任务运行日志的工具，无需重新执行任务。

基本命令格式 #

airflow tasks log <dag_id> <task_id> <execution_date>

参数说明 #

• <dag_id>: 目标DAG的唯一标识符
• <task_id>: 要查看日志的具体任务ID
• <execution_date>: 任务的执行日期，支持格式如YYYY-MM-DD（天级调度）或YYYY-MM-DDTHH:MM:SS（精确到时分秒）

示例 #

假设你的DAG ID是user_activity_pipeline，任务ID是load_to_db，执行日期为2024-05-20，执行命令：

airflow tasks log user_activity_pipeline load_to_db 2024-05-20

如果任务有重试记录，想要查看第2次重试的日志，可添加-n参数指定重试次数：

airflow tasks log user_activity_pipeline load_to_db 2024-05-20 -n 2

额外提示 #

如果不确定任务的精确执行日期，可先通过以下命令查看目标DAG的所有运行记录：

airflow dags list-runs <dag_id>

内容的提问来源于stack exchange，提问作者Vlad Vlad