Я не понимаю, что такое использование оператора 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?