python - 在 Pymongo 中将聚合中间结果字段作为 python 函数参数传递

Question

使用 MongoDB 4.0 我必须根据现有字段计算一个新字段。mycollection 中的文档示例：

{
    _id: ...,
    f1: 'a',
    f2: 'b'
}

我的python代码，连接到数据库后：

请注意，myJoin这里只是举例。在实际使用场景中，此功能非常复杂（自定义加密计算和字节操作）。

def myJoin(left, right):
  return left+'-myDelimiter-'+right


myPipeline = [
    {
        '$match': {
            'f1': {
                '$exists': True
            }
        }
    }, {
        '$addFields': {
            'f3': myJoin('$f1', '$f2')
        }
    }
]

mydb.mycollection.aggregate(myPipeline)

但是在数据库中我看到：

{
    _id: ...,
    f1: 'a',
    f2: 'b',
    f3: '$f1-myDelimiter-$f2'
}

但我想要：

{
    _id: ...,
    f1: 'a',
    f2: 'b',
    f3: 'a-myDelimiter-b'
}

目前我正在使用管道聚合。但也欢迎其他策略。

Answer 1

您可以使用$concat运算符来连接带有分隔符的字段，

{
  '$addFields': {
    'f3': { '$concat': ['$f1', '-myDelimiter-', '$f2'] }
  }
}

例如，我使用了 myJoin。我的自定义函数执行一系列加密计算和字节操作。

我认为不可能在当前的 MongoDB v4.4 中集成到 python lang 的查询中，

从 MongoDB 4.4 开始有一个$functionjavascript运算符，您可以在那里编写代码并在查询中执行，但是查询性能很昂贵。

我建议您在查询结果后执行此操作。