如何通过Benthos的MongoDB输入查询ISODate类型日期字段？

背景示例 #

以下是用MongoDB Shell（mongosh）创建含ISODate字段文档的操作：

test> db.createCollection("dates")
{ ok: 1 }
test> db.dates.insertOne({"date": new Date()})
{
  acknowledged: true,
  insertedId: ObjectId('65c103d3540bd3cffe79bfcb')
}
test> db.dates.find()
[
  {
    _id: ObjectId('65c103d3540bd3cffe79bfcb'),
    date: ISODate('2024-02-05T15:50:43.826Z')
  }
]

核心解决方法 #

MongoDB中的ISODate本质是Date对象，Benthos的mongodb输入组件支持直接使用ISO 8601格式字符串或动态生成的标准日期字符串进行查询，无需手动调用ISODate()构造函数。

1. 静态日期范围查询 #

如果需要查询固定时间范围的文档，直接在Benthos配置的query字段中使用MongoDB日期操作符（如$gte、$lt）配合ISO 8601字符串：

input:
  mongodb:
    uri: "mongodb://localhost:27017"
    database: "test"
    collection: "dates"
    query: |
      {
        "date": {
          "$gte": "2024-02-05T00:00:00.000Z",
          "$lt": "2024-02-06T00:00:00.000Z"
        }
      }

2. 动态日期范围查询 #

如果需要基于当前时间生成动态条件（比如查询过去24小时的文档），可以使用Benthos的时间插值函数生成标准RFC3339格式的日期字符串：

input:
  mongodb:
    uri: "mongodb://localhost:27017"
    database: "test"
    collection: "dates"
    query: |
      {
        "date": {
          "$gte": "${!time.parse_rfc3339 \"24h ago\"}"
        }
      }

注意事项 #

• 确保日期字符串严格符合ISO 8601/RFC3339格式（如YYYY-MM-DDTHH:mm:ss.sssZ），MongoDB会自动将其解析为Date对象匹配
• 可先在mongosh中验证查询逻辑，确认返回预期结果后再移植到Benthos配置
• Benthos时间函数支持多种相对时间表达式（如"1d ago"、"30m"），可灵活调整查询范围

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