使用DynamoDB DocumentClient删除数据异常及写容量配置咨询

一、Promise.all批量删除不生效的原因与修复 #

你的代码确实存在几个关键问题，导致Promise.all无法正确等待删除操作完成，甚至实际没有执行预期的删除：

1. 函数未返回Promise：deleteItemOnTable没有返回任何异步操作的Promise，所以Promise.all接收的是两个undefined值，直接就“完成”了，根本不会等待删除操作执行。
2. 回调未包装为Promise：documentClient.delete用的是回调模式，没有转换成Promise，导致你的chain.then里的操作是异步但无法被追踪的。
3. forEach循环的错误使用：你在forEach里每次都重新创建chain变量，而且没有把这些Promise串联或收集起来返回，所有删除操作的Promise都被丢弃了。
4. Params硬编码未使用传入数据：你的params是固定的HashKey: 'hashkey', NumberRangeKey: 1，没有根据dataToBeDeleted里的item动态生成Key，所以实际删除的都是同一个条目（如果存在的话），其他数据根本没被处理。

修正后的代码示例 #

我们可以改用Promise.all并行处理每个条目，同时把documentClient.delete包装成Promise：

const documentClient = new AWS.DynamoDB.DocumentClient();

// 单个条目删除的Promise封装
function deleteSingleItem(tableName, item) {
  const params = {
    TableName: tableName,
    Key: {
      HashKey: item.HashKey, // 根据你的数据结构动态取Key
      NumberRangeKey: item.NumberRangeKey
    }
  };
  // 使用promise()方法把回调转为Promise
  return documentClient.delete(params).promise()
    .then(data => {
      console.log(`Deleted item from ${tableName}:`, data);
      return data;
    })
    .catch(err => {
      console.error(`Delete failed from ${tableName}:`, err);
      throw err; // 抛出错误让Promise.all捕获
    });
}

// 批量处理单表的删除
function deleteItemsOnTable(tableName, dataToBeDeleted) {
  // 用map把每个item转为删除Promise，然后用Promise.all并行执行
  const deletePromises = dataToBeDeleted.map(item => {
    return deleteSingleItem(tableName, item)
      .then(() => delay(10)); // 如果需要延迟，放在这里
  });
  return Promise.all(deletePromises);
}

// 多表批量删除调用
return Promise.all([
  deleteItemsOnTable(table1Name, table1Data),
  deleteItemsOnTable(table2Name, table2Data)
]);

关键改进点：

• 把单个删除操作封装成返回Promise的函数
• 用map替代forEach，收集所有删除操作的Promise
• 动态生成每个条目的Key参数
• 正确返回Promise链，让Promise.all能追踪所有异步操作

二、写容量单位计算问题 #

根据DynamoDB的官方规则：

一个写容量单位代表每秒可处理1次大小不超过1KB的写入操作。若写入的项目大于1KB，DynamoDB会消耗额外的写容量单位，所需总单位数取决于项目大小。

删除操作属于写操作，所以遵循同样的规则：

• 单条数据0.4KB，小于1KB，每次删除操作消耗1个写容量单位
• 要在1秒内完成1000条无延迟的删除，需要1000个写容量单位（因为每秒要处理1000次写操作，每次1单位）

简单来说：写容量单位是按操作次数计算的（只要单条数据≤1KB），和数据大小无关，所以1000次操作就需要1000个单位。

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