2016-06-09 41 views
0

我正在运行并且pyramid应用程序在gentic异步工作者的gunicorn容器中, 其中一个端点是通过kombu汇集AMQP的长池端点。gevent + concurrent.futures和SQLAlchemy

如果长池withing 30秒超时返回前返回从AMQP的一些数据,我需要将其保存到Postgres的,现在的问题是:

是否确定在上下文中启动concurrent.futures.ThreadPoolExecutor上的应用程序在GEVENT循环中运行,并处理未来提交给执行器的SQLAlchemy会话和数据持久性?

还是我完全错误的思维方式?

PS DB驱动程序是psycopg2

回答

0

在我的高并发应用程序中使用ThreadPoolExecutorgevent我可以证实,这工作正常后。

但是,如果DB驱动程序已经是不必要的,如“友好”,如:psycogreen