1. 程式人生 > >logstash 通過type判斷

logstash 通過type判斷

[[email protected] type]$ cat input.conf 
input {
        file {
                type => "type_a"
                path => ["/usr/local/logstash-2.3.4/config/type/a.txt"]
        }
    
       file { 
                type => "type_b" 
                path => ["/usr/local/logstash-2.3.4/config/type/b.txt"] 
        } 

 
}


output {
     if [type] == "type_a" { 
        redis {
                host => "192.168.32.67"
                data_type => "list"
                key => "type_a:redis"
                port=>"6379"
                password => "1234567"
        }
}
      else if [type] == "type_b"{
       redis { 
                host => "192.168.32.67" 
                data_type => "list" 
                key => "type_b:redis" 
                port=>"6379" 
                password => "1234567" 
        } 
}
}
---------------------------------------------------

[
[email protected]
type]$ cat output.conf input { redis { host => "192.168.32.67" data_type => "list" key => "type_a:redis" password => "1234567" port =>"6379" } redis { host => "192.168.32.67" data_type => "list" key => "type_b:redis" password => "1234567" port =>"6379" } } output { if [type] == "type_a"{ stdout { codec => rubydebug } } else if [type] == "type_b"{ stdout { codec =>json } } } [
[email protected]
type]$ ../../bin/logstash -f output.conf Settings: Default pipeline workers: 1 Pipeline main started { "message" => "aaaaaaaa", "@version" => "1", "@timestamp" => "2016-09-16T06:26:07.211Z", "path" => "/usr/local/logstash-2.3.4/config/type/a.txt", "host" => "0.0.0.0", "type" => "type_a" } {"message":"aaaaaaaa","@version":"1","@timestamp":"2016-09-16T06:26:31.079Z","path":"/usr/local/logstash-2.3.4/config/type/b.txt","host":"0.0.0.0","type":"type_b"}

相關推薦

logstash 通過type判斷

[[email protected] type]$ cat input.conf input { file { type => "type_a" path => ["/u

logstash 根據type 判斷輸出

也歡迎大家轉載本篇文章。分享知識,造福人民,實現我們中華民族偉大復興!                # 更多ELK資料請訪問 http://devops.taobao.com一、配置前需要注意:1.Use chmod to modify nginx log f

通過python判斷質數

內存問題 cnblogs 質數 演示 range 是不是 Coding code 自然數 #!/usr/bin/env python3 #-*- coding:utf-8 -*- ‘‘‘ 質數,只能被1和自己整除的自然數 在數學上,如果一個數不能被從2到該數字開根數之間

通過日誌判斷系統是否正常運行

日誌 url orm type 簡單的 utf-8 常常 success 監控端口 當前已經引入了自動化部署,但是由於能力有限和其他限制,目前只是通過監控端口是否存在來判斷程序正常啟動與否。常常jenkins上返回服務部署成功,用戶訪問時卻失敗,只能靠人手動登錄系統查看日誌

通過反射判斷對象的屬性值是否為空

color err 繼承 access declare set arr logger 方式 問題產生場景? 在項目開發過程中我采用了表單內部嵌套列表的形式提交數據,將表單於列表數據同時提交保存。 有時候管理人的出資人結構我新增了多條 這時候並沒有真正的保存到數

js通過UA判斷ios、android、微信、qq、qq瀏覽器

function isIPhone(){ //判斷是否是ios var u = navigator.userAgent; var isIOS = !!u.match(/\(i[^;]+;( U;)? CPU.+Mac OS X/); //ios終端 return is

動態載入Dll時,通過Type生成類物件

原文: 動態載入Dll時,通過Type生成類物件 轉:http://www.cnblogs.com/zfanlong1314/p/4197383.html “反射”其實就是利用程式集的元資料資訊。 反射可以有很多方法,編寫程式時請先匯入 System.Reflection 名稱空間。

Java中通過反射判斷私有屬性是否為空的工具類

class ObjectIsEmptyUtil { public static boolean isEmpty(Object obj, String objProperty) throws Exception, IllegalAccessException { // 獲取類物件

java通過ping 判斷網路是否正常

import java.io.BufferedReader; import java.io.IOException; import java.io.InputStream; import java.io.InputStreamReader;

通過currUrl 判斷登入163郵箱是否成功---Python

# coding:utf-8 ''' 4.1.1 id定位 find_element_by_id('kw') find_element_by_id('su') find_element_by_id()方法通過id屬性來定位元素 4.1.2 name定位 find_el

JS通過核心判斷各種瀏覽器|區分360與谷歌(親測可用)

function getBrowserInfo(){ var ua = navigator.userAgent.toLocaleLowerCase(); var browserType=null; if (ua.match(/m

剛剛釋出 logstash通過webhdfs放入hdfs增加時間戳和host欄位

1.問題描述 logstash通過webhdfs外掛把資料放入hdfs的時候,發現每行資料的簽名都增加了一個時間戳和host欄位 2018-12-19T08:30:30.234Z %{host} "128.1.1.2" "GET" #2.資料查詢 在網上找了很多資料,描述的都是

C#中通過Type類訪問資料型別資訊

C#中通過Type類可以訪問任意資料型別資訊。 1.獲取給定型別的Type引用有3種方式:    a.使用typeof運算子,如Type t = typeof(int);    b.使用GetType()方法,如int i;Type t = i.GetType();    c.使用Type類的靜態方法GetT

通過js判斷微信、QQ等內建瀏覽器並在外部瀏覽器開啟

在涉及移動端微信推廣的專案時,由於對推廣需求的精細化,不僅需要推廣效率,還有始終保證域名在微信中的正常狀態,我們解決方案在微信、QQ、支付寶內建瀏覽器給出相應的提示。 function is_neizhi() { var ua = navigator.userAgent.toLowerCas

通過js判斷微信、QQ等內置瀏覽器並在外部瀏覽器打開

掃描二維碼 function 默認瀏覽器 信任 == 打開 lan 支付寶 直接 在涉及移動端微信推廣的項目時,由於對推廣需求的精細化,不僅需要推廣效率,還有始終保證域名在微信中的正常狀態,我們解決方案在微信、QQ、支付寶內置瀏覽器給出相應的提示。 function is

filebeat傳輸到logstash通過ssl加密

**【filebeat->>logstash通過ssl加密】** filebeat端 1、配置openssl.cnf檔案        在[ v3_ca ]下面加入        

Unity3D --//通過射線判斷角色是否在地面

using System.Collections; using System.Collections.Generic; using UnityEngine; public class PlayerContro : MonoBehaviour { public fl

logstash通過kafka傳輸nginx日誌(三)

單個程序 logstash 可以實現對資料的讀取、解析和輸出處理。但是在生產環境中,從每臺應用伺服器執行 logstash 程序並將資料直接傳送到 Elasticsearch 裡,顯然不是第一選擇:第一,過多的客戶端連線對 Elasticsearch 是一種額外的壓力;第

通過js判斷微信內建瀏覽器跳轉到外部瀏覽器開啟

在涉及移動端微信推廣的專案時,由於對推廣需求的精細化,不僅需要推廣效率,還有始終保證域名在微信中的正常狀態,我們解決方案在微信、QQ、支付寶內建瀏覽器給出相應的提示。 function is_neizhi() { var ua = navigator.userAgent.toLowerCase();

window下cmd通過Type命令檢視檔案文字內容和通過Echo命令新增文字內容到檔案

CMD是Command的簡寫,是Windows系統下的類DOS精簡系統。 在CMD視窗中,檢視文字檔案內容是用的命令是:TYPE 按下快捷鍵:WIN+R,調出執行視窗,輸入:CMD CMD的TYPE指令,語法:type 驅動器:\資料夾\檔名 示例參考: typ