Как обновить данные Logstash в режиме Redshift в режиме реального времени?

Я ищу способ построить конвейер для хранения данных журналов (я использую стек ELK) в AWS Redshift, для аналитики.

Я прошел через выходные плагины для ElasticSearch и нашел один для записи данных в AWS S3. Но он записывает данные партиями, а работа с S3 идет медленно.

Итак, есть ли способ, как я могу построить конвейер из моего стека ELK в Redshift для моих данных журналов?

Обновление: кластер стека ELK размещен на EC2 VPC