Airflow：使用 MySqlHook 获取连接

Question

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

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

给我一个错误：tuple' object has no attribute 'get_conn'

非常感谢任何帮助！

Answer 1

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

看了into the models and the hook itself，好像是

MySqlHook(mysql_conn_id='test_connection')

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