Проблема запуска MySQL Скрипт с потоком воздуха MySQL Оператор - PullRequest
0 голосов
/ 25 января 2020

Я не понимаю, что такое использование оператора MySQL для вызова и сценария MySQL с Apache Воздушный поток.

Когда я запускаю эту задачу ...

    MySQLTest    = MySqlOperator(
                                task_id='MySQLTest',
                                sql = '/home/user/DBScripts/MySQLScript/SampleMySQLScript.sql',
                                mysql_conn_id = 'mysql_db_connect',                                
                                autocommit = True, 
                                database = 'segments' 
                                )

Я получаю эту ошибку при трассировке ...

jinja2.exceptions.TemplateNotFound: /home/user/DBScripts/MySQLScript/SampleMySQLScript.sql

Задача DAG работает нормально, если в качестве параметра я предоставляю весь сценарий SQL.

Я не знаком с Джинджей.

Легче ли научиться писать свои сценарии в качестве шаблона Jinja? Должен ли я импортировать текст скрипта и назначить его переменной, которую я передаю? Есть ли способ написать задачу Airflow, чтобы она не ожидала шаблон Jinja?

Добро пожаловать на сайт PullRequest, где вы можете задавать вопросы и получать ответы от других членов сообщества.
...