如何一次更新 DynamoDB 表中的多个项目

Question

我正在使用 DynamoDB，我需要更新多条记录的特定属性。用伪语言编写我的要求我想做一个更新，上面写着“更新表 persons set relationshipStatus = 'married' where personKey IN (key1, key2, key3, ...)”（假设那 personKey 是我的 DynamoDB 表中的 KEY）。

换句话说，我想使用 IN 子句进行更新，或者我想可以将其称为批量更新。我发现this 链接明确询问是否存在像批量更新这样的操作，答案是不存在。但是，它没有提到 IN 子句。 documentation 表明 ConditionalExpressions 支持 IN 子句（一次可以提供 100 个值）。但是，我不确定这样的 IN 子句是否适合我的情况，因为我仍然需要提供一个强制性的 KEY 属性（它似乎需要一个值 - 我可能是错的）而且我担心它会做每次更新的全表扫描。

所以我的问题是：如何同时更新多个 DynamoDB 记录？目前，我几乎必须为每个 Key 一个一个地调用一个更新语句，这感觉真的不对……

Answer 1

如您所述，DynamoDB 不支持批量更新操作。您需要查询并获取要更新的所有记录的键。然后遍历该列表，一次更新每一项。

Answer 2

您可以使用 TransactWriteItems 操作更新 DynamoDB 表中的多条记录。

官方文档可用here，也可以看TransactWriteItems javascript/nodejs 例子here。

Answer 3

我不知道自从给出答案后它是否发生了变化，但现在有可能

查看文档： https://docs.aws.amazon.com/amazondynamodb/latest/APIReference/API_BatchWriteItem.html

我在 javascript 中这样使用它（将新块映射到具有所需结构的对象数组：

let params = {}
let tableName = 'Blocks';

params.RequestItems[tableName] = _.map(newBlocks, block => {
    return {
        PutRequest: {
            Item: {
                'org_id': orgId,
                'block_id': block.block_id,
                'block_text': block.block_text
            },
            ConditionExpression: 'org_id <> :orgId AND block_id <> :block_id',
            ExpressionAttributeValues: {
                ':orgId': orgId,
                ':block_id': block.block_id
            }
        }
    }
})

docClient.batchWrite(params, function(err, data) {
   .... and do stuff with the result

您甚至可以混合使用puts 和deletes

如果您使用 dynogels（由于 dynogels 支持，您不能混合 em，但您可以做的是更新（使用 create，因为它在幕后将它作为 put 的 batchWrite 函数）

var item1 = {email: 'foo1@example.com', name: 'Foo 1', age: 10};
var item2 = {email: 'foo2@example.com', name: 'Foo 2', age: 20};
var item3 = {email: 'foo3@example.com', name: 'Foo 3', age: 30};

Account.create([item1, item2, item3], function (err, acccounts) {
  console.log('created 3 accounts in DynamoDB', accounts);
});

请注意 DynamoDB 限制 (from the docs)：

BatchWriteItem 操作在一个或多个表中放置或删除多个项目。对 BatchWriteItem 的一次调用可以写入多达 16 MB 的数据，其中可以包含多达 25 个放置或删除请求。要写入的单个项目可以大到 400 KB。

如果我没记错的话，我认为 dynogels 在发送请求之前将请求分成 25 个块，然后将它们收集在一个承诺中并返回 （尽管我对此不是 100% 确定） - 否则包装函数很容易组装

Answer 4

DynamoDb 并非设计为支持本机事务的关系数据库。最好首先设计模式以避免多次更新的情况。或者，如果在您的情况下不实用，请记住您可以在重构设计时对其进行改进。

同时更新多个项目的唯一方法是使用 DynamoDB 提供的 TransactionWrite 操作。但它有一个限制（例如最多 25 个）。所以请记住，您可能也应该在您的应用程序中做一些限制。尽管成本非常高（因为实现涉及一些共识算法），但它仍然比简单的循环快。它为您提供了 ACID 属性，这可能是我们最需要的。想想使用循环的情况，如果其中一个更新失败，你如何处理失败？是否可以回滚所有更改而不会导致某些竞争条件？更新是幂等的吗？这实际上取决于您应用原因的性质。小心点。

另一个选择是使用线程池来做网络 I/O 工作，这绝对可以节省很多时间，但它也有同样的失败和回滚问题要考虑。

Answer 5

您可以按如下方式更新 aws dynamo 表中的多个项目。 假设您有一个包含 2 列的表格

|第一列名 |第二列名|
|列值 |列值  |

Aws::String updateExpression("SET #columnA = :valueA, #columnB = :valueB");
updateItemRequest.SetUpdateExpression(updateExpression);

expressionAttributeNames["#columnA"] = "FirstColumnName";
expressionAttributeNames["#columnB"] = "SecondColumnName";

TArray<Aws::DynamoDB::Model::AttributeValue> attributeValues;
Aws::DynamoDB::Model::AttributeValue avColumn1;
avColumn1.SetS("ColumnValue1")
attributeValues.Add(avColumn1);

Aws::DynamoDB::Model::AttributeValue avColumn2;
avColumn2.SetS("ColumnValue2")
attributeValues.Add(avColumn2);

Aws::Map<Aws::String, Aws::DynamoDB::Model::AttributeValue> expressionAttributeValues;
expressionAttributeValues[":valueA"] = avColumn1;
expressionAttributeValues[":valueB"] = avColumn2;
const Aws::DynamoDB::Model::UpdateItemOutcome& result = Client->UpdateItem(updateItemRequest);
if (!result.IsSuccess())
{
    // sad face
}