Airflow DAG没有输出的问题可能是由于以下几个原因引起的:
from airflow import DAG
from airflow.operators.python_operator import PythonOperator
from datetime import datetime
def my_task():
# 任务逻辑代码
print("Hello Airflow")
dag = DAG('my_dag', description='My DAG', schedule_interval='0 0 * * *', start_date=datetime(2022, 1, 1))
task = PythonOperator(task_id='my_task', python_callable=my_task, dag=dag)
def my_task():
# 任务逻辑代码
print("Hello Airflow")
在airflow.cfg
配置文件中,找到以下行并确保设置为以下值:
[core]
...
logging_level = INFO
...
在airflow.cfg
配置文件中,找到以下行并确保设置为正确的日志存储路径:
[core]
...
dag_processing_log_location = /path/to/log/directory
...
通过以下命令启用DAG:
$ airflow dags unpause my_dag
通过以下命令检查配置文件是否存在错误:
$ airflow config validate
如果配置文件存在错误,将会显示错误信息。
如果以上方法仍然无法解决问题,可以尝试重启Airflow服务,并检查Airflow日志,以查看是否有其他错误信息。