龙卷风：如何共享多个请求的pymongo连接？

我想共享多个请求的MongoDB连接。这是我现在拥有的，但看起来它为每个请求创建一个新的连接。龙卷风：如何共享多个请求的pymongo连接？

dbasync = asyncmongo.Client(pool_id='mydb', host='127.0.0.1', port=27017, maxcached=10, maxconnections=50, dbname='bench') 

@route('/readAsync') 
class ReadAllAsynchHandler(tornado.web.RequestHandler): 
    @tornado.web.asynchronous 
    def get(self):   
     print("getting sessions") 
     dbasync["ss"].find({}, callback=self._on_response) 

    def _on_response(self, response, error): 
     print("on response: %s" % response) 
     if error: 
      raise tornado.web.HTTPError(500) 
     self.finish(SS_TEMPLATE.generate(sessions=response))

当1000个并发客户端标杆，我得到这些错误：

Traceback (most recent call last): 
    File "/home/ubuntu/envs/myproj/local/lib/python2.7/site-packages/tornado/web.py", line 1115, in _stack_context_handle_exception 
    raise_exc_info((type, value, traceback)) 
    File "/home/ubuntu/envs/myproj/local/lib/python2.7/site-packages/tornado/web.py", line 1298, in wrapper 
    result = method(self, *args, **kwargs) 
    File "bench.py", line 29, in get 
    dbasync["ss"].find({}, callback=self._on_response) 
    File "/home/ubuntu/envs/myproj/local/lib/python2.7/site-packages/asyncmongo/cursor.py", line 380, in find 
    connection = self.__pool.connection() 
    File "/home/ubuntu/envs/myproj/local/lib/python2.7/site-packages/asyncmongo/pool.py", line 116, in connection 
    raise TooManyConnections("%d connections are already equal to the max: %d" % (self._connections, self._maxconnections)) 
TooManyConnections: 50 connections are already equal to the max: 50 

DEBUG:root:dropping connection. connection pool (10) is full. maxcached 10

来源

2013-09-22 lairtech

的maxconnections参数不起到缓冲了请求由现有的连接池被重新使用。相反，它只是确保如果需要，您的应用程序不会消耗无限量的资源。有关此行为的更多讨论，请参阅https://github.com/bitly/asyncmongo/pull/45。此拉取请求似乎提供您所需的行为。你可以安装asyncmongo使用像他的修订：

pip install git+git://github.com/ceymard/[email protected]

或者，你可能能够并发连接数的某处限制为您的应用程序在龙卷风的设置，或者通过，也就是说，nginx的（见HttpLimitConnModule ）

来源

2013-09-23 17:20:24 danielhfrank

龙卷风：如何共享多个请求的pymongo连接？

回答

相关问题