Python 如何通过UI停止/杀死Airflow任务

在本文中，我们将介绍如何通过使用Python编程语言通过用户界面（UI）停止或杀死Airflow任务。Airflow是一种以编程方式创建、调度和监视工作流程的开源平台，提供了强大的任务管理功能。有时候，我们需要手动停止或杀死正在执行的任务，以便及时处理异常或调整工作流程。

Airflow提供了两种方法来停止或杀死任务：通过UI界面或通过Python代码。本文将重点介绍如何通过UI界面进行操作。

阅读更多：Python 教程

通过UI停止任务

首先，我们需要打开Airflow的用户界面。在浏览器中输入Airflow的URL地址，然后导航到相应的任务页面。在任务页面中，可以看到当前正在运行的任务列表。

要停止任务，可以选择要停止的任务，并单击“停止”按钮。Airflow将发送一个停止信号给任务，并将其状态更改为“停止中”。任务将在接收到停止信号后尽快停止。

以下是一个示例的Python代码片段，演示如何通过UI停止任务：

import requests

# Airflow的URL地址
airflow_url = "http://localhost:8080"

# 停止任务的函数
def stop_airflow_task(task_id):
    stop_url = f"{airflow_url}/data_profiler/{task_id}/stop"
    response = requests.get(stop_url)
    if response.status_code == 200:
        print("任务停止成功！")
    else:
        print("任务停止失败。")

# 调用停止任务的函数
stop_airflow_task("my_task_id")

在上面的代码中，我们使用了requests库来发送HTTP请求。我们只需要将airflow_url替换为运行Airflow的主机和端口，stop_airflow_task()函数中的task_id替换为要停止的任务的ID即可。

通过UI杀死任务

除了停止任务，有时候我们需要强制终止任务的执行。在Airflow的任务页面中，可以看到正在运行的任务列表以及对应的终止按钮。

要杀死任务，只需选择要杀死的任务并单击“终止”按钮。Airflow将向任务发送终止信号，并立即将其状态更改为“终止”。任务将立即停止运行。

以下是一个通过UI杀死任务的示例Python代码片段：

import requests

# Airflow的URL地址
airflow_url = "http://localhost:8080"

# 杀死任务的函数
def kill_airflow_task(task_id):
    kill_url = f"{airflow_url}/data_profiler/{task_id}/kill"
    response = requests.get(kill_url)
    if response.status_code == 200:
        print("任务成功终止！")
    else:
        print("任务终止失败。")

# 调用杀死任务的函数
kill_airflow_task("my_task_id")

在上述代码中，我们使用了与停止任务相同的requests库来发送HTTP请求。同样，我们只需要将airflow_url替换为运行Airflow的主机和端口，kill_airflow_task()函数中的task_id替换为要终止的任务的ID。