@Daniela Miao，感谢分享解决方案。
我们可以在您发布的代码中添加一个代码块，以避免DynamoDB异常。这将在再次请求DynamoDB批量写入之前检查params.RequestItems是否有未处理的数据。

//db is AWS.DynamoDB Client
var processItemsCallback = function(err, data) {
  if (err) { 
     //fail
  } else {
    var params = {};
    params.RequestItems = data.UnprocessedItems;
    /*
    * Added Code block 
    */
    if(Object.keys(params.RequestItems).length != 0) {
      db.batchWriteItem(params, processItemsCallback);
    }
  }
};

db.batchWriteItem(/*initial params*/, processItemsCallback);

字符串

这是我使用“await”语法的代码示例。所以这段代码必须在一个javascript函数中。它在重试之前会随机延迟。

do {
    batchWriteResp = await dynamo.batchWriteItem({RequestItems:batchWriteItems}).promise()
    if (Object.keys(batchWriteResp.UnprocessedItems).length>0) {
        batchWriteItems = batchWriteResp.UnprocessedItems
        // delay a random time between 0.5~2.5 seconds
        const delay = Math.floor(Math.random() * 2000 + 500)
        await new Promise(resolve => setTimeout(resolve, delay));
    } else {
        break
    }
} while (true)

字符串

Nodejs是单线程的，它首先执行所有的主函数，所以你的while循环永远不会结束，回调永远不会执行。
你应该这样做：

//db is AWS.DynamoDB Client
var processItemsCallback = function(err, data) {
  if (err) { 
     //fail
  } else {
    var params = {};
    params.RequestItems = data.UnprocessedItems;
    db.batchWriteItem(params, processItemsCallback);
  }
};

db.batchWriteItem(/*initial params*/, processItemsCallback);

字符串

我发现公认的答案不必要地递归，因此很难阅读和维护。

const isEmptyObj = obj => {
    for (const k of obj) return false;
    return true;
};

async writeBatchToDynamodbAndHandleUnprocessedItems(db, itemsToWrite) => {
    
    // Note that `itemsToWrite` should look like:
    // { [tableName]: [ item1, item2, item3, ... ] }    
    
    while (!isEmptyObj(itemsToWrite)) {
        
        const result = await db.batchWriteItem({ RequestItems: itemsToWrite }).promise();
        itemsToWrite = result.UnprocessedItems;
        
    }
    
};

字符串

一个非常简洁的解决方案，使用递归的BatchGetItem（其工作方式与BatchWrite完全相同）：

public async batchGet(params: BatchGetItemInput, output: BatchGetResponseMap): Promise<BatchGetResponseMap> {
    const batchGetItemOutput: BatchGetItemOutput = await this.documentClient.batchGet(params).promise();

    Object.keys(batchGetItemOutput.Responses).forEach(tableName => {
        if (output[tableName]) {
            output[tableName] = output[tableName].concat(batchGetItemOutput.Responses[tableName]);
        } else {
            output[tableName] = batchGetItemOutput.Responses[tableName];
        }
    });

    if (Object.keys(batchGetItemOutput.UnprocessedKeys).length !== 0) {
        output = await this.batchGet({ RequestItems: batchGetItemOutput.UnprocessedKeys }, output);
    }

    return output;
}

字符串

根据AWS文档，SDK会自动处理重试逻辑：
注意AWS SDK实现了自动重试逻辑和指数回退。
最大重试次数可通过以下方式配置：

var dynamodb = new AWS.DynamoDB({apiVersion: '2012-08-10', maxRetries:5});

字符串