Я новичок в использовании воздушного потока и что мне нужно сделать, это использовать MssqlHook
или MssqlOperator
, но я не знаю, как.
С помощью крючка и оператора ниже кода
hook = MsSqlHook(mssql_conn_id=ms_sql)
t2 = MsSqlOperator(
task_id = 'sql-op',
mssql_conn_id = ms_sql,
sql = 'Select Current_date()',
dag = dag)
в соединениях Airflow UI -
Conn Id - ms_sql
Conn Type -Microsoft SQL server
Host - host_name
schema- default
login- username
password- password
port - 14481
И когда я делаю это, ошибка
Не удалось установить соединение по неизвестной причине
Какя должен подключиться?