我是新手使用airflow,我需要做的是使用MssqlHook,但我不知道该怎么做。在构造函数中应该提供哪些元素?
我在airflow中有一个名为connection_test的连接。
我不完全理解类中的属性:
class MsSqlHook(DbApiHook):
"""
Interact with Microsoft SQL Server.
"""
conn_name_attr = 'mssql_conn_id'
default_conn_name = 'mssql_default'
supports_autocommit = True
我有以下代码:
sqlhook=MsSqlHook(connection_test)
sqlhook.get_conn()
当我这样做时,出现错误连接失败,原因未知。
为了使它与airflow连接正常工作,我该怎么做?
我需要调用MsSqlHook的函数.get_conn()。
autocommit=True
。 - GabeMsSqlImportOperator
。那是某个人构建的自定义operator。 - Gabe