0

Я использую AWS Kinesis Stream, который содержит транзакции клиентов. Я хочу сделать резервную копию транзакций на S3, прежде чем приступить к их обработке. Как я могу использовать голый Kinesis Firehose для резервного копирования транзакций из Kinesis Stream без использования каких-либо Лямбда или другого вычислительного компонента?Kinesis Stream to S3 Backup with Firehose

+0

вы не можете сделать это без использования лямбда-функции или специального кода, работающего на ec2. Кинезийский поток не способен писать на пожар. – halil

ответ

0

Вы можете изменить порядок ваших Kinesis строительных блоков:

  1. Вместо того, чтобы писать в Kinesis поток, запись в Kinesis шланговой, который направлен на S3.

  2. Запустите приложение Kinesis Analytics (KA), чтобы прочитать события от вашего Kinesis Firehose (KF) и записать их в поток Kinesis (KS). Вы можете использовать функциональность KA для выполнения некоторых фильтров, агрегации и объединений, которые в противном случае вы использовали бы в своем коде (Lambda или KCL).

Смежные вопросы