From afb8531e4bddec0cef370b79248af6da95ce20ec Mon Sep 17 00:00:00 2001
From: Calvin <calvin.xiao@ericsson.com>
Date: Tue, 11 Feb 2014 18:09:51 +0800
Subject: [PATCH] =?UTF-8?q?#325=20=E5=A2=9E=E5=8A=A0Logstash=E4=BB=8E?=
 =?UTF-8?q?=E4=B8=9A=E5=8A=A1=E6=97=A5=E5=BF=97=E8=BF=9B=E8=A1=8C=E7=BB=9F?=
 =?UTF-8?q?=E8=AE=A1=E7=9A=84=E6=BC=94=E7=A4=BA?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 support/.gitignore                            |  1 -
 support/logstash/error_collector/shipper.conf |  6 ++--
 support/logstash/metrics_shipper/shipper.bat  |  3 ++
 support/logstash/metrics_shipper/shipper.conf | 36 +++++++++++++++++++
 4 files changed, 42 insertions(+), 4 deletions(-)
 create mode 100644 support/logstash/metrics_shipper/shipper.bat
 create mode 100644 support/logstash/metrics_shipper/shipper.conf

diff --git a/support/.gitignore b/support/.gitignore
index 179ff716..42631498 100644
--- a/support/.gitignore
+++ b/support/.gitignore
@@ -2,5 +2,4 @@ jmeter/*.jtl
 jmeter/*.log
 local-script/
 logstash/logstash-*-flatjar.jar
-logstash/*/shipper.conf
 logstash/*/data
diff --git a/support/logstash/error_collector/shipper.conf b/support/logstash/error_collector/shipper.conf
index 69a5fc47..f74785ad 100644
--- a/support/logstash/error_collector/shipper.conf
+++ b/support/logstash/error_collector/shipper.conf
@@ -6,13 +6,13 @@ input {
       pattern => "(^.+Exception: .+)|(^\s+at .+)|(^\s*Caused by:.+)|(^\s+... \d+ common frames omitted)"
       what => "previous"
     }
-  start_position => "beginning"
+    start_position => "beginning"
   }
 }
 
 filter {
-   if [message] !~ /(ERROR)|(^.+Exception: .+)/{        # 将非错误日志过滤掉
-    drop {}                                             
+    if [message] !~ /(ERROR)|(^.+Exception: .+)/{        # 将非错误日志过滤掉
+      drop {}                                             
   }
 }
 
diff --git a/support/logstash/metrics_shipper/shipper.bat b/support/logstash/metrics_shipper/shipper.bat
new file mode 100644
index 00000000..29360b4c
--- /dev/null
+++ b/support/logstash/metrics_shipper/shipper.bat
@@ -0,0 +1,3 @@
+java -jar ../logstash-*.jar agent -f shipper.conf
+
+pause;
\ No newline at end of file
diff --git a/support/logstash/metrics_shipper/shipper.conf b/support/logstash/metrics_shipper/shipper.conf
new file mode 100644
index 00000000..0fe03ece
--- /dev/null
+++ b/support/logstash/metrics_shipper/shipper.conf
@@ -0,0 +1,36 @@
+input {
+  file {
+    path => "C:\tmp\logs\business.log"   # logstash要求必须是绝对路径
+    type => "business"
+  }
+}
+
+filter {
+  if [type] == "business" {
+    metrics {
+      meter => "business-events"
+      clear_interval => 10
+      flush_interval => 10
+      rates => []
+      add_tag => "business-metric"
+    }
+  }
+}
+
+output {
+  if "business-metric" in [tags] {
+    stdout {
+      debug => true
+    }
+    graphite {
+      host =>  "localhost"
+      port => 2003
+      debug => true
+      metrics => ["showcase.business-events","%{business-events.count}"]
+    }
+  } else {
+    stdout {
+      debug => false
+    }
+  }
+}