在Airflow MySqlHook的实例化中显式传递Schema参数,例如:
from airflow.hooks import MySqlHook mysql_hook = MySqlHook(mysql_conn_id='my_conn', schema='my_schema')
在这个例子中,我们实例化了一个名为mysql_hook的MySqlHook对象,并明确指定了schema参数。这将确保在连接到MySQL数据库时自动使用正确的schema。
上一篇:AirflowMWAA中的XCom值未显示
下一篇:AirflowMySQLToGCSOperator使用了大量内存