LINUX.ORG.RU

sqlalchemy Session в разных процессах (потоках)

 ,


0

1

Имеется модуль с session_scope. Могу ли я смело его подключать к своим отдельным скриптам, содержимое которых будет выполняться параллельно в отдельных airflow dag?

engine_mydb = create_engine(mydb_setting)

@contextmanager
def session_scope():
    try:
        session = Session(bind=engine_mydb)
        yield session
        session.commit()
    except Exception as e:
        send_error(e)
        session.rollback()
    finally:
        session.close()


Последнее исправление: scisearcher (всего исправлений: 2)

Ответ на: комментарий от qaqa

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

scisearcher
() автор топика
Вы не можете добавлять комментарии в эту тему. Тема перемещена в архив.