无需先调用GetItems，如何用DynamoDB批量更新指定属性？

我需要更新DynamoDB表中的数据项，仅修改每个项的2个属性；若项不存在则忽略。我尝试使用TransactWriteItems或BatchWriteItems API，但必须先调用GetItems API过滤不存在的项，请问是否有办法避免调用GetItems？

相关代码 #

index.js #

const {DocumentClient} = require("aws-sdk/clients/dynamodb");
const documentClient = new DocumentClient({region:'us-west-2'});
exports.handler = async (event, context) => {
  const filteredItems = await client.getItems(event.body.items)
  await client.updateItems(filteredItems, event.body.soldPrice, documentClient);
}

client.js #

const updateItems = async(filteredItems, soldPrice, documentClient) => {
   let params = {
      RequestItems: {
        [tableName] : filteredItems.map((key) =>({
              PutRequest: {
                Item: {
                  itemNumber: key.itemNumber,
                  soldPrice: soldPrice,
                  lastModified: new Date().toISOString()
                }
              }
           })
        )
   };
   await documentClient.batchWrite(params).promise()
}

尝试过的代码（更新说明） #

我还尝试了以下代码，但这会清除现有值：

const buildUpdateRequest = (filteredItems, soldPrice) => {
  return items.map((item) => ({
    PutRequest: {
        Item: {
            'itemNumber': item,
            'soldPrice': soldPrice,
            'lastModified': new Date().toISOString()
        },
        ConditionExpression: 'attribute_exists(itemNumber)'
    }
  }));
}
const batchWriteInvoices = (filteredItems, state, documentClient) => {
  const params = {
    RequestItems: {
        [tableName]: buildUpdateRequest(filteredItems, state),
    }
  };

  documentClient.batchWrite(params, (err, data) => {
    if (err) {
        console.error('Error:', err);
    } else {
        console.log('Success:', data);
    }
  });
}

解决方案 #

完全可以避免提前调用GetItems API，核心是用UpdateRequest替代PutRequest——PutRequest会直接替换整个Item（导致其他属性被清除），而UpdateRequest可以仅更新指定属性，同时配合条件表达式过滤不存在的项：

1. 使用UpdateRequest而非PutRequest，通过UpdateExpression指定要修改的属性
2. 添加ConditionExpression: 'attribute_exists(itemNumber)'，确保只更新已存在的项
3. 通过ExpressionAttributeValues传递要更新的参数值

修改后的代码示例：

const batchUpdateItems = async(filteredItems, soldPrice, documentClient) => {
  const currentTimestamp = new Date().toISOString();
  const params = {
    RequestItems: {
      [tableName]: filteredItems.map(item => ({
        UpdateRequest: {
          Key: {
            itemNumber: item.itemNumber // 主键必须准确匹配
          },
          UpdateExpression: "SET soldPrice = :sp, lastModified = :lm",
          ExpressionAttributeValues: {
            ":sp": soldPrice,
            ":lm": currentTimestamp
          },
          ConditionExpression: "attribute_exists(itemNumber)"
        }
      }))
    }
  };

  try {
    const result = await documentClient.batchWrite(params).promise();
    console.log('批量更新成功:', result);
    // 处理未完成的更新项（可选）
    if (Object.keys(result.UnprocessedItems).length > 0) {
      console.log('存在未处理项，可执行重试:', result.UnprocessedItems);
    }
  } catch (err) {
    console.error('批量更新失败:', err);
  }
}

关键点说明： #

• UpdateExpression：明确指定要更新的属性，不会影响Item中的其他字段
• ConditionExpression：只有当itemNumber属性存在时才执行更新，自动忽略不存在的项
• 无需提前调用GetItems，直接批量发起更新请求即可，不存在的项会被条件表达式过滤，不会产生副作用

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