MongoDB Unwind Error: cannot encode object of type: <class 'set'>

Question

希望你一切都好。

我似乎找不到通过 'equity id' 聚合以下文档的方法。

{
    "_id": {
        "$oid": "6001dc246192c700013e8252"
    },
    "user": "blablabla",
    "_type": "User::Individual",
    "created_at": {
        "$date": "2021-01-15T18:17:11.130Z"
    },
    "integrations": [{
        "_id": {
            "$oid": "6001dc62e7a0970001258da8"
        },
        "status": "completed",
        "authentication_failed_msg": null
    }],
    "portfolios": [{
        "_id": {
            "$oid": "6001dc62e7a0970001258da9"
        },
        "_type": "SimplePortfolio",
        "transactions": [{
            "_id": {
                "$oid": "6001dc62e7a0970001258daa"
            },
            "settlement_period": 2,
            "expenses": 0,
            "source": "integration",
            "_type": "Transaction::Equity::Buy",
            "date": {
                "$date": "2020-03-02T00:00:00.000Z"
            },
            "shares": 100,
            "price": 13.04,
            "equity_id": "abcd"
        }, {
            "_id": {
                "$oid": "6001dc62e7a0970001258dab"
            },
            "settlement_period": 2,
            "expenses": 0,
            "source": "integration",
            "_type": "Transaction::Equity::Buy",
            "date": {
                "$date": "2020-03-02T00:00:00.000Z"
            },
            "shares": 1000,
            "price": 1.03,
            "equity_id": "efgh"

我试过

db.collection.aggregate([{"$unwind": {'$portfolios.transactions'}},
                         {"$group" : {"_id": "$equity_id"}}])

出现错误InvalidDocument: cannot encode object: {'$portfolios.transactions'}, of type: <class 'set'>

理想情况下，我想要一个按 user 和 equity_id 分组的列表及其份额的总和。有谁知道这个错误是我的聚合还是文档结构导致的？

Answer 1

你应该 $unwind 两次。

db.collection.aggregate([
  {
    "$unwind": "$portfolios"
  },
  {
    "$unwind": "$portfolios.transactions"
  },
  {
    "$group": {
      "_id": "$portfolios.transactions.equity_id"
    }
  }
])

mongoplayground

MongoDB Unwind Error: cannot encode object of type: <class 'set'>

MongoDB Unwind Error: cannot encode object of type: <class 'set'>

mongodb

pymongo

mongodb-query

aggregation-framework