我正在尝试使用MySqlHook来获取连接对象。假设我在名为test_connection的Web服务器管理员中保存了一个mysql连接。我所做的:

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


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

任何帮助将不胜感激!

最佳答案

我不确定该代码示例的来源,尤其是参数conn_name_attr。看来参数是错误的。

看了into the modelshook itself之后,似乎

MySqlHook(mysql_conn_id='test_connection')

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

关于python-3.x - Airflow :使用MySqlHook获得连接,我们在Stack Overflow上找到一个类似的问题:https://stackoverflow.com/questions/49674527/

10-12 16:14