Как сопоставить объект DynamoDB Streams с объектом Javascript? - PullRequest
Новая
       55

Как сопоставить объект DynamoDB Streams с объектом Javascript?

0 голосов
/ 11 апреля 2019

У меня есть лямбда-триггер, подключенный к потокам DynamoDB. Соответствующий документ DynamoDB передается объекту Lambda как AttributeValue .

Моя лямбда-функция выглядит следующим образом: 

import { Handler, Context, Callback } from 'aws-lambda'
import { config, DynamoDB } from 'aws-sdk'

const handler: Handler = async (event: any, context: Context, callback: Callback) => {
  if (!event) {
    return callback(null, `Failed processing records. event is null.`);
  }
  if (!event.Records) {
    return callback(null, `Failed processing records. No records present.`);
  }
  event.Records.forEach((record) => {
    console.log(record.eventID);
    console.log(record.eventName);
    console.log('DynamoDB Record: %j', record.dynamodb);
    //An example of record.dynamodb is shown below.
  });
  return callback(null, `Successfully processed ${event.Records.length} records.`);
}

export { handler }

Пример AttributeValue выглядит следующим образом: 

{
  "ApproximateCreationDateTime": 1554660820,
  "Keys": {
    "id": {
      "S": "ab66eb3e-045e-41d6-9633-75597cd47234"
    },
    "date_time": {
      "S": "2019-04-07T18:13:40.084Z"
    }
  },
  "NewImage": {
    "some_property": {
      "S": "some data"
    },
    "another_property": {
      "S": "more data"
    },
    "id": {
      "S": "ab66eb3e-045e-41d6-9633-75597cd47234"
    },
    "date_time": {
      "S": "2019-04-07T18:13:40.084Z"
    }
  },
  "SequenceNumber": "60215400000000011976585954",
  "SizeBytes": 1693,
  "StreamViewType": "NEW_IMAGE"
}

Как мне сопоставить AttributeValue с объектом javascript, предпочтительно используя определение Typescript? То есть если я определю класс Typescript следующим образом: 

class DynamoDBDocument {
    id: string;
    date_time: Date;
    some_property: string
    another_property: string
}

это приведет к объекту, подобному этому: 

{
    "id": "ab66eb3e-045e-41d6-9633-75597cd47234",
    "date_time": "S": "2019-04-07T18:13:40.084Z",
    "some_property": "some data",
    "another_property": "more data"
}

DynamoDB Data Mapper выглядит многообещающим решением, но я не могу понять, как использовать его с AttributeValue.

Ответы [ 2 ]

1 голос
/ 12 апреля 2019

Вот решение с использованием @ shiftcoders / динамо-легкого :

Сначала определите вашу модель (убедитесь, что вы указали правильный сопоставитель даты , если требуется что-то кроме строки ISO) 

import { DateProperty, Model, PartitionKeyUUID, SortKey } from '@shiftcoders/dynamo-easy'

@Model({ tableName: 'dynamo-table-name' })
class CustomModel {
  // hash key with auto generated uuid
  @PartitionKeyUUID()
  id: string

  // range key
  @SortKey()
  @DateProperty()
  date_time: Date

  some_property: string
  another_property: string
}

реализовать функцию обработчика 

import { DateProperty, fromDb, Model, PartitionKeyUUID, SortKey } from '@shiftcoders/dynamo-easy'
import { Callback, Context } from 'aws-lambda'
import * as DynamoDB from 'aws-sdk/clients/dynamodb'
import { Handler } from 'aws-sdk/clients/lambda'

const handler: Handler = async (event: any, context: Context, callback: Callback) => {
  event.Records.forEach((record) => {
    const newImage: DynamoDB.AttributeMap = record.dynamodb.NewImage
    if (newImage) {
      // map the dynamoDB attributes to a JS object using the CustomModel
      const newObject = fromDb(newImage, CustomModel)
      console.log(`item with id ${newObject.id} / ${newObject.date_time.toDateString()} changed to %j`, newObject)

      // start with the business logic which requires the newObject
    }

  })

  // no need to use callback when using async handler
  return `Successfully processed ${event.Records.length} records.`
}

Изучите документы для получения дополнительной информации о том, как выполнить запросы , если это в конечном итоге требуется вашей бизнес-логикой.

0 голосов
/ 11 апреля 2019

Я нашел решение в DynamoDB Data Marshaller . 

import { Handler, Context, Callback } from 'aws-lambda'
import { AttributeMap } from "aws-sdk/clients/dynamodb";
import { DataMapper } from '@aws/dynamodb-data-mapper'
import { unmarshallItem, Schema } from '@aws/dynamodb-data-marshaller'

const someSchema: Schema = {
    id: {type: 'String', keyType: "HASH"},
    date_time: {type: 'Date', keyType: "RANGE"},
    some_property: {type: 'String'},
    another_property: {type: 'String'},
};

const handler: Handler = async (event: any, context: Context, callback: Callback) => {

  event.Records.forEach((record) => {
    let dynamoDB: AttributeMap = record.dynamodb.NewImage
    let someObject = unmarshallItem(someSchema, dynamoDB)
    console.log('DynamoDB Object: %j', someObject)

  });
  return callback(null, `Successfully processed ${event.Records.length} records.`);
}

export { handler }
...