airflow dag 网络接口请求,并且把请求结果写入redis。

Airflow DAG 可以通过使用 PythonOperator 和 requests 库来进行网络接口请求,并通过使用 redis 模块将请求结果写入 redis。

下面是一个简单的示例:

from airflow import DAG
from airflow.operators.python_operator import PythonOperator
import requests
import redis

default_args = {
    'owner': 'airflow',
    'depends_on_past': False,
    '