Я нашел решение: 1) Я модифицировал каждый журнал в Kinesis Firehose, используя функцию Lambda. Я добавил идентификатор в конец строки журнала. И тогда это выглядит так: Модифицированные журналы
2) Я создал функцию Lambda с триггером, который работает каждый раз, когда журналы записываются в корзину s3. И в этой функции я распределяю журналы по папкам, которые мне нужны, основываясь на информации, которую я добавил в журналы ранее. Я не буду давать код этой лямбда-функции. Я описал общий подход и думаю, что те, кто в нем нуждается, могут понять его.