Как лучше всего разделить aws s3 на основе значения поля userId, полученного из Steam Firehose - PullRequest
0 голосов
/ 05 августа 2020

Я использую Kinesis Firehose для доставки данных о посещениях веб-сайта в s3. Я хочу создать подпапки корзины на основе значения UserID, которое у меня есть в моем потоке json. Если я не ошибаюсь, у нас есть ограничения, и пожарный шланг обрабатывает префикс logi c на основе this Я попытался использовать упомянутую подсказку здесь , в разделе Префикс раздела, но это не так. работай. Итак, я хочу понять, есть ли способ настроить префикс Logi c Firehose для динамического создания подпапки корзины во время выполнения на основе значений полей? Если нет, следует ли использовать Lambda для анализа записей потока и создания подпапок на основе поля useId в каждой записи? Это будет дорого?

С уважением, Лина

...