怎样向其中传递参数

在使用 PythonOperator 时，可以向其中传递参数。以下是传递参数的示例代码：

1. 修改 Python 函数，使其接受参数

def my_python_function(my_param):
    # your python code here

2. 在创建 PythonOperator 实例时，传递参数

my_operator = PythonOperator(
    task_id='my_task',
    python_callable=my_python_function,
    op_kwargs={'my_param': 'my_value'},
    dag=dag,
)

3. 参数说明

- `op_kwargs`: 传递给 Python 函数的参数，以字典形式传递。

4. 完整示例

from datetime import datetime, timedelta
from airflow import DAG
from airflow.operators.python_operator import PythonOperator

default_args = {
    'owner': 'airflow',
    'start_date': datetime(2021, 1, 1),
    'retries': 1,
    'retry_delay': timedelta(minutes=5),
}

dag = DAG(
    'my_dag',
    default_args=default_args,
    schedule_interval=timedelta(days=1),
)

def my_python_function(my_param):
    # your python code here

my_operator = PythonOperator(
    task_id='my_task',
    python_callable=my_python_function,
    op_kwargs={'my_param': 'my_value'},
    dag=dag,
)

my_other_task >> my_operator

希望这个传递参数的示例代码能够帮助到您！