MongoDB Charts导出代码在NodeJS运行报pipeline参数错误如何解决

MongoInvalidArgumentError: Argument "pipeline" must be an array of aggregation stages报错由两个写法问题导致：

1. MongoDB Node.js驱动的aggregate()方法入参要求直接传入聚合阶段组成的数组，直接传入MongoDB Charts导出的完整前端配置对象时，对象里的isFetching、isOpen都是Charts页面的UI状态字段，不属于聚合管道语法，驱动无法识别。
2. 导出代码里的{"$oid": "xxx"}是MongoDB Extended JSON的序列化格式，在Node.js驱动代码中不能直接使用，需要替换为驱动提供的ObjectId实例。

• 提取配置对象中pipeline字段对应的数组，直接作为aggregate()的入参，删掉外层包裹的UI状态字段
• 将$match阶段中campaignID的$oid写法，替换为new ObjectId("对应ID字符串")的标准写法
• 额外优化：代码中重复声明了clientPromise，既然已经从../../lib/mongodb导入了封装好的连接实例，不需要重复写MongoClient连接逻辑，避免重复创建数据库连接。

import clientPromise from "../../../../lib/mongodb";
import { ObjectId } from 'mongodb'

export default async function overview(req, res) {
  try {
    const client = await clientPromise;
    const database = client.db('DATABASE');
    const nowplayingstats = database.collection('NowPlaying');

    const search = await nowplayingstats.aggregate([
      {
        "$match": {
          "campaignID": new ObjectId("629d7fb4b0697d84aa7043ee")
        }
      },
      {
        "$addFields": {
          "__alias_0": {
            "$cond": {
              "if": {
                "$isArray": "$history"
              },
              "then": {
                "$size": "$history"
              },
              "else": 0
            }
          }
        }
      },
      {
        "$addFields": {
          "timeplay": {
            "$cond": {
              "if": {
                "$eq": [
                  {
                    "$type": "$timeplay"
                  },
                  "date"
                ]
              },
              "then": "$timeplay",
              "else": null
            }
          }
        }
      },
      {
        "$addFields": {
          "__alias_1": {
            "year": {
              "$year": "$timeplay"
            },
            "month": {
              "$subtract": [
                {
                  "$month": "$timeplay"
                },
                1
              ]
            },
            "date": {
              "$dayOfMonth": "$timeplay"
            }
          }
        }
      },
      {
        "$group": {
          "_id": {
            "__alias_1": "$__alias_1"
          },
          "__alias_0": {
            "$sum": "$__alias_0"
          }
        }
      },
      {
        "$project": {
          "_id": 0,
          "__alias_1": "$_id.__alias_1",
          "__alias_0": 1
        }
      },
      {
        "$project": {
          "x": "$__alias_1",
          "y": "$__alias_0",
          "_id": 0
        }
      },
      {
        "$sort": {
          "x.year": 1,
          "x.month": 1,
          "x.date": 1
        }
      },
      {
        "$limit": 5000
      }
    ]).toArray();
  
    res.json(search)
  } catch (err) {
    res.status(500).json({ error: err.message })
  }
}

补充说明：MongoDB Charts导出的代码默认是给Charts内嵌渲染使用的配置，不是直接可运行的Node.js驱动代码，不能直接复制粘贴到服务端逻辑中使用。

内容的提问来源于stack exchange，提问作者Russell Harrower