Airflow:如何将xcom从父dag传递到子dag

from airflow.operators.python_operator import PythonOperator
from airflow.models import DAG

def push_data(**context):
    data = "Hello, World!"
    context['ti'].xcom_push(key='my_data', value=data)

with DAG('parent_dag', schedule_interval=None) as dag:
    push_task = PythonOperator(
        task_id='push_task',
        python_callable=push_data
    )

2. XComPullOperator：在子DAG中使用XComPullOperator从xcom中拉取数据。例如：

```python
from airflow.operators.python_operator import PythonOperator
from airflow.models import DAG

def pull_data(**context):
    data = context['ti'].xcom_pull(key='my_data')
    print(data)

with DAG('child_dag', schedule_interval=None) as dag:
    pull_task = PythonOperator(
        task_id='pull_task',
        python_callable=pull_data
    )

在子DAG中，可以通过context['ti'].xcom_pull(key='my_data')来获取父DAG中推送的数据。

推荐的腾讯云相关产品：腾讯云容器服务（Tencent Kubernetes Engine，TKE），它是一种高度可扩展的容器管理服务，可帮助您轻松部署、运行和管理容器化应用程序。TKE提供了强大的容器编排和调度能力，适用于部署和管理Airflow等工作负载。

腾讯云产品介绍链接地址：https://cloud.tencent.com/product/tke