如何修改MuleSoft DataWeave代码实现MongoDB的$match与$dateToString分组

原用于统计item集合中UpdateDate字段的MongoDB聚合命令及MuleSoft DataWeave代码存在两个核心问题：

• 未过滤最近5天的数据，导致全量扫描集合，性能损耗大
• 分组时未剥离时间戳，同一日期的记录会被拆分为多条分组结果，统计结果不准确

以下命令通过$match过滤最近5天数据，并用$dateToString统一日期格式，解决上述问题：

db.item.aggregate([
  // 过滤最近5天的数据
  {
    $match: {
      UpdateDate: {
        $gte: new Date(Date.now() - 5 * 24 * 60 * 60 * 1000)
      }
    }
  },
  // 格式化日期，去除时间戳
  {
    $project: {
      formattedDate: {
        $dateToString: { format: "%Y-%m-%d", date: "$UpdateDate" }
      }
    }
  },
  // 按格式化后的日期分组统计
  {
    $group: {
      _id: "$formattedDate",
      count: { $sum: 1 }
    }
  },
  // 按日期升序排序
  {
    $sort: { _id: 1 }
  }
])

以下代码动态适配从属性获取的日期字段（运行时注入为UpdateDate），实现与上述MongoDB命令一致的逻辑：

%dw 2.0
output application/json
// 从属性动态获取日期字段名，默认值为UpdateDate
var targetDateColumn = attributes.datecolumn default "UpdateDate"
// 计算5天前的时间点
var fiveDaysPrior = now() - |P5D|
---
{
  aggregate: [
    // 过滤最近5天的数据
    {
      "$match": {
        (targetDateColumn): {
          "$gte": fiveDaysPrior as DateTime { format: "yyyy-MM-dd'T'HH:mm:ss.SSS'Z'" }
        }
      }
    },
    // 格式化日期，剥离时间戳
    {
      "$project": {
        "formattedDate": {
          "$dateToString": {
            "format": "%Y-%m-%d",
            "date": "$" ++ targetDateColumn
          }
        }
      }
    },
    // 按格式化日期分组统计数量
    {
      "$group": {
        "_id": "$formattedDate",
        "count": { "$sum": 1 }
      }
    },
    // 按日期升序排序结果
    {
      "$sort": { "_id": 1 }
    }
  ]
}

关键逻辑说明 #

• targetDateColumn通过属性动态获取统计字段，确保运行时可灵活配置为UpdateDate或其他日期字段
• fiveDaysPrior使用DataWeave的时间计算语法生成5天前的时间，避免硬编码时间戳
• 动态字段引用(targetDateColumn)确保$match和$dateToString阶段能正确指向目标日期字段
• $dateToString将日期统一为YYYY-MM-DD格式，保证同一日期的记录被归为同一分组

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