1

Hueyを単純なピラミッド アプリと統合しています。アプリでグローバル SQLAlchemy セッションを使用していません (最新の Alchemy scaffold を使用しています)。ただし、定期的なタスクにセッションを提供する簡単な方法は他にないようです。

from huey import RedisHuey

huey = RedisHuey(password=os.environ.get('REDIS_PASSWORD', ''))
DBSession = scoped_session(sessionmaker())


@huey.periodic_task(crontab(minute='*/1'))
def notify_not_confirmed_assignments():
    # TODO: Use a non-global DB session
    assignments = DBSession.query(Assignment).filter_by(date=next_date).all()

Huey は、タスクの完了時に DB 接続を閉じるためのフックを提供しますか? これらのタスクにスレッドセーフな接続を提供する最善の方法は何ですか?

前もって感謝します!

4

2 に答える 2