Logstash配置安装

input {
   rabbitmq {
    host => "rabbitmqip地址"
    subscription_retry_interval_seconds => "5"
    exchange => "log.msg.direct"
    queue => "log.queue.direct"
    durable => "true"
    key => "rk.msg.direct"
    user => "mqname"
    password => "mqpassword"
    }
}
output {
    elasticsearch {
        hosts => "es ip:port" 
        #flush_size=> 10  
        #workers => 5  
        #document_id => "%{jobid}" 
        #document_type => "BaseSysLog"
        index => "logstashsyslog"
        user => "elastic"
        password => "password"
    }
    #stdout {
    #codec => rubydebug {}
    #}
}