猫鼬

2024-09-27 00:15:58 发布

您现在位置:Python中文网/ 问答频道 /正文

我想用熊猫做一个聚合函数。我想用变量“MARCA”,“MODEL”对它们进行分组,但只对“AN_fabricie”小于2010的记录进行分组

    collection = db["clienti_daune"]
   pipeline=[
{'$group' : {
       "_id" : {"MARCA":"$MARCA","MODEL":"$MODEL"},
       "VALOARE_MANOPERA": { '$sum': "$PRET_MANOPERA" },
       "VALOARE_DAUNA": { '$sum': "$VALOARE_DAUNA" }

        }},
{'$match' : {"AN_FABRICATIE": {'$lt': 2010}}}
  ]
   cursor = collection.aggregate(pipeline)

    df  = pd.DataFrame.from_dict(list(cursor))

       cursor.close()
        pprint (df)

下面是代码,但当我放置match时,它返回空数据帧

我哪里做错了

多谢各位


Tags: 函数andfmodelpipelinematch记录cursor

热门问题