Ошибка при запуске системной задачи Системная задача - Airflow DAG / SQL Server

После того, как я запустил и обновил задачу dag, она перешла из состояния выполнения, задержки в состояние сбоя. Журнал ошибок из воздушного потока сказал мне проверить ошибку с сервера sql, который я получил. Не удалось запустить системную задачу Системная задача, когда я проверил журналы на моем докер-контейнере sql-сервера. Я не уверен, нужно ли мне указывать схему, но остальные параметры подключения верны.

[entrypoint.sh]

"${AIRFLOW_CONN_MY_SRC_DB:=mssql+pyodbc://SA:P@SSW0RD@mssqlcsc380:1433/?driver=ODBC+Driver+17+for+SQL+Server}"

[dag.py]

with DAG (
    'mssql_380_dag',
    start_date=days_ago(1),
    schedule_interval=None,
    catchup=False,
    default_args={
        'owner' : 'me',
        'retries' : 1,
        'retry_delay' : dt.timedelta(minutes=5)
        }
    ) as dag:
    get_requests = MsSqlOperator(
        task_id = 'get_requests',
        mssql_conn_id = 'my_src_db',
        sql = 'select * from Request',
        dag = dag
    )

введите описание изображения здесь


airflow sql-server airflow-operator pyodbc
person CLUTCHER    schedule 24.08.2020    source источник

Ответы (1)


arrow_upward
0
arrow_downward

Проблема заключалась только в том, что он не мог заметить таблицу, поэтому я указал базу данных, которая устранила проблему, хотя база данных должна была быть распознана, поскольку я передал ее в строке подключения.

sql = 'use csc380db; select * from Request',
person CLUTCHER    schedule 24.08.2020