CSRF 令牌使用 REST API 调用删除气流 UI 中的 Airflow Dag

Question

目的是通过 rest api 调用从 UI 中删除气流 dag。我尝试了api调用 .../delete?dag_id=<dag_id> ，这个休息调用失败，说 CSRF 令牌丢失。如何从气流服务器获取 CSRF 令牌？还是有更好的方法以自动方式从气流 UI 中删除 dag？ （不是从气流 UI 中手动按下删除按钮）

Answer 1

对于气流版本 >= 1.10，您可以使用实验性 REST API

这是一个代码示例：

import requests
from urllib.parse import urljoin

def delete_dag(airflow_server_address ,dag_id):
    url = urljoin(airflow_server_address, '/api/experimental/dags/'+dag_id)
    requests.delete(url)

这将从数据库中删除 dag 运行和数据。 确保先删除 dag .py 文件，否则 dag 将继续出现在气流 GUI 中。