气流：使用 MySqlHook 获取连接

Question

我正在尝试在使用 MySqlHook 时获取连接对象。假设我在名为test_connection. 我所做的：

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. 好像参数不对。

在查看模型和钩子本身之后，它似乎是

MySqlHook(mysql_conn_id='test_connection')

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