将 Filebeat 日志发送到 AWS Kinesis

Question

我的问题

我有一个日志管道，其中日志被写入文件并使用 Filebeat 传送到 ElasticSearch。我想从 ElasticSearch 切换到 AWS Kinesis，我想知道为新输出配置 Filebeat 的正确方法是什么。

我的选择

• Google 的解决方案 - 已找到 kinesisbeat，但没有很好的记录或使用。
• 运行 使用 exec plugin 的自定义脚本。但是，由于 "The exec output will run a command for each event received"，对于大容量日志流来说是不切实际的。
• 写我自己的插件。可以，但我不想重新发明轮子。

我的问题

如何将日志从 Filebeat 发送到 AWS Kinesis？

Answer 1

你可以查看我正在处理的https://github.com/s12v/awsbeats。但是，它需要 Go 1.10，它仍然是一个 RC。