如何使用 mongodb 聚合添加自定义字段？

Posted 2023-03-16

【中文标题】如何使用 mongodb 聚合添加自定义字段？

【英文标题】：How to add a custom field using mongo aggregation?

【发布时间】：2021-06-12 16:17:28

【问题描述】：

我收藏的一个文档的结构如下：

    "tracking": [
        
            "track_id": "abcd",
            "track_name": "Sample track"
        , ..., ...
    ]

我在一个名为 tracking 的数组中有多个这样的对象。现在我正在尝试使用 mongo 聚合添加一个名为 current_status 的字段，如下所示：

        
            "$addFields": 
                "current_status": 
                    "$cond": 
                        "if": "tracking.track_id": "$in": ['abcd'],
                        "then": "Approved",
                        "else": "Pending"
                    
                
            
        

运行后，我收到以下错误：

pymongo.errors.OperationFailure: Invalid $addFields :: caused by :: FieldPath field names may not contain '.'.

我想根据 track_id abcd 的对象是否存在于跟踪数组中，在 Mongo 聚合查询的结果中添加一个新字段。

【问题讨论】：

尝试使用“tracking$track_id”

不工作，抛出以下错误 pymongo.errors.OperationFailure: Invalid $addFields :: 由 :: Expression $in 引起，正好需要 2 个参数。 1 个被传入。

使用"if": "$in": ["$tracking.track_id", ['abcd'], 你混合了docs.mongodb.com/manual/reference/operator/query/in/index.html 和docs.mongodb.com/manual/reference/operator/aggregation/in/…

谢谢@WernfriedDomscheit，它正在工作

【参考方案1】：

试试这个：

db.collection.aggregate([
    
        "$addFields": 
            "tracking": 
                "$map": 
                    "input": "$tracking",
                    "as": "item",
                    "in": 
                        "$cond": 
                            "if":  "$eq": ["$$item.track_id", "abcd"] ,
                            "then": 
                                "track_id": "$$item.track_id",
                                "track_name": "$$item.track_name",
                                "current_status": "Approved"
                            ,
                            "else": 
                                "track_id": "$$item.track_id",
                                "track_name": "$$item.track_name",
                                "current_status": "Pending"
                            
                        
                    
                
            
        
    
])

输出：

    "_id" : ObjectId("604f50859ee8b82dd8cd9f4a"),
    "tracking" : [
        
            "track_id" : "abcd",
            "track_name" : "Sample track 1",
            "current_status" : "Approved"
        ,
        
            "track_id" : "fdsdf",
            "track_name" : "Sample track 2",
            "current_status" : "Pending"
        
    ]

【讨论】：

感谢您回复 Dheemanth，但我从上面的 cmets 得到了答复