我如何将Logstash数据实时更新到Redshift?

我正在寻找一种方法来构build将日志数据(我使用ELK堆栈)存储到AWS Redshift进行分析的pipe道。

我已经浏览了ElasticSearch的Output插件,并find了一个用于将数据写入AWS S3的工具。 但是,它批量写入数据,处理S3很慢。

那么,有什么办法可以从我的ELK堆栈到Redshiftbuild立一个pipe道来处理我的日志数据?

更新:ELK堆栈集群托pipe在EC2 VPC上