MongoDB 4.4迁移至Amazon DocumentDB 4.0：批量写入更新报错求助

问题背景 #

从MongoDB 4.4.0迁移至Amazon DocumentDB 4.0后，Java API执行批量更新操作时持续报错。原代码使用bulkWrite触发错误，改为updateMany后仍无法正常执行。

原bulkWrite代码 #

private final MongoDAO statisticsDBService; // 构造函数注入
List<WriteModel<Document>> statsBulkWrites = new ArrayList<>();

MongoCollection<Document> collection = statisticsDBService.getCollection();
collection.bulkWrite(statsBulkWrites);

批量更新操作示例（statsBulkWrites） #

[
  {"$set": {"months": "$months"}}, 
  {"$set": {"months": {"$concatArrays": [{"$filter": {"input": "$months", "cond": {"$not": [{"$in": ["$$this.date", [{"$numberLong": "0000000000000"}]]}]}}}, {"$map": {"input": [{"$numberLong": "0000000000000"}], "in": {"$cond": [{"$in": ["$$this", "$months.date"]}, {"date": "$$this", "value": {"$sum": [{"$arrayElemAt": ["$months.value", {"$indexOfArray": ["$months.date", "$$this"]}]}, {"$numberLong": "000000"}]}}, {"date": "$$this", "value": {"$numberLong": "000000"}}]}}}]}}},
  {"$set": {"sum": {"$sum": "$years.value"}}}
]

错误信息 #

1. 使用bulkWrite时的错误：

com.mongodb.MongoBulkWriteException: Bulk write operation error on server a207849-mktp-docdb-cluster2.csahjzki9umq.us-east-1.docdb.amazonaws.com:27017. 
Write errors: [BulkWriteError{index=0, code=14, message='Wrong type for parameter u', details={}}]. 
    at com.mongodb.connection.BulkWriteBatchCombiner.getError(BulkWriteBatchCombiner.java:173)
    ...（栈跟踪省略）

2. 改为updateMany后的错误：

com.mongodb.MongoWriteException: Document can't have $ prefix field names: $concatArrays
    at com.mongodb.client.internal.MongoCollectionImpl.executeSingleWriteRequest(MongoCollectionImpl.java:1055)
    ...（栈跟踪省略）

错误原因分析 #

• bulkWrite报错：DocumentDB 4.0对批量写入中包含聚合表达式的更新操作支持有限，与MongoDB 4.4的兼容性存在差异，错误码14本质是DocumentDB无法解析bulkWrite中的嵌套聚合式更新逻辑。
• updateMany报错：直接将WriteModel<Document>对象传入updateMany是错误用法，updateMany需要的是UpdateDefinition类型参数，而非原始的更新操作文档，导致解析时将聚合操作符识别为非法字段名。

解决方案 #

1. 修正updateMany调用方式 #

将原WriteModel中的更新逻辑转换为UpdateDefinition，使用MongoDB Java驱动的Updates工具类构建合法的更新对象：

// 遍历原批量更新集合
for (WriteModel<Document> writeModel : statsBulkWrites) {
    // 提取UpdateOneModel/UpdateManyModel中的更新文档
    if (writeModel instanceof UpdateOneModel) {
        UpdateOneModel<Document> updateModel = (UpdateOneModel<Document>) writeModel;
        Document updateDoc = updateModel.getUpdate();
        // 将原生Document转换为UpdateDefinition
        UpdateDefinition<Document> updateDef = Updates.fromDocument(updateDoc);
        // 执行updateMany（注意查询条件document需正确设置）
        statisticsDBService.getCollection().updateMany(document, updateDef);
    }
}

2. 调整聚合表达式更新逻辑 #

DocumentDB 4.0对复杂嵌套聚合操作符的支持有限，针对当前的数组更新逻辑（去重+累加/新增），可改为两种实现方式：

• 应用层处理：先查询目标文档的months数组，在Java代码中完成过滤、映射、合并逻辑，再将处理后的数组直接更新回数据库；
• 简化数据库操作：拆分为两步更新，先用$pull移除目标日期元素，再用$push添加新元素（包含累加后的值），避免使用嵌套聚合操作符。

3. 替换bulkWrite为循环单更新 #

如果DocumentDB的bulkWrite始终无法兼容复杂聚合更新，可放弃批量写入，改为循环执行单个updateOne/updateMany操作，确保每个更新逻辑都能被DocumentDB正确解析。

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