0
我正在運行並且pyramid
應用程序在gentic異步工作者的gunicorn容器中, 其中一個端點是通過kombu
彙集AMQP的長池端點。gevent + concurrent.futures和SQLAlchemy
如果長池withing 30秒超時返回前返回從AMQP的一些數據,我需要將其保存到Postgres的,現在的問題是:
是否確定在上下文中啓動concurrent.futures.ThreadPoolExecutor
上的應用程序在GEVENT循環中運行,並處理未來提交給執行器的SQLAlchemy會話和數據持久性?
還是我完全錯誤的思維方式?
PS DB驅動程序是psycopg2