logstash中的redis插件

redis作为logstash中的官方broker,既有input插件,还有output插件。

redis input插件

data_type属性: 有三种类型,

list -》 BLPOP --阻塞式列表弹出

channel -》 SUBSCRIBE -- 指定订阅者

pattern_channel -》 PSUBSCRIBE --多个订阅者,模糊匹配

input插件作为消息队列。

使用pattern_channel

input {

redis {

  data_type => "pattern_channel"

  key => "test-*" --这里能够使所有带test-前缀的key都被监听到。而data_type换成channel就不可以。

  host => "127.0.0.1"

  port => 6379

  threads => 5

}

}

连上redis-client, 测试语句: 

> publish test-1 "hello"

 可在logstash控制台看到输出

原文地址:https://www.cnblogs.com/guochunyi/p/6104874.html