如何比较两个集合中的两个值 - pymongo？

Question

我有两个收藏。 例如;

collection1: 
[
  {
    _id: ObjectId("6253492b634e9f3970c5dc86"),
    ID: 90448,
    Name: 'Hostname1',
    Identifier: 'hostname_example1'
  },
  {
    _id: ObjectId("6253492b634e9f3970c5dc87"),
    ID: 66062,
    Name: 'Hostname2',
    Identifier: 'hostname_example2'
  },
  {
    _id: ObjectId("6253492b634e9f3970c5dc88"),
    ID: 56415,
    Name: 'Hostname3',
    Identifier: 'hostname_example3'
  },
  {
    _id: ObjectId("6253492b634e9f3970c5dc89"),
    ID: 84576,
    Name: 'Hostname4',
    Identifier: 'hostname_example4'
  }
]

collection2 =
[
  {
    _id: ObjectId("625350ff09043895b2c3b2d3"),
    flowSourceType: 'Unix',
    flowHostname: 'flowHostname1',
    flowIPd: '11.11.11.11'
  },
    {
    _id: ObjectId("625350ff09043895b2c3b2d3"),
    flowSourceType: 'Unix',
    flowHostname: 'hostname_example2',
    flowIPd: '12.12.12.12'
  },
    {
    _id: ObjectId("625350ff09043895b2c3b2d3"),
    flowSourceType: 'Unix',
    flowHostname: 'hostname_example3',
    flowIPd: '13.13.13.13'
  },
]

我需要这样的比较：

我想搜索-collections1-中标识符的“ flowhostname'-collections2-”的值。 （我的目标是在这里有两件事，1。等于2。包含） 在上面的示例中，我想获取以下数据。

result=
[
    {
    _id: ObjectId("625350ff09043895b2c3b2d3"),
    flowSourceType: 'Unix',
    flowHostname: 'hostname_example2',
    flowIPd: '12.12.12.12'
  },
    {
    _id: ObjectId("625350ff09043895b2c3b2d3"),
    flowSourceType: 'Unix',
    flowHostname: 'hostname_example3',
    flowIPd: '13.13.13.13'
  },
]

如果我以某种方式获得比赛对我来说就足够了。

我该如何使用Python的Pymongo进行操作？

Answer 1

只需将相等的$或条件放在第一个$ match阶段的条件中。您可以使用$ limit：1来提高性能。

db.collection2.aggregate([
  {
    "$lookup": {
      "from": "collection1",
      "let": {
        f: "$flowHostname"
      },
      pipeline: [
        {
          "$match": {
            $expr: {
              $or: [
                {
                  $eq: [
                    "$f",
                    "$Identifier"
                  ]
                },
                {
                  $ne: [
                    {
                      "$indexOfCP": [
                        "$Identifier",
                        "$f"
                      ]
                    },
                    -1
                  ]
                }
              ]
            }
          }
        },
        {
          $limit: 1
        }
      ],
      "as": "col1Lookup"
    }
  },
  {
    "$unwind": "$col1Lookup"
  },
  {
    "$unset": "col1Lookup"
  }
])

这是 mongo playground 供您参考。