$geowithin 与 $lookup 上的 Foriegn 集合

Question

我有两个集合 Members 和 MobileUserLocations - 每个用户的位置都保存（可以是多个）作为外部字段的 userId。

成员：

{
  _id: ObjectId("591553ffa4233a181506880c"),
  userName: "Test user"
}

MobileUserLocations：

{ _id: ObjectId("59156070a4233a1815068b6b"),
  userId: ObjectId("591553ffa4233a181506880c"),
  location: {type: "Point", coordinates: [76.9121, 10.2232]]},
  updatedOn: 2017-05-12T07:12:48.626Z,
  status: 1 
},
{ _id: ObjectId("59156070a4233a1815068b6b"),
  userId: ObjectId("591553ffa4233a181506880c"),
  location: {type: "Point", coordinates: [76.8121, 10.1232]]},
  updatedOn: 2017-05-12T07:12:48.626Z,
  status: 1 
}

我想获取半径范围内的成员 - 例如参考特定地理点 5 公里 - 例如：[10.0132295, 76.3630502]（lat,lng 格式）。

我试过了：

collection.aggregate([
                                {$match: {_id: { $ne: options.accessToken.userId }},
                                { "$lookup": {
                                    "localField": "_id",
                                    "from": "MobileUserLocations",
                                    "foreignField": "userId",
                                    "as": "userLocInfo"
                                  }
                                },
                                {
                                    $project: {
                                        _id: 1,
                                        userLocInfo: {
                                           "$filter": {
                                                "input": "$userLocInfo",
                                                "as": "userLoc",
                                                "cond": { 
                                                            "$eq": [ "$$userLoc.status", -1],  
                                                       "$$userLoc.location": {"$geoWithin": {"$centerSphere": [[76.3630502, 10.0132295], 5 / 3963.2]}}
                                                        }
                                            } 
                                        }
                                    }
                                },
                                {$unwind: "$userLocInfo"}

                      ]

但没有得到。如果我从过滤条件中删除 $geowithin，它会得到，否则不会得到。但如果我是单独查询集合，我会得到结果。

谁能知道这个问题？

Answer 1

这不起作用，因为$geoWithin 不是“逻辑运算符”，而是“查询运算符”，并且只能在使用$match 的聚合管道中使用。对您来说幸运的是，这确实是您想要的。虽然你还不明白为什么：

collection.aggregate([
  { "$match": { 
    "_id": { "$ne": options.accessToken.userId }
  }},
  { "$lookup": {
    "localField": "_id",
    "from": "MobileUserLocations",
    "foreignField": "userId",
    "as": "userLocInfo"
  }},
  { "$unwind": "$userLocInfo" },
  { "$match": {
    "userLocInfo.status": -1, 
    "userLocInfo.updatedOn": "2017-05-12T12:11:04.183Z", 
    "userLocInfo.location": {
      "$geoWithin": {
        "$centerSphere": [[76.3630502, 10.0132295], 5 / 3963.2]
      }
    }
  }}
])

除了它是唯一的工作方式之外，还有一个非常好的理由。要了解，请查看"explain" 输出：

    {
        "$lookup" : {
            "from" : "MobileUserLocations",
            "as" : "userLocInfo",
            "localField" : "_id",
            "foreignField" : "userId",
            "unwinding" : {
                "preserveNullAndEmptyArrays" : false
            },
            "matching" : {
                "$and" : [ 
                    {
                        "status" : {
                            "$eq" : -1.0
                        }
                    }, 
                    {
                        "updatedOn" : {
                            "$eq" : "2017-05-12T12:11:04.183Z"
                        }
                    }, 
                    {
                        "location" : {
                            "$geoWithin" : {
                                "$centerSphere" : [ 
                                    [ 
                                        76.3630502, 
                                        10.0132295
                                    ], 
                                    0.00126160678239806
                                ]
                            }
                        }
                    }
                ]
            }
        }
    }

这表明$unwind 和关注$match 都被$lookup 舞台本身所吸引。这意味着$geoWithin和其他条件实际上是在外部集合上执行“之前”返回结果。

这就是$lookup 处理可能超过 16MB 限制的结果连接的方式。这也是目前“过滤”连接结果的最有效方式。

所以这才是你真正想要在这里做的。

---

根据您问题中的数据，此声明：

db.members.aggregate([
  { "$lookup": {
    "localField": "_id",
    "from": "MobileUserLocations",
    "foreignField": "userId",
    "as": "userLocInfo"
  }},
  { "$unwind": "$userLocInfo" },
  { "$match": {
    "userLocInfo.location": {
      "$geoWithin": {
        "$centerSphere": [[76.9121, 10.2232], 5 / 3963.2]
      }
    }
  }}
])

过滤掉$lookup 中与约束匹配的一个位置：

/* 1 */
{
    "_id" : ObjectId("591553ffa4233a181506880c"),
    "userName" : "Test user",
    "userLocInfo" : {
        "_id" : ObjectId("59c3c37359f55d64d6e30297"),
        "userId" : ObjectId("591553ffa4233a181506880c"),
        "location" : {
            "type" : "Point",
            "coordinates" : [ 
                76.9121, 
                10.2232
            ]
        },
        "updatedOn" : ISODate("2017-05-12T07:12:48.626Z"),
        "status" : 1.0
    }
}