riemann influxdb

gistfile1.clj

(let [index (index)]
  ; Inbound events will be passed to the functions that come after (streams...
  (streams
    ;This is one function. Index all events immediately.
    index

    ;For each distinct host and service combination
    (by [:host :service]
      ;Send events to InfluxDB
      (influxdb
        (let [servicename (:service event)
              hostname (:host event)]
          {:host "10.0.1.195"
          :port 8086
          :scheme "http"
          :username "nick"
          :password "password"
          :db "riemann-data"
          :series (clojure.string/join "." [hostname servicename])})))


    ;Just for debugging, log all events to the log file specified above in "(logging/init...."
    #(info %)))