- 确认Airflow日志路径是否正确配置,并确保路径存在。可以通过修改airflow.cfg文件中的以下行来配置日志路径:
log_base = /usr/local/airflow/logs
- 确认Airflow用户对路径具有适当的权限。例如,如果Airflow使用用户“airflow”运行,则可以运行以下命令:
sudo chown -R airflow: /usr/local/airflow/logs
- 如果任务实例无法在UI中显示日志,则可以尝试刷新任务实例或重启Airflow webserver和scheduler:
airflow webserver -p 8080
airflow scheduler
- 确认任务实例的日志级别是否正确配置。例如,如果希望调整任务实例的日志级别为“DEBUG”,则可以在DAG文件中使用以下代码:
dag = DAG(
'example_dag',
default_args=default_args,
schedule_interval=timedelta(days=1),
catchup=False,
dagrun_timeout=timedelta(minutes=60))
with dag:
task = BashOperator(
task_id='example_task',
bash_command='echo "Hello World"',
dag=dag,
# 设置日志级别为DEBUG
logging_level=logging.DEBUG
)
- 最后,确保对Airflow进行了正确的配置和部署,并已安装所有必要的依赖项。可以参考Airflow文档中的“快速入门”部分进行更多设置和调整。