如何删除DynamoDB表中所有数据？（适配AWS Amplify与JS SDK）

由于你的表是通过AWS Amplify创建的，直接删除并重建表可能破坏现有CloudFormation栈的关联资源，因此采用批量删除数据的方式更稳妥。以下是基于AWS SDK v3（JavaScript）的完整实现方案：

核心思路 #

• 先通过扫描表获取所有条目的主键（DynamoDB删除操作必须指定主键）
• 以25个条目为一批次（DynamoDB批量操作的上限），使用BatchWriteItemCommand执行批量删除
• 处理扫描的分页结果，确保获取表中所有条目
• 收集并处理删除失败的条目（可选添加重试逻辑）

完整代码实现 #

import { 
  ScanCommand, 
  BatchWriteItemCommand,
  DynamoDBClient 
} from "@aws-sdk/client-dynamodb";
// 若已通过Amplify配置好DynamoDB客户端，可直接导入你的现有实例
// import { ddbClient } from "./dynamoDbClient";

// 初始化DynamoDB客户端（Amplify环境下需确保已配置正确的认证权限）
const ddbClient = new DynamoDBClient({});
const tableName = "myTableName";

// 扫描表，获取所有条目的主键集合
async function scanAllPrimaryKeys() {
  let allKeys = [];
  let lastEvaluatedKey = null;

  do {
    const scanCmd = new ScanCommand({
      TableName: tableName,
      ProjectionExpression: "id", // 仅提取主键字段，减少数据传输量
      ExclusiveStartKey: lastEvaluatedKey // 分页续扫标记
    });

    const scanResult = await ddbClient.send(scanCmd);
    // 将主键转换为批量删除所需的格式
    scanResult.Items.forEach(item => {
      allKeys.push({ DeleteRequest: { Key: item } });
    });
    lastEvaluatedKey = scanResult.LastEvaluatedKey;
  } while (lastEvaluatedKey);

  return allKeys;
}

// 分批次执行批量删除
async function batchDelete(allKeys) {
  const batchLimit = 25; // DynamoDB BatchWriteItem单次最多支持25个操作
  let unprocessedItems = [];

  for (let i = 0; i < allKeys.length; i += batchLimit) {
    const currentBatch = allKeys.slice(i, i + batchLimit);
    const deleteCmd = new BatchWriteItemCommand({
      RequestItems: {
        [tableName]: currentBatch
      }
    });

    const deleteResult = await ddbClient.send(deleteCmd);
    // 收集删除失败的条目，可后续重试
    if (deleteResult.UnprocessedItems[tableName]) {
      unprocessedItems = [...unprocessedItems, ...deleteResult.UnprocessedItems[tableName]];
    }
  }

  // 若存在未处理的失败条目，可添加自动重试逻辑
  if (unprocessedItems.length > 0) {
    console.warn(`检测到${unprocessedItems.length}条删除失败的条目，建议重试`, unprocessedItems);
    // 可选：递归重试失败条目（需注意添加重试间隔，避免触发限流）
    // await batchDelete(unprocessedItems);
  }
}

// 主执行函数
export async function deleteAllTableItems() {
  try {
    console.log("开始扫描表中所有条目...");
    const allPrimaryKeys = await scanAllPrimaryKeys();
    console.log(`共扫描到${allPrimaryKeys.length}条记录，开始批量删除...`);
    await batchDelete(allPrimaryKeys);
    console.log("全表数据删除完成");
  } catch (err) {
    console.error("删除操作出错:", err);
    throw err;
  }
}

关键注意事项 #

• 权限配置：确保Amplify关联的IAM角色拥有dynamodb:Scan和dynamodb:BatchWriteItem权限
• 性能优化：若表中数据量极大（百万级以上），建议分时间段执行删除，避免占用过多读写容量导致业务受影响
• 数据备份：执行删除前建议通过AWS控制台导出表数据备份，防止误删数据
• 重试逻辑：代码中已收集删除失败的条目，可根据业务需求添加带间隔的自动重试逻辑，避免触发DynamoDB的限流机制

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