为黎曼事件注入新领域

Question

我可能不理解 riemann/clojure 中的一些关键概念。 我正在尝试从格式为"aaa:1234.bbbb.cccc.ddddd" 的事件解析字段：service，并使用函数“with”将新字段pid 添加到事件中。 任何人都可以向我解释为什么riemann.config 中的这段代码会引发异常：

...
(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

我猜(where (service ,,,)) 只是(where* (fn [event] (let [service (:service event)] ,,,))) 的where 宏的语法糖，这就是为什么你不能在where 的主体中使用service：它不是在那里定义的名称。

查看documentation for with，在我看来你应该使用smap：

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