如何在BashOperator执行的python脚本文件中使用Xcom

from airflow import DAG
from airflow.operators.bash_operator import BashOperator
from airflow.operators.python_operator import PythonOperator
from airflow.models import Variable

dag = DAG('xcom_example', description='Example DAG with Xcom', schedule_interval='0 0 * * *', start_date=datetime(2022, 1, 1), catchup=False)

def process_data(**kwargs):
    # 从Xcom中获取之前任务传递的数据
    data = kwargs['ti'].xcom_pull(task_ids='previous_task')
    
    # 处理数据
    processed_data = process(data)
    
    # 将处理后的数据传递给下一个任务
    kwargs['ti'].xcom_push(key='processed_data', value=processed_data)

bash_task = BashOperator(task_id='execute_script', bash_command='python /path/to/script.py', dag=dag)

python_task = PythonOperator(task_id='process_data', python_callable=process_data, provide_context=True, dag=dag)

bash_task >> python_task