Django 函数返回 MongoDB 聚合管道的结果

Question

如果有人能帮我解决这个问题，我将不胜感激。我需要Django(Python(函数将一些参数注入到管道脚本中，将其传递给MongoDB Atlas并在游标中接收结果。

from bson import ObjectId
import pymongo
conn = "connection string"
client = pymongo.MongoClient(conn) 
pipeline = [
<<pipeline script>>
]
out = client.db.mycollection.aggregate(pipeline)

Answer 1

如果你使用 Djongo 将 Django ORM 连接到 MongoDB，你可以使用提供的 DjongoManager 作为模型的管理器，并使用mongo_前缀使用 PyMongo 函数。下面是一个快速示例：

models.py

from djongo import models
class Message(models.Model):
text = models.CharField(max_length=150)
objects = models.DjongoManager()

然后在 shell 中，您可以执行以下操作：

>>> from core.models import *
>>> cursor = Message.objects.mongo_aggregate('pipeline')