mongodb - PDI Kettle - 如何在 MongoDB 输出中为查询匹配指定 ObjectId

Question

使用 PDI Kettle MongoDB 输出，我试图通过查询 _id (ObjectId) 字段来更新 mongodb 文档。如果我将 _id 变量作为字符串传递给 MongoDB 输出步骤，则创建的最终查询看起来像

    Modifier update query:

{
  "_id" : "<string val>"
}

最终可能会变成类似的东西

    Modifier update query:

{
  "_id" : "579c18b47f34b4330f85a981"
}

这可能导致查询找不到文档并且更新失败并出现错误“没有为修饰符更新操作指定要更新的字段!”

有什么方法可以指定如下查询吗？

{"_id" : ObjectId(579c18b47f34b4330f85a981)}

还是我看到错误是因为其他原因？

请找到“mongo 文档字段”选项卡的屏幕截图。

Answer 1

首先，您可以使用“Javascript”步骤将“_id”值转换为 JSON 格式:

_id = '{ "$oid": "' + _id + '" }'

然后在“MongoDB 输出”步骤的最后一行中，您应该将 JSON 属性设置为 Y。