python-3.x之Airflow:使用 MySqlHook 获取连接

我试图在使用 MySqlHook 时获取连接对象。假设我在 Web 服务器管理中保存了一个名为 test_connection 的 mysql 连接。我做了什么:

mysql_hook = MySqlHook(conn_name_attr = 'test_connection') 
conn = mysql_hook.get_conn() 

给我一​​个错误:tuple'对象没有属性'get_conn'

任何帮助将不胜感激!

请您参考如下方法:

我不确定该代码示例来自哪里，尤其是参数 conn_name_attr。好像参数不对。

查看后into the models和 hook itself ，好像是

MySqlHook(mysql_conn_id='test_connection')

此外，如果您返回一个元组，请尝试打印它，因为其中可能有错误消息或其他有用的信息。