DynamoDB Streams Kinesis Adapter: Как получить неключевые атрибуты при вставке и изменении событий? - PullRequest
Новая
       25

DynamoDB Streams Kinesis Adapter: Как получить неключевые атрибуты при вставке и изменении событий?

0 голосов
/ 28 октября 2019

Я создаю приложение на основе этого примера кода для запуска некоторых действий при обновлении хранимых данных в DynamoDB.

Пока мое приложение запускается как на "INSERT", так и на "INSERT". События «MODIFY», но похоже, что «NewImage» содержит только частичные данные, которые являются первичным ключом раздела.

Ниже показано, как я создал таблицу (в таблице предполагается хранить «ключ» и другиедва атрибута.). 

aws dynamodb create-table --attribute-definitions '[{ "AttributeName": "key", "AttributeType": "S" }]' --table-name some-table --key-schema '[ { "KeyType": "HASH", "AttributeName": "key" } ]' --provisioned-throughput ReadCapacityUnits=5,WriteCapacityUnits=5 --stream-specification '{"StreamViewType":"NEW_AND_OLD_IMAGES", "StreamEnabled": true}' --endpoint-url http://localhost:8000

Пример содержимого таблицы: 

{
  "key": "0CNHN5558000O001",
  "messages": {
    "0CNHN6HGG000U003": {
      "headers": {
        "Id": "...",
        "Value": "..."
      },
      "path": "...",
      "payload": { ... }
    },
             :
  },
  "statuses": {
    "0CNHN69IG000U003": {
      "status": "..."
    },
             :
  }
}

Как настроить таблицу DynamoDB, чтобы можно было получать сообщения и статусы вместе с ключом?

...