在烧瓶中使用芹菜会导致警告: MongoClient在叉子之前打开

Question

当我在Flask中使用Celery-schedule任务将redis中的数据保存到mongoDB时，Celery会发出一条警告消息：

[2021-07-11 17:01:19,092: WARNING/ForkPoolWorker-2] 
/home/moluo/anaconda3/envs/mofang/lib/python3.8/site- 
packages/pymongo/topology.py:161: UserWarning: MongoClient opened before fork. 
Create MongoClient only after forking. See PyMongo's documentation for 
details: https://pymongo.readthedocs.io/en/stable/faq.html#is-pymongo-fork-safe

导致警告的代码：

import orjson
from application import celery,redis_tree
from .documents import UserTreeDocument

@celery.task(name="save_user_tree")
def save_user_tree():
    all_user_doc = UserTreeDocument.objects.only('user_id').all()
    for doc in all_user_doc:
        tree_info = orjson.loads(redis_tree.get(f"tree_{doc.user_id}"))
        doc.update(**tree_info)

任务运行正常，但只有警告代码。如何修复警告？

我的英语不是很好。如果我的描述不清楚，很抱歉。

Answer 1

维修计划：MONGODB_CONNECT = False

我已经自己修复了这个问题~文档上说：

默认情况下，flask-mongoengine在扩展被实例化时打开连接，但是您可以通过将MONGODB_SETTINGS‘’connect‘参数或其等同于False的MONGODB_CONNECT平面设置为False，将其配置为仅在首次访问数据库时打开连接