1. 确定日志位置 检查你的airflow.cfg文件，了解你的日志的位置。如果使用默认配置，则日志位于/var/log/airflow目录下。

2. 设置Logging Configuration 配置日志记录Level以及output，在你的dag文件中添加以下代码：

import logging from airflow.models import DAG from airflow.operators.python_operator import PythonOperator

def my_function(): logging.info('This is an info message')

dag = DAG(dag_id='my_dag', schedule_interval=None)

log_operator = PythonOperator(task_id='log_operator', python_callable=my_function, dag=dag)

在从worker中查找日志文件时，应该可以看到记录器正在发出日志。

3. 重新启动Airflow服务 如果尝试使用上述步骤后仍然遇到问题，请尝试重新启动Airflow服务。可以尝试运行以下命令：

sudo service airflow-webserver restart sudo service airflow-scheduler restart sudo service airflow-worker restart

检查日志，看看是否已解决问题。