如何动态更新 dynamodb 项目中的属性？

Question

我使用 Node js 在 dynamodb 中创建了一个项目，该项目具有多个属性，例如品牌、类别、折扣、有效性等。我使用 uuid 为每个项目生成 id。现在假设我要更新项目的有效性属性，在这种情况下，我当前正在发送整个 json 对象，并将有效性值修改为新值。

这绝对不是最优的，请帮我找到一个最优的解决方案。

const params = {
    TableName: process.env.PRODUCT_TABLE,
    Key: {
      id: event.pathParameters.id,
    },
    ExpressionAttributeNames: {
      '#discount': 'discount',
    },
    ExpressionAttributeValues: {
      ':brand': data.brand,
      ':category': data.category,
      ':discount': data.discount,
      ':denominations': data.denominations,
      ":validity": data.validity,
      ":redemption": data.redemption    
    },
    UpdateExpression: 'SET #discount = :discount, denominations = :denominations, brand = :brand, category = :category, validity = :validity, redemption = :redemption',
    ReturnValues: 'ALL_NEW',
  };

我只想发送我想用新值更新的属性，如果我想将有效期从 6 个月更改为 8 个月，我应该发送如下内容： { “有效期”：“8个月” } 它应该更新项目的有效性属性。 同样应该适用于该项目的任何其他属性。

'use strict';

const AWS = require('aws-sdk');

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

module.exports.update = (event, context, callback) => {
  const data = JSON.parse(event.body);

  let attr = {};
  let nameobj = {};
  let exp = 'SET #';
  let arr = Object.keys(data);
  let attrname = {};

  arr.map((key) => {attr[`:${key}`]=data[key]});

  arr.map((key) => {
    exp += `${key} = :${key}, `
  });

  arr.map((key) => {nameobj[`#${key}`]=data[key]});

  attrname = {
    [Object.keys(nameobj)[0]] : nameobj[Object.keys(nameobj)[0]]
  }

  const params = {
    TableName: process.env.PRODUCT_TABLE,
    Key: {
      id: event.pathParameters.id,
    },
    ExpressionAttributeNames: attrname,
    ExpressionAttributeValues: attr,
    UpdateExpression: exp,
    ReturnValues: 'ALL_NEW',
  };

  // update the todo in the database
  dynamoDb.update(params, (error, result) => {
    // handle potential errors
    if (error) {
      console.error(error);
      callback(null, {
        statusCode: error.statusCode || 501,
        headers: { 'Content-Type': 'text/plain' },
        body: 'Couldn\'t update the card',
      });
      return;
    }

    // create a response
    const response = {
      statusCode: 200,
      body: JSON.stringify(result.Attributes),
    };
    callback(null, response);
  });
};

Answer 1

与其他cmets相反，这是很有可能的，使用UpdateItem动作。

Language agnostic API docs

JavaScript specific API docs

如果您想动态创建查询，请尝试以下操作：

const generateUpdateQuery = (fields) => {
    let exp = {
        UpdateExpression: 'set',
        ExpressionAttributeNames: {},
        ExpressionAttributeValues: {}
    }
    Object.entries(fields).forEach(([key, item]) => {
        exp.UpdateExpression += ` #${key} = :${key},`;
        exp.ExpressionAttributeNames[`#${key}`] = key;
        exp.ExpressionAttributeValues[`:${key}`] = item
    })
    exp.UpdateExpression = exp.UpdateExpression.slice(0, -1);
    return exp
}

let data = {
    'field' : { 'subfield': 123 },
    'other': '456'
}

let expression = generateUpdateQuery(data)

let params = {
    // Key, Table, etc..
    ...expression
}

console.log(params)

输出：

{ 
    UpdateExpression: 'set #field = :field, #other = :other',
    ExpressionAttributeNames: {
        '#field': 'field',
        '#other': 'other'
    },
    ExpressionAttributeValues: {
        ':field': { 
            'subfield': 123
        },
        ':other': '456'
    } 
}

Answer 2

使用Javascript SDK V3：

从正确的包导入：

import { DynamoDBClient PutItemCommandInput, UpdateItemCommandInput, UpdateItemCommand } from '@aws-sdk/client-dynamodb';

动态对项目进行部分更新的功能： （下面的代码是 typescript 可以很容易地转换成 Javascript，只需删除类型！）

function updateItem(id: string, item: any) {
  const dbClient = new DynamoDBClient({region: 'your-region-here });

  let exp = 'set ';
  let attNames: any = { };
  let attVal: any = { };
  for(const attribute in item) {
    const valKey = `:${attribute}`;
    attNames[`#${attribute}`] = attribute;
    exp += `#${attribute} = ${valKey}, `;     
    const val = item[attribute]; 
    attVal[valKey] = { [getDynamoType(val)]: val };
  }

  exp = exp.substring(0, exp.length - 2);

  const params: UpdateItemCommandInput = {
    TableName: 'your-table-name-here',
    Key: { id: { S: id } },
    UpdateExpression: exp,
    ExpressionAttributeValues: attVal,
    ExpressionAttributeNames: attNames,
    ReturnValues: 'ALL_NEW',
  };

  try {
    console.debug('writing to db: ', params);
    const command = new UpdateItemCommand(params);
    const res = await dbClient.send(command);
    console.debug('db res: ', res);
    return true;
  } catch (err) {
    console.error('error writing to dynamoDB: ', err);
    return false;
  }
}

并使用它（我们也可以进行部分更新）：

updateItem('some-unique-id', { name: 'some-attributes' });

Answer 3

我所做的是创建一个helper class。

• 这是一个简单的函数：添加所有进入的属性和值，如果值为 null 或未定义，则不会出现在表达式中。

• 我建议用typescript 创建一个helper class，并添加更多功能和其他东西，例如expressionAttributeValues、expressionAttributeNames ...的生成器，希望对您有所帮助。

function updateExpression(attributes, values) {
  const expression = attributes.reduce((res, attribute, index) => {

    if (values[index]) {
      res += ` #${attribute}=:${attribute},`;
    }

    return res;
  }, "SET ");

  return expression.slice(0, expression.length - 1)
}

console.log(
  updateExpression(["id", "age", "power"], ["e8a8da9a-fab0-55ba-bae3-6392e1ebf624", 28, undefined])
);

Answer 4

您可以使用代码并根据您提供的对象生成 params 对象。它只是一个 JavaScript 对象，您遍历这些项目，以便更新表达式仅包含您提供的字段。 这不是一个真正的 DynamoDB 问题，因为这更像是一个通用的 JS 编码问题。

Answer 5

您可以使用 UpdateItem；要熟悉 DynamoDb 查询，我建议您使用 DynamoDb NoSQL 工作台： https://docs.aws.amazon.com/amazondynamodb/latest/developerguide/workbench.settingup.html

它可以根据您的查询为您生成 sn-ps。

DynamoDb NoSQL workbench screenshot query