Я запускаю и pyramid
приложение внутри контейнера gunicorn с асинхронными рабочими gevent, одна из конечных точек - это конечная точка с длинным пулом, объединяющая AMQP через kombu
.
Если длинный пул с 30-секундным тайм-аутом возвращает некоторые данные из AMQP, мне нужно сохранить их в postgres перед возвратом, теперь возникает вопрос:
Можно ли запускать concurrent.futures.ThreadPoolExecutor
в контексте приложения, работающего в цикле gevent, и иметь дело с сеансами SQLAlchemy и сохранением данных внутри будущего, отправленного исполнителю?
Или я совсем не прав в своих рассуждениях?
Драйвер PS DB — psycopg2.