如何向MySqlOperator传递和使用参数

from airflow.providers.mysql.operators.mysql import MySqlOperator

# 创建MySqlOperator对象并传递参数
task = MySqlOperator(
    task_id='mysql_task',
    sql='SELECT * FROM table WHERE column = %(param)s',
    parameters={'param': 'value'},
    mysql_conn_id='mysql_conn'
)

from airflow.providers.mysql.operators.mysql import MySqlOperator

# 前一个任务中传递参数
task1 = PythonOperator(
    task_id='task1',
    python_callable=push_param,
    op_kwargs={'param': 'value'},
    provide_context=True
)

# 后续任务中获取参数
task2 = MySqlOperator(
    task_id='mysql_task',
    sql='SELECT * FROM table WHERE column = %(param)s',
    mysql_conn_id='mysql_conn',
    params={'param': '{{ task_instance.xcom_pull(task_ids="task1", key="param") }}'}
)