0
我正在运行并且pyramid
应用程序在gentic异步工作者的gunicorn容器中, 其中一个端点是通过kombu
汇集AMQP的长池端点。gevent + concurrent.futures和SQLAlchemy
如果长池withing 30秒超时返回前返回从AMQP的一些数据,我需要将其保存到Postgres的,现在的问题是:
是否确定在上下文中启动concurrent.futures.ThreadPoolExecutor
上的应用程序在GEVENT循环中运行,并处理未来提交给执行器的SQLAlchemy会话和数据持久性?
还是我完全错误的思维方式?
PS DB驱动程序是psycopg2