要解决“Airflow实验性API - DAG运行从未入队”的问题,需要检查以下几个方面:
[api]
# 是否启用实验性API
# 仅供开发和测试目的
experimental_api = true
确保使用的Airflow版本支持实验性API。只有Airflow 1.10.12及更高版本才支持实验性API。
确认代码中是否正确调用了实验性API。以下是一个示例,展示如何使用实验性API运行DAG。
import requests
# 设置实验性API的基本URL
api_base_url = 'http://localhost:8080/api/experimental/'
# 运行DAG
def run_dag(dag_id):
url = api_base_url + 'dags/' + dag_id + '/dag_runs'
response = requests.post(url)
if response.status_code == 200:
print('DAG运行已成功入队')
else:
print('DAG运行入队失败')
# 调用run_dag函数来运行指定的DAG
run_dag('my_dag_id')
确保将my_dag_id
替换为您要运行的DAG的ID。
请注意,由于实验性API可能会在未来的Airflow版本中发生更改,因此建议在生产环境中谨慎使用实验性API。