logstash 输出实时推送，非简单查询

Logstash | 作者 yu89780012 | 发布于2019年09月17日 | 阅读数：1614

分享到：QQ空间新浪微博微信 QQ好友印象笔记有道云笔记

想在有这么一个需求。我用logstash 收集到一些用户日志，想在输出时候动态监测到这些日志，根据日志（实际上是一条条记录）的某一个字段做判断，最后实时推送到对应用户前端展示。目前没搜索到类似的方案。大家有什么好的方案吗。求思路

4 个回复

juin - 大数据开发

赞同来自: yu89780012

elastalert

liuxg - Elastic

你可以参照我的教程“Logstash：处理多个input”。https://blog.csdn.net/UbuntuTo ... 80709。你在里面使用字段检查。比如在我那里面使用的是type来检查。

if[type] == "apache" {
mutate {
add_tag => ["apache"]
}
}
if [type] == "daily" {
mutate {
add_tag => ["daily"]
}
}

Reilee - 在日devops

参见楼上
简单来说 logstash filter 是支持条件判断的

yu89780012

可能我描述的有点问题，实际上我的重点不是解析数据，而是想实时转发数据。目前我根据英文官方文档写了一个logstash 输出插件，在里面封装 netty 控件，当收到数据的同时，将数据转发到我另一个服务上去，这个服务暂时成为A 吧，我在A 上接收到数据，进行解析，同时嵌入websocket 。在处理数据的同时，若有匹配的用户，则实时推送给用户。。

要回复问题请先登录或注册

logstash 输出实时推送，非简单查询

4 个回复

发起人

活动推荐

相关问题

问题状态

logstash 输出 实时推送，非简单查询

与内容相关的链接

4 个回复

发起人

活动推荐

相关问题

问题状态

logstash 输出实时推送，非简单查询