如何用类似SQL LIKE的条件更新DynamoDB指定主键前缀的条目？

你踩了一个常见的DynamoDB坑：update() API是专门用来更新单个主键条目的，它不支持KeyConditionExpression——这个表达式是给query()或scan()这类批量读取操作用的，用来筛选一组符合条件的条目。

要实现你想要的“更新所有opIdUserId以123开头或包含123的条目”，得分成两步走：先找出所有符合条件的条目，再逐个更新它们。下面是具体的修改方案：

方案1：更新以"123-"开头的条目（高效版，用Query） #

因为opIdUserId是分区键，用query()配合begins_with筛选效率远高于全表扫描，优先用这个方案：

const AWS = require('aws-sdk');
const docClient = new AWS.DynamoDB.DocumentClient({ region: 'eu-west-1' });
const table = "tablename";

exports.handler = async function(event, context, callback) {
    try {
        // 第一步：查询所有opIdUserId以"123-"开头的条目
        const queryParams = {
            TableName: table,
            KeyConditionExpression: "begins_with(opIdUserId, :prefix)",
            ExpressionAttributeValues: {
                ":prefix": "123-"
            }
        };
        const queryResult = await docClient.query(queryParams).promise();
        
        // 第二步：遍历查询结果，逐个更新条目
        const updatePromises = queryResult.Items.map(item => {
            const updateParams = {
                TableName: table,
                Key: {
                    opIdUserId: item.opIdUserId // 用查询到的主键定位条目
                },
                UpdateExpression: "set operationStatus = :status",
                ExpressionAttributeValues: {
                    ":status": "COMP"
                },
                ReturnValues: "UPDATED_NEW"
            };
            return docClient.update(updateParams).promise();
        });
        
        // 等待所有更新完成
        const updateResults = await Promise.all(updatePromises);
        callback(null, { 
            message: `成功更新${updateResults.length}条条目`,
            details: updateResults 
        });
    } catch (err) {
        callback(err, null);
    }
};

方案2：更新所有包含"123"的条目（扫描版，效率较低） #

如果你的需求是只要opIdUserId里包含123不管位置（比如"U1-123"这类），那query()就满足不了了，得用scan()配合contains表达式：

const AWS = require('aws-sdk');
const docClient = new AWS.DynamoDB.DocumentClient({ region: 'eu-west-1' });
const table = "tablename";

exports.handler = async function(event, context, callback) {
    try {
        // 第一步：扫描全表，筛选opIdUserId包含"123"的条目
        const scanParams = {
            TableName: table,
            FilterExpression: "contains(opIdUserId, :keyword)",
            ExpressionAttributeValues: {
                ":keyword": "123"
            }
        };
        const scanResult = await docClient.scan(scanParams).promise();
        
        // 第二步：遍历更新（和方案1逻辑一致）
        const updatePromises = scanResult.Items.map(item => {
            const updateParams = {
                TableName: table,
                Key: {
                    opIdUserId: item.opIdUserId
                },
                UpdateExpression: "set operationStatus = :status",
                ExpressionAttributeValues: {
                    ":status": "COMP"
                },
                ReturnValues: "UPDATED_NEW"
            };
            return docClient.update(updateParams).promise();
        });
        
        const updateResults = await Promise.all(updatePromises);
        callback(null, { 
            message: `成功更新${updateResults.length}条条目`,
            details: updateResults 
        });
    } catch (err) {
        callback(err, null);
    }
};

注意事项 #

• 如果你的表数据量很大，scan()会非常慢，而且消耗更多读写容量，尽量优先用query()的方案；
• 上面的代码用了async/await代替回调，比原来的回调嵌套更易读和维护；
• 如果需要处理分页（比如查询/扫描结果超过1MB的限制），还要加上循环处理LastEvaluatedKey的逻辑，确保所有符合条件的条目都被更新。

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