在代码中添加conn_id参数
例: from airflow.operators.mysql_operator import MySqlHook
hook = MySqlHook(mysql_conn_id='my_conn_id') # 添加conn_id参数
上一篇:Airflow从数据库中获取数据并将其打印出来。
下一篇:Airflow存储在云端?