Установите 'Autocommit = false' с оператором воздушного потока "Снежинка" - PullRequest
Новая
       84

Установите 'Autocommit = false' с оператором воздушного потока "Снежинка"

0 голосов
/ 01 мая 2020

У меня есть простая группа обеспечения доступности баз данных, предназначенная для фиксации одной транзакции. Я использую Airflow для этого варианта использования, так как Snowflake не позволяет управлять транзакциями в хранимых процедурах или задачах.

Просматривая в журнале моих задач конкретную c задачу, отвечающую за начало транзакции, я заметил, что для автоматической фиксации установлено значение true для каждого соединения: 

[2020-05-01 09:19:07,460] {{logging_mixin.py:112}} INFO - [2020-05-01 09:19:07,460] {{cursor.py:525}} INFO - query: [ALTER SESSION SET autocommit=True]

Мне нужно установить для этого свойства значение false, возможно ли это?

1 Ответ

2 голосов
/ 01 мая 2020

Копание в коде пакета на https://github.com/apache/airflow/blob/v1-10-stable/airflow/contrib/operators/snowflake_operator.py

Заметил, что после инициализации оператора Snowflake вы можете установить для свойства автоматической фиксации значение false.

I Можно подтвердить, что после установки этого значения свойства журнал отражает это: 

[2020-05-01 11:05:24,817] {{logging_mixin.py:112}} INFO - [2020-05-01 11:05:24,817] {{cursor.py:525}} INFO - query: [ALTER SESSION SET autocommit=False]
...