python - pymongo 无法使用多线程

Question

下面的代码不管是在python2.6还是python3.2中都不行。

测试代码:

import pymongo

class A(Thread):  
        def __init__(self):  
            Thread.__init__(self)  
            self.conn = pymongo.Connection('localhost',30000)  
            self.mongo = self.conn.puppet  
            self.mongo.authenticate('test','123')  
        def run(self):  
            print self.mongo.href.find_one()  

A().start()

异常信息:

 OperationFailure: database error: unauthorized db:puppet lock
   type:-1 client:127.0.0.1  

有什么解决办法吗？

Answer 1

这可能是由于 pymongo 中身份验证的处理方式，参见 note in the API docs - Pymongo 不会在线程之间缓存身份验证凭据，因此每个线程都必须单独进行身份验证。