Выполнение кинесиса Firehose «поток доставки» данных в Lambda для преобразования и перемещения данных в два разных местоположения
- Преобразование / фильтр - расположение s3
- s3 резервное копирование.
-s3 location - я получаю данные фильтра. Но я не смог получить данные всего потока данных в папке резервной копии s3. \
Условие лямбда-фильтрации:
String status = "Dropped";
if (data.toLowerCase().contains("apple"))
status = "Ok";
outRec.setResult(status);
