问：

将 json 管道转换为 Aggify 查询

这是我的管道，我怎样才能将其转换为Aggify查询

我需要通过使用 aggify 生成器（一个 python 包）来简化我的一些查询，以便可以读取它并且我可以更快地查询。但是我在某些方面有问题，比如这个问题，有点复杂

加重 ： https://github.com/Aggify/aggify

from mongoengine import Document, fields


class DiscussionDocument(Document):
    network_id = fields.ObjectIdField()
    post = fields.ReferenceField('PostDocument', db_field='post_id')
    parent = fields.ReferenceField('self', db_field='parent_id')
    owner = fields.ReferenceField('AccountDocument', db_field='owner_id')
    body = fields.StringField()
    stat = fields.EmbeddedDocumentField(DiscussionStat)
    is_pinned = fields.BooleanField()
    weight = fields.IntField()
    deleted_at = fields.LongField()

    meta = {
        'collection': 'discussion',
        'indexes': ['post', 'parent', 'owner', 'deleted_at'],
        'ordering': ['-_id'],
    }


pipeline = [
    {'$match': {'owner_id': ObjectId(account_id)}},
    {
        '$lookup': {
            'from': 'discussion',
            'let': {'id': '$_id'},
            'pipeline': [
                {
                    '$match': {
                        '$expr': {
                            '$and': [
                                {'$eq': ['$parent_id', '$$id']},
                                {'$ne': ['$owner_id', ObjectId(account_id)]},
                            ]
                        }
                    }
                }
            ],
            'as': 'replies',
        }
    },
]