如何在forEach中结合Promise/DynamoDB Delete实现请求延时控制？

嘿，我来帮你搞定这个批量删除的延时问题！你之前遇到的情况很典型——用forEach配合delay的时候，所有的异步任务其实是同时启动计时的，2秒后会一股脑儿发起所有删除请求，自然就触发DynamoDB的容量限制了。下面给你两个靠谱的解决方案：

方案一：用async/await + for...of实现串行延迟删除 #

这是最直观的方法，通过for...of循环配合await，确保每一次删除操作都在前一个操作完成（包括等待2秒）之后再执行：

async function deleteItemsOneByOne(items) {
  for (const item of items) {
    // 先等待2秒，再执行删除
    await new Promise(resolve => setTimeout(resolve, 2000));
    
    // 根据当前item构造删除参数
    const deleteParams = {
      TableName: '你的DynamoDB表名',
      Key: {
        // 替换成你的表主键，比如：
        id: item.id
      }
    };

    try {
      await docClient.delete(deleteParams).promise();
      console.log(`成功删除条目: ${JSON.stringify(item)}`);
    } catch (err) {
      console.error(`删除条目失败: ${JSON.stringify(item)}`, err);
      // 可以根据需求决定是否中断循环，或者继续执行下一个
      // throw err; // 中断
    }
  }
}

// 调用这个函数开始删除
deleteItemsOneByOne(arrayOfitems);

这个方法的优势是逻辑简单清晰，完全串行执行，绝对不会超过DynamoDB的单请求频率限制。

方案二：用p-map控制并发（更灵活） #

如果你之后想在不触发限流的前提下，提高一点删除效率（比如同时处理2-3个请求），p-map就是很好的选择。它可以帮你控制并发数，同时你依然可以在每个任务前添加延时：

const pMap = require('p-map');

async function deleteItemsWithConcurrency(items) {
  const processItem = async (item) => {
    // 每个任务执行前等待2秒
    await new Promise(resolve => setTimeout(resolve, 2000));
    
    const deleteParams = {
      TableName: '你的DynamoDB表名',
      Key: {
        id: item.id
      }
    };

    await docClient.delete(deleteParams).promise();
    return item;
  };

  // concurrency设为1就是完全串行，你可以根据DynamoDB的容量调整这个数字
  const deletedItems = await pMap(items, processItem, { concurrency: 1 });
  console.log(`批量删除完成，共处理${deletedItems.length}条数据`);
}

deleteItemsWithConcurrency(arrayOfitems);

为什么你之前的代码不生效？ #

再解释下你之前的forEach写法问题：forEach是同步遍历，它会在瞬间把所有的delay(2000).then(...)都启动起来——也就是说，所有的2秒计时是同时开始的，2秒后所有删除请求会同时发送，这和你想要的“逐个等待”完全不是一回事。

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