Динамодб Потоки + Ламда + NodeJS - PullRequest
0 голосов
/ 04 июня 2018

Довольно простой вопрос.У меня есть две таблицы DynamodB.Таблица1 содержит список значений, а Таблица2 будет содержать совокупность значений (среднее и т. Д.).

Я использую потоки dyndamodb для запуска функции lamda для вычисления совокупных значений из данных в Таблице1, а затем обновляю Таблицу2с этими ценностями.У меня вопрос, будет ли поток dyndamodb содержать ВЕСЬ таблицу1 или просто новую запись?

Я просто настраиваю лямбда-функции для вычисления средних значений и сохранения в Таблице 2, и я просто пытаюсь спланировать лучшееспособ сделать это.Кажется, все работает.Просто спотыкаюсь о получении данных из таблицы1.Любые другие советы, касающиеся forEach для записей, также будут высоко оценены.Спасибо!

1 Ответ

0 голосов
/ 04 июня 2018

Только измененное поле, иначе не было бы особого смысла передавать всю базу данных каждый раз, верно?из документов: https://docs.aws.amazon.com/amazondynamodb/latest/developerguide/Streams.Lambda.Tutorial.html

Вы получите сообщение типа:

{
    "Records": [
        {
            "eventID": "7de3041dd709b024af6f29e4fa13d34c",
            "eventName": "INSERT",
            "eventVersion": "1.1",
            "eventSource": "aws:dynamodb",
            "awsRegion": "us-west-2",
            "dynamodb": {
                "ApproximateCreationDateTime": 1479499740,
                "Keys": {
                    "Timestamp": {
                        "S": "2016-11-18:12:09:36"
                    },
                    "Username": {
                        "S": "John Doe"
                    }
                },
                "NewImage": {
                    "Timestamp": {
                        "S": "2016-11-18:12:09:36"
                    },
                    "Message": {
                        "S": "This is a bark from the Woofer social network"
                    },
                    "Username": {
                        "S": "John Doe"
                    }
                },
                "SequenceNumber": "13021600000000001596893679",
                "SizeBytes": 112,
                "StreamViewType": "NEW_IMAGE"
            },
            "eventSourceARN": "arn:aws:dynamodb:us-east-1:123456789012:table/BarkTable/stream/2016-11-16T20:42:48.104"
        }
    ]
}

Не знаю, какие агрегаты вам нужны, ни ваш вариант использования, поэтому я не могу помочь счто.

Добро пожаловать на сайт PullRequest, где вы можете задавать вопросы и получать ответы от других членов сообщества.
...