Запись в поток Kinesis с использованием функции AWS Lambda

Question

Можем ли мы создать функцию Lambda, которая может быть выполнена, когда мы записываем запись в таблицу Dynamo DB &, запись которой записывается в поток Kinesis? В принципе, мы можем написать поток Kinesis с помощью функции лямбда? Если да, пожалуйста, поделитесь примером кода для этого. Также я хочу знать, как это работает ..... Спасибо

Answer 1

Да. Вы можете создать триггер «Динамо», поддерживаемый функцией лямбда, и включить эту функцию Лямбды в поток.

Вот прогулка, которая показывает, как создать триггер:

http://docs.aws.amazon.com/amazondynamodb/latest/developerguide/Streams.Lambda.html

В теле вашей функции лямбда, то вы можете вызвать функцию Kinesis «putRecord». Вот информация о "putRecord":

http://docs.aws.amazon.com/kinesis/latest/APIReference/API_PutRecord.html

Если вы реализуете ваши функции лямбда в Node.js, вот ссылка на SDK документации для Kinesis:

http://docs.aws.amazon.com/AWSJavaScriptSDK/latest/AWS/Kinesis.html#putRecord-property

Аналогично здесь ссылку на Java SDK (если вы используете Java):

http://docs.aws.amazon.com/AWSJavaSDK/latest/javadoc/com/amazonaws/services/kinesis/AmazonKinesis.html#putRecord(com.amazonaws.services.kinesis.model.PutRecordRequest)

А ссылка на документы Бото (если вы используете питон):

http://boto.cloudhackers.com/en/latest/ref/kinesis.html

ДоП ссылка должна иметь всю информацию вашей потребность.