python - 如何按 mongodb 中 $geonear 聚合管道中的其他字段排序

Question

我的收藏就是这种格式。

{
    "_id" : ObjectId("52e5f94d83b45407f959e7ff"),

    "latlng" : {
        "coordinates" : [
            85.29035240000007,
            27.6663671
        ],
        "type" : "Point"
    },
    "name" : "Sujit Maharjan",
    "updates" : [
        {
            "status" : "I want to #buy 5 kg of tomatoes.",
            "picture" : [ ],
            "parent_tweet_id" : "0",
            "deleted" : 1,
            "tweet_id" : "428578269169205248",
            "time_stamp" : 1391015996
        }
        {
            "status" : "I want to #start #milk business who can help me ?",
            "picture" : [ ],
            "parent_tweet_id" : "0",
            "deleted" : 0,
            "tweet_id" : "108fd43a-7efa-404d-800d-0c30a5da06e5",
            "time_stamp" : 1391955084
        },
        {
            "status" : "@SantoshGhimire @bhanduroshan Connect to us for  #Dairy business",
            "picture" : [ ],
            "parent_tweet_id" : "432503201968168960",
            "deleted" : 1,
            "tweet_id" : "432517594026082304",
            "time_stamp" : 1391955208
        },
        {
            "status" : "@bhanduroshan Did you get my message ?",
            "picture" : [ ],
            "parent_tweet_id" : "432502654154334208",
            "deleted" : 0,
            "tweet_id" : "432788670463377408",
            "time_stamp" : 1392019838
        },
        {
            "status" : "this is tweet with images @foodtradeHQ http://t.co/3eL1351HWf",
            "picture" : [
                "http://pbs.twimg.com/media/BgLZ4YaCUAAsFTJ.jpg"
            ],
            "parent_tweet_id" : "0",
            "deleted" : 1,
            "tweet_id" : "433148076820156417",
            "time_stamp" : 1392105574
        }
    ]
}

现在我需要查询用户在一定半径内按up​​dates.time_stamp排序的更新。

为此，我使用了聚合管道，但 $geonear 查询会根据距离进行排序并限制结果。

这是我在 python 中的管道

    geo_search = {"near": [float(self.lng), float(self.lat)],
                               "distanceField": "distance",
                                "includeLocs": "latlng",
                                "uniqueDocs": True,
                                "spherical":True,
                                "limit":100,  # this will cut off the possible results, and complexity increasing in increasing this number
                            }



    pipeline = []

    final_query = {"$and":query_string}

    if len(query_string)>0:
        geo_search['query'] = final_query


    geo_search['maxDistance'] = 0.01261617096

    geo_near = {
                    "$geoNear": geo_search
                  }


    pipeline.append(geo_near)

Answer 1

与 $geoNear聚合管道阶段，这基本上执行标准类型的“nearSphere”或“near”之类的查询，但将结果文档放入管道中，并带有 distanceField 所需的附加字段。

这必须是第一个管道阶段，可以在其中使用索引:

 collection.aggregate([
     { "$geoNear": {
         "near": [ float(self.lng), float(self.lat) ],
         "maxDistance": 0.01261617096,
         "distanceField": "distance",
         "includeLocs": "latlng",
         "uniqueDocs": True,
         "spherical":True,
         "query": {
             "updates.time_stamp": {
                 "$gte": timestamp_cutoff
             }
         },
         "limit":100
     }},
     { "$sort": { "other": 1, "distance": 1 } }
])

通过管道的其余部分，现在存在“distanceField”中定义的附加字段，因此为了获得最接近的结果，请将其传递给 $sort 。您可以传递任何您想要排序的内容，因为这就是管道阶段的作用。

您基本上可以根据结果采取任何您喜欢的操作，包括其他阶段，例如 $match当然，如果其他信息与初始结果相关，那么您可以使用 $geoNear 的“查询”选项。 .

实际上，要做你想做的事情，你需要通过使用“查询”中的某些内容来“限制”可能匹配的文档，如图所示。因此，返回的“最近”文档只是那些符合附加条件的文档。