gevent + concurrent.futures和SQLAlchemy(gevent + concurrent.futures and SQLAlchemy)

 我正在使用gevent异步工作程序在gunicorn容器内运行和pyramid应用程序，其中一个端点是通过kombu汇集AMQP的长池端点。 
 
 如果具有30秒超时的长池从AMQP返回一些数据，我需要在返回之前将其保存到postgres，现在的问题是： 
 
 可以在gevent循环中运行的应用程序的上下文中启动concurrent.futures.ThreadPoolExecutor ，并在提交给执行程序的未来内处理SQLAlchemy会话和数据持久性吗？ 
 
 或者我的思维方式完全错了？ 
 
 PS DB驱动程序是psycopg2 

I'm running and pyramid app inside gunicorn container with gevent async workers, one of endpoints is a long-pool endpoint pooling AMQP via kombu.
 
If the long pool withing 30s timeout returns some data from AMQP I need to save it to postgres before returning, now the question is:
 
Is it OK to start concurrent.futures.ThreadPoolExecutor in context on app running in gevent loop, and deal with SQLAlchemy sessions and data persistence inside a future submitted to executor?
 
Or am I completely wrong in my way of thinking?
 
PS DB driver is psycopg2

原文：https://stackoverflow.com/questions/37728069