在PyMongo中，MongoClient的maxPoolSize=100的默认值无效？

Question

以下是PyMongo连接的简单测试片段：

from pymongo import MongoClient

clients = [] 
for i in range(0,1000):
    con = MongoClient('mongodb://localhost:27017/')
    clients.append(con)
    print(i)

以下是输出：

......998 999

以下是MongoDB控制台中的输出：

2018-03-24T20:00:55.746 0530 I网络[listener]连接已从127.0.0.1:51272#1500（现在有1000个连接打开）接受2018-03-24T20:00:55.747 0530 I网络[conn1500]从127.0.0.1:51272 conn:{驱动程序：{名称：“PyMongo”，版本：“3.6.1”，操作系统：{type:“Darwin”，名称：“Darwin”，体系结构：“x86_64”，版本：“10.1”}，平台：“CPython 3.6.0.final.0”}2018-03-24T20:00:55.773 0530 I网络[conn1486]端连接127.0.0.1:51286（999个连接现在打开）2018-03-24T20:00:55.773 0530 I网络[conn1485]端连接127.0.0.1:51285（998个连接现在打开）2018-03-24T20:00:55.773 0530 I网络[conn1484]端连接127.0.0.1:51284（997个连接现在打开）。

我看到MongoClient有一个关键字参数maxPoolSize。默认值只有100。

但是上面的代码是如何工作的呢？

Answer 1

MongoClient有一个关键字参数maxPoolSize。默认值只有100。

没错。PyMongo（从v3.6开始）MongoClient中的maxPoolSize默认值为100。但是，maxPoolSize参数控制每个MongoDB服务器上MongoClient实例的最大内置连接池。

您的示例片段创建了1000个MongoClient实例。请注意，每个进程只需要一个MongoClient，并将其重用于所有操作。为每个请求创建一个新客户端是一个常见的错误，这是非常低效的。

但是上面的代码是如何工作的呢？

如果您想检查限制是否有效，可以使用Python线程模块创建线程来测试MongoClient连接的限制。

您还可以使用另外两个参数：

>

waitQueueTimeoutMS：此参数设置线程在从池中获得连接之前应在队列中等待多长时间。通过设置低maxPoolsize和低waitQueueTimeoutMS您的代码将收到ConnectionFailure异常。

例子：

def worker(num, db): 
    print("Thread number %s" % num)
    try:
        print(db.test.insert({"a":num, "b":num*2}))
    except Exception as e: 
        print("Exception: %s" % e)
    return 

client = MongoClient("mongodb://localhost:27017/", 
                     maxPoolSize=1, 
                     waitQueueTimeoutMS=1, 
                     waitQueueMultiple=1)
database = client.test
threads = []

for i in range(100): 
    t = threading.Thread(target=worker, args=(i, database))
    threads.append(t) 
    # Start thread.
    t.start()

# Wait for all threads to complete. 
for t in threads: 
    t.join() 

看看连接池在PyMongo中是如何工作的？更多细节。请使用提供的默认值，除非您有需要更改上述值的特定用例。