logstash——redis读取脚本

input { 
Redis { 
#redis地址 
host => “1.1.1.1” 
#端口 
port => “6379” 
#数据库号 
db => “5” 
#密码 
password => “foobared” 
#数据类型 
data_type => “list” 
#Key 
key => “tomcat_access_log” 
} 
} 
output { 
#如果tags里面包含tomcat_access_log则执行里面内容 
if “tomcat_access_log” in [tags] { 
#输出到es 
elasticsearch { 
#格式为json格式 
codec => “json” 
#es地址 
hosts => [“1.1.1.2:9200”,”1.1.1.3:9200”,”11.1.1.4:9200”] 
#索引 
index => “tomcat_access_log-%{+YYYY.MM.dd}” 
} 
#输出到标准输出 
stdout { codec => rubydebug } 
} 
}