SQL Server的钩和气流运营商连接(SQL Server Hook and operator

2019-11-05 09:50发布

我是新来使用气流和我需要做的就是用MssqlHookMssqlOperator ,但我不知道怎么办。

通过使用钩和操作员下面的代码

hook = MsSqlHook(mssql_conn_id=ms_sql)

t2 = MsSqlOperator(
        task_id = 'sql-op',
        mssql_conn_id = ms_sql,
        sql = 'Select Current_date()',
        dag = dag)

在气流UI连接 -

Conn Id - ms_sql
Conn Type -Microsoft SQL server
Host - host_name
schema- default
login- username
password- password
port - 14481

而当我这样做的错误

连接失败原因不明

我应该如何连接?

文章来源: SQL Server Hook and operator connection in Airflow