要使用Apache Airflow的REST API进行身份验证,可以使用基本身份验证(Basic Authentication)或令牌身份验证(Token Authentication)。下面是两种方法的代码示例:
import requests
from requests.auth import HTTPBasicAuth
# 设置Airflow的REST API URL和用户名密码
url = 'http://localhost:8080/api/experimental/dags'
username = 'admin'
password = 'admin'
# 发起GET请求并进行身份验证
response = requests.get(url, auth=HTTPBasicAuth(username, password))
# 打印响应内容
print(response.json())
import requests
# 设置Airflow的REST API URL和令牌
url = 'http://localhost:8080/api/experimental/dags'
token = 'your_token_here'
# 设置请求头部的Authorization字段
headers = {'Authorization': f'Bearer {token}'}
# 发起GET请求并进行身份验证
response = requests.get(url, headers=headers)
# 打印响应内容
print(response.json())
注意:在使用令牌身份验证时,需要先生成一个有效的令牌。可以通过在Airflow的Web UI中导航到Admin -> Variables -> Create来创建一个名为"airflow_api_token"的变量,并将其值设置为所需的令牌。然后在代码中将"your_token_here"替换为该变量的值。
这些示例代码可以帮助您进行Apache Airflow的REST API身份验证。您可以根据自己的需求进行修改和扩展。
上一篇:Apache Airflow - 每个DAG任务的预设重新运行,并改变日期
下一篇:Apache Airflow - 如何在目标DAG中使用TriggerDagRunOperator设置execution_date以使用当前execution_date