在 Flask 中使用 Celery 导致警告：MongoClient 在 fork 之前打开

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'] 参数或其 [= 将其配置为仅在首次访问数据库时打开连接19=] 等价于 False

在 Flask 中使用 Celery 导致警告：MongoClient 在 fork 之前打开

Using Celery in Flask causes warning: MongoClient opened before fork

python

mongodb

flask

celery