好的,经过一番研究,我找到了解决方案:
def _filter_by_additional_framework(collection, query):
results = collection.aggregate([
{'$limit': 1},
{'$lookup':
{
'from': 'profiles',
'pipeline': [
{'$match': {
'$text': {
'$search': f"\"{query['framework']}\" \"{query['framework2']}\""}}
},
{'$sort': {'Rating': DESCENDING}}
], 'as': 'col1'}},
{'$lookup':
{
'from': 'profiles',
'pipeline': [
{'$match': {
'$text': {
'$search': f"\"{query['framework']}\" -\"{query['framework2']}\""}}
},
{'$sort': {'Rating': DESCENDING}}
], 'as': 'col2'}},
{'$project': {'union': {'$concatArrays': ["$col1", "$col2"]}}},
{'$unwind': '$union'},
{'$replaceRoot': {'newRoot': '$union'}},
{'$project': search_result_order()},
], collation=Collation(locale="en_US", numericOrdering=True))
return results
它通过集合中的同一字段执行 2 次查找(第一个查找说 Flask AND React ('"Flask" "React"'),第二个查找 Flask AND NOT React ('"Flask" -"React" ')。我还必须向某些字段添加文本索引以执行文本查找。
此外,您可能会注意到每个管道中都有一个 $sort 表达式。这是为了额外的排序(在我的例子中是评级)。聚合的第二个参数(排序规则)用于按整数对字符串字段进行排序。因此,您可以根据需要单独对每个查询进行排序,也可以将排序表达式移出管道并对整个查询进行排序。