logstash基於RabbitMQ的輸入配置

先安裝配置好logstash，並能正常運行

然后配置 /usr/share/logstash/pipeline/logstash.conf 文件

有三大配置項：

 input 輸入配置

 filter 數據過濾處理

 output 輸出配置

 

 配置內容

input {
    rabbitmq {
        host => "192.168.1.3"    #RabbitMQ-IP地址
        vhost => "Ocsa_Cap"      #虛擬主機
        port => 5672             #端口號
        user => "cap"            #用戶名
        password => "cap"        #密碼
        queue => "LogQueue"      #隊列
        durable => false         #持久化跟隊列配置一致
        codec => "plain"         #格式
    }
}

output {
    elasticsearch {
        hosts => ["192.168.1.3:9200"]
        index => "logstash-rabbitmq"
    }
}

 

這里輸入源為 RabbitMQ ，也可以是 Redis  日志文件  數據庫  ElasticSearch  等。輸出也是，這里的輸出為 ElasticSearch 

 codec 輸入格式 plain  json 

 

是 plain 方式，如果輸入是JSON格式的話，輸出把全部內容直接放到message字段里

 

 

 

是 json 方式，輸入JSON格式，輸出會生成對應JSON格式字段。

 

 

 

 

參考資料：

https://blog.csdn.net/qq330983778/article/details/105644835

https://blog.csdn.net/qq330983778/category_9875412.html