pymongo 集合对象序列化__getnewargs__方法

Question

当我尝试使用芹菜运行任务时，Pymongo 集合对象失败。我想它无法序列化它。我该怎么办？顺便说一句，我尝试了泡菜，但它对我没有帮助。

PS：我不想将全局数据库导入到此模块。

"集合"对象不可调用。如果你的意思是称"getnewargs"方法......

示例代码如下。module.py

from celery.contrib.methods import task_method

class Some_Class(object):
    """docstring for Some_Class"""
    def __init__(self, db):
        super(Some_Class, self).__init__()
        self.db = db  # This object causes 'Collection' object is not callable
        #db is a pymongo collection object from db.py

    @app.task(filter=task_method)  # Celery task
    def add(self):
        """
        db.insert({'some_key':'some_value'})
        """
        return 3

db.py

from pymongo import MongoClient    
db = MongoClient()['test']['collection']

Answer 1

不应序列化集合对象。而是存储集合名称并从任务中获取集合对象。

集合对象需要关联的已建立的MongoClient对象图可用。如果没有MongoClient，即使你以某种方式设法反序列化集合对象，它也不会工作。