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

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


amazon-web-services aws-lambda amazon-dynamodb amazon-kinesis
person AKSHAY SHINGOTE    schedule 20.11.2015    source источник
comment
Добро пожаловать в StackOverflow. Пожалуйста, сначала проверьте справку StackOverflow, чтобы задать вопросы. Сосредоточьтесь на Как задать хороший вопрос и Как создать минимальный, полный и проверяемый пример, но также могут быть полезны другие разделы справки.   -  person David Ferenczy Rogožan    schedule 20.11.2015
comment
если вы хотите найти решение по этому поводу. посетите образец репозитория, созданный terraform.   -  person GNOKOHEAT    schedule 26.10.2019

Ответы (2)


arrow_upward
24
arrow_downward

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

Вот пошаговое руководство по созданию триггера:

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)

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

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

Ссылки на документы должны содержать всю необходимую информацию.

person Scott Wisniewski    schedule 21.11.2015

arrow_upward
0
arrow_downward

Не отвечая на вопрос, но обновляя последнее решение части вопроса

когда мы записываем запись в таблицу Dynamo DB, и эта запись записывается в поток Kinesis

Теперь вы можете напрямую включить потоки Kinesis в таблице db Dynamo https://aws.amazon.com/about-aws/whats-new/2020/11/now-you-can-use-amazon-kinesis-data-streams-to-capture-item-level-changes-in-your-amazon-Dynamodb-table/

person Sachin Kariyattin    schedule 23.07.2021