使用DynamoDB TransactWriteItems多表批量插入报错求解决方案

错误原因分析 #

你遇到的Transaction request cannot include multiple operations on one item异常，主要有两个触发点：

1. UserTable事务项构建错误：
   代码中已创建合法的Put对象userDetailsWrites，但添加事务项时错误传入了userRecords（DynamoDB属性Map，而非Put实例），导致构造出无效的事务操作项。

2. PermissionTable存在重复主键记录：
   若传入的permissions列表中，有多个Permission对象对应DynamoDB表中同一个主键（分区键+排序键），事务中对同一Item执行多次Put操作会触发该异常。

修正后的代码 #

public boolean insertRecords(List<Permission> permissions, UserDetails user) {
    AmazonDynamoDB dynamoDB = AmazonDynamoDBClientBuilder.standard().build();
    TransactWriteItemsRequest request = new TransactWriteItemsRequest();
    
    // 构建PermissionTable的事务插入项
    List<TransactWriteItem> permissionRecords = new ArrayList<>();
    for(Permission permission : permissions) {
        final Map<String, AttributeValue> permissionRecord = convertToDDBMap(permission);
        Put permissionWrites = new Put().withTableName("PermissionTable")
                .withItem(permissionRecord);
        permissionRecords.add(new TransactWriteItem().withPut(permissionWrites));
    }

    // 构建UserTable的事务插入项
    final Map<String, AttributeValue> userRecord = convertToDDBMap(user);
    Put userDetailsWrites = new Put().withTableName("UserTable")
          .withItem(userRecord);
    List<TransactWriteItem> writeRequests = new ArrayList<>();
    // 修正：传入正确的Put对象userDetailsWrites，而非属性Map
    writeRequests.add(new TransactWriteItem().withPut(userDetailsWrites));
    writeRequests.addAll(permissionRecords);

    request.withTransactItems(writeRequests);
    request.withReturnConsumedCapacity(ReturnConsumedCapacity.TOTAL);

    try {
        dynamoDB.transactWriteItems(request);
    } catch (Exception exception) {
        // 建议添加日志打印异常详情，便于排查
        exception.printStackTrace();
        return false;
    }

    return true;
}

额外注意事项 #

• 确保permissions列表中的每条记录对应DynamoDB中的唯一主键，避免同一Item被多次操作。
• 事务操作的总项数不能超过25个，若permissions数量过大（超过24个，加上UserTable的1个共25个），需要拆分事务分批执行。

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