【问题标题】:Airflow: Using MySqlHook to get connection气流:使用 MySqlHook 获取连接
【发布时间】:2018-04-05 14:12:08
【问题描述】:

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

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

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

任何帮助将不胜感激!

【问题讨论】:

    标签: python-3.x airflow directed-acyclic-graphs


    【解决方案1】:

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

    看了into the modelshook itself,好像是

    MySqlHook(mysql_conn_id='test_connection')

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

    【讨论】:

    • 只是一方面,我更喜欢使用airflow.hooks.base_hook.BaseHook.get_connection,然后针对生成的对象调用get_hook。如果您更改连接类型,这将在未来证明您的代码。
    猜你喜欢
    • 1970-01-01
    • 2022-01-22
    • 2019-07-09
    • 2018-07-22
    • 1970-01-01
    • 2022-08-16
    • 1970-01-01
    • 1970-01-01
    • 1970-01-01
    相关资源
    最近更新 更多