clojure - Riemann - マップからストリームを動的に構築する

Question

サービス名としきい値でマップを取得する次の関数があります。サービスが定義されたしきい値を超えたかどうかを確認し、イベントで複数のダウンストリームの子を呼び出します。

(defn tc
  [s & children]
   (where
     (and (service (:service_name s)) (not (expired? event)))
       (by [:host :service]
         (where (> metric (:threshold s)
           (with :state "critical" 
             (apply sdo children)))))))

マップのベクトルを使用してストリームを動的に構築したいと思います。

(def services [{:service "cpu/usage" :threshold 90}
               {:service "memory/usage" :threshold 90}])

ストリームで実行しようとすると、次の警告が表示されます。

(streams
  (doseq [s services] (tc s prn)))

WARN [2015-01-05 14:27:07,187] Thread-15 - riemann.core - instrumentation service caught
java.lang.NullPointerException
  at riemann.core$stream_BANG_$fn__11140.invoke(core.clj:19)
  at riemann.core$stream_BANG_.invoke(core.clj:18)
  at riemann.core$instrumentation_service$measure__11149.invoke(core.clj:57)
  at riemann.service.ThreadService$thread_service_runner__8782$fn__8783.invoke(service.clj:66)
  at riemann.service.ThreadService$thread_service_runner__8782.invoke(service.clj:65)
  at clojure.lang.AFn.run(AFn.java:22)
  at java.lang.Thread.run(Thread.java:701)

dosq 内でストリーム関数を実行すると機能します。これは機能し、次の出力が得られます。

(doseq [s services]
  (streams (tc s prn)))

#riemann.codec.Event{:host "testhost", :service "memory/usage", :state "critical", :description nil, :metric 91.0, :tags nil, :time 1420460856, :ttl 60.0}