以下是使用Python代码向Airflow Rest-API发出GET请求的示例:
import requests
from requests_oauthlib import OAuth1
credentials = {
'consumer_key': 'your_consumer_key',
'consumer_secret': 'your_consumer_secret',
'token_key': 'your_token_key',
'token_secret': 'your_token_secret'
}
url = 'http://localhost:8080/api/experimental/test'
auth = OAuth1(
credentials['consumer_key'],
credentials['consumer_secret'],
credentials['token_key'],
credentials['token_secret']
)
headers = {'Content-Type': 'application/json'}
response = requests.get(url, auth=auth, headers=headers)
data = response.json()
print(data)
以上代码中,我们使用OAuth1库初始化了授权信息,并将其传递到API请求中。同时也设置了Headers,这个取决于API的要求。最后使用response.json()方法将API返回的数据解析成JSON格式。
此方法可以使用在多种场景下,如创建DAG、运行任务、查看日志等。
下一篇:Airflow-如何跳过某些任务