管道中的$匹配项会怎样？

Question

我是MongoDB和Python脚本的新手。我很困惑$匹配术语在管道中处理。

假设我管理了一个库，在该图书馆中，在其中跟踪书籍中的JSON文件。每本书的副本都有一个JSON。 book.json文件看起来像这样：

{
    "Title": "A Tale of Two Cities",
    "subData":
        {
            "status": "Checked In"
            ...more data here...
        }
}

status将是有限字符串的一个字符串，也许只是：{{'''ined in in'，“ nocked ofer”，“ nocked”，“丢失”，等等。 }但还请注意，可能没有状态字段：

{
    "Title": "Great Expectations",
    "subData":
        {
            ...more data here...
        }
}

好的：我试图在Python脚本中编写MongoDB管道，该脚本执行以下操作：

• 对于库中的每本书：
  • 分组并计算状态的不同实例字段

，因此我的Python脚本中的目标输出将是这样的：

{ "A Tale of Two Cities"   'Checked In'    3 }
{ "A Tale of Two Cities"   'Checked Out'   4 }
{ "Great Expectations"     'Checked In'    5 }
{ "Great Expectations"     ''    7 }

这是我的代码：

mydatabase = client.JSON_DB
mycollection = mydatabase.JSON_all_2

listOfBooks = mycollection.distinct("bookname")
for book in listOfBooks:
    match_variable = {
        "$match": { 'Title': book }
    }
    group_variable = {
        "$group":{
            '_id': '$subdata.status',
            'categories' : { '$addToSet' : '$subdata.status' },
            'count': { '$sum': 1 }
        }
    }
    project_variable = {
        "$project": {
            '_id': 0,
            'categories' : 1,
            'count' : 1
        }
    }
    pipeline = [
        match_variable,
        group_variable,
        project_variable
    ]
    results = mycollection.aggregate(pipeline)
    for result in results:
        print(str(result['Title'])+"  "+str(result['categories'])+"  "+str(result['count']))

您可能会说，我几乎不知道我是什么正在做。当我运行代码时，我会发现一个错误，因为我试图引用我的$ match术语：

Traceback (most recent call last):
  File "testScript.py", line 34, in main
    print(str(result['Title'])+"  "+str(result['categories'])+"  "+str(result['count']))
KeyError: 'Title'

那么$ match项不包含在管道中？或者我不是在group_variable或project_variable中包括它吗？

总的来说，上述似乎有很多代码可以做一些相对容易的事情。有人看到更好的方法吗？它很容易在线找到简单的示例，但这是与我可以找到的任何内容相比，这是复杂的一步。谢谢。

Answer 1

这是一个聚合管道到“ $ group” ast “ title”和“ subdata .status“。

db.collection.aggregate([
  {
    "$group": {
      "_id": {
        "Title": "$Title",
        "status": {"$ifNull": ["$subData.status", ""]}
      },
      "count": { "$count": {} }
    }
  },
  { // not really necessary, but puts output in predictable order
    "$sort": {
      "_id.Title": 1,
      "_id.status": 1
    }
  },
  {
    "$replaceWith": {
      "$mergeObjects": [
        "$_id",
        {"count": "$count"}
      ]
    }
  }
])

其中一个“书籍”的示例输出：

  {
    "Title": "mumblecore",
    "count": 3,
    "status": ""
  },
  {
    "Title": "mumblecore",
    "count": 3,
    "status": "Checked In"
  },
  {
    "Title": "mumblecore",
    "count": 8,
    "status": "Checked Out"
  },
  {
    "Title": "mumblecore",
    "count": 6,
    "status": "Missing"
  }

在。