; -*- mode: clojure; -*-
; vim: filetype=clojure(logging/init {:file "/var/log/riemann/riemann.log"}); Listen on the local interface over TCP (5555), UDP (5555), and websockets
; (5556)
(let [host "127.0.0.1"]
(tcp-server {:host host})
(udp-server {:host host})
(ws-server  {:host host})); Expire old events from the index every 5 seconds.
(periodically-expire 5)(let [index (index)]
; Inbound events will be passed to these streams:
(streams(default :ttl 60; Index all events immediately.index; Log expired events.(expired(fn [event] (info "expired" event))))))

package mainimport ("github.com/bigdatadev/goryman"//"fmt""time""math/rand"
)func main(){
c := goryman.NewGorymanClient("localhost:5555")
err := c.Connect()
if err != nil {panic(err)
}defer c.Close()for {
rd := rand.New(rand.NewSource(time.Now().UnixNano()))err = c.SendEvent(&goryman.Event{Host : "box1",Service: "foo",Metric:  rd.Intn(1000),Tags: []string{"meter","dev"},
})
if err != nil {panic(err)
}rd = rand.New(rand.NewSource(time.Now().UnixNano()))err = c.SendEvent(&goryman.Event{Host : "box2",Service: "bar",Metric:  rd.Intn(1000),Tags: []string{"meter","dev"},
})
if err != nil {panic(err)
}
}
}

#安装启动graphite
pip install carbonpip install whisperpip install graphite-web
pip install Django
pip install django-tagging
#默认安装路径在 /opt/graphite/目录下

#初始化配置
PYTHONPATH=`pwd`/webapp:`pwd`/whisper python ./webapp/graphite/manage.py syncdbecho DEBUG = True > webapp/graphite/local_settings.py

#启动web服务，web访问界面
PYTHONPATH=`pwd`/whisper ./bin/run-graphite-devel-server.py --libs=`pwd`/webapp/ /opt/graphite/

#启动接收数据的后台进程puchd config cp carbon/conf/carbon.conf.example carbon/conf/carbon.confPYTHONPATH=`pwd`/whisper ./carbon/bin/carbon-cache.py --debug start

; -*- mode: clojure; -*-
; vim: filetype=clojure(logging/init {:file "/var/log/riemann/riemann.log"}); Listen on the local interface over TCP (5555), UDP (5555), and websockets
; (5556)
(let [host "127.0.0.1"]
(tcp-server {:host host})
(udp-server {:host host})
(ws-server  {:host host})); Expire old events from the index every 5 seconds.
(periodically-expire 5)(let [index (index)]
; Inbound events will be passed to these streams:
(streams(default :ttl 60; Index all events immediately.index; Log expired events.(expired(fn [event] (info "expired" event))))))#定义graph绘图的host，这里是部署在一台机器上面的
(def graph (graphite {:host "localhost"}));所有的event数据都发给graph进行绘图(streams  graph)