私はおそらくリーマン/ Clojureの中にいくつかの重要な概念を理解していないよリーマンイベント

Question

に新しいフィールドを注入します。 私はフィールド解析しようとしています：フォーマット"aaa:1234.bbbb.cccc.ddddd"であるイベントからサービスを、そして「と」機能を使用して、イベントに新しいフィールドのPIDを追加します。あなたがwhereの本体でserviceを使用できない理由である(where* (fn [event] (let [service (:service event)] ,,,)))ためwhereマクロによってだけ糖衣構文を、私は(where (service ,,,))推測

... 
(let [index (default :ttl 300 (update-index (index)))] 

; Inbound events will be passed to these streams: 
(streams 
index 
(where (service #"(\w+):(\d+)\.(\w+)\.(\w+)\.(\w+)") 
    (with :pid (str/replace service #"(\w+):(\d+)\.(\w+)\.(\w+)\.(\w+)" "$2") 
) 
) 
... 

user=> (riemann.bin/reload!) 
#error { 
:cause "Unable to resolve symbol: service in this context" 
:via 
[{:type clojure.lang.Compiler$CompilerException 
:message "java.lang.RuntimeException: Unable to resolve symbol: service in this context, compiling:(/etc/riemann/riemann.config:73:19)" 

Answer 1

さ：riemann.configでこのコードが例外をスローしている理由 誰か私に説明することができますそれはそこに定義された名前ではありません。ために

documentationを見ると、それは私には思えるあなたはsmapを使用する必要があります。アドバイス

(where (service #"(\w+):(\d+)\.(\w+)\.(\w+)\.(\w+)") 
    (smap (fn [e] (assoc e :pid (str/replace (:service e) #"(\w+):(\d+)\.(\w+)\.(\w+)\.(\w+)" "$2")))))