5

私はRiemannとClojureが初めてです。私がやりたいことは、いくつかのサービスの TTL が期限切れになったときに、3 つの電子メール グループに電子メール通知を送信することだけです。メールのリストを保存するある種の構成ファイルを作成しました。

{
  :email_group_1 (
                  "first@example.com"
                  "second@example.ru"
                 )
  :email_group_2 (
                  "third@example.com"
                 )
}

私のリーマン設定は次のようになります。

(logging/init {:console true})
(import org.apache.log4j.Level)
(logging/set-level Level/DEBUG)

(require '[clojure.java.io :as io])
(import '[java.io PushbackReader])

(let [host "0.0.0.0"]
  (tcp-server {:host host :port 60001})
  (udp-server {:host host})
  (ws-server  {:host host :port 60003}))
(repl-server  {:host "127.0.0.1"})

(def cwd (System/getProperty "user.dir"))

(def emails
  (with-open [r (io/reader (str cwd "/etc/emails.clj"))]
             (read (PushbackReader. r))))

(periodically-expire 5)

(def email (mailer))

(defn notify [& egroups]
  (for [egroup egroups]
    (rollup 1 60 (apply email (emails egroup)))))

(let [index (index)]
  (streams
    (default :ttl 60
      index

      (expired
          (where (service "service_connect_active")
                    #(info "expired" %)
                    (notify :email_group_1 :email_group_2))))))

コードは (私にとっては) 良さそうに見えますが、このサービスの有効期限が切れると、次のエラーが発生します。

09:45:39 riemann.1      | INFO [2015-05-08 10:45:39,313] Thread-5 - riemann.config - expired {:ttl 60, :time 357766884827/250, :state expired, :service service_connect_active, :host ava.local}
09:45:39 riemann.1      | WARN [2015-05-08 10:45:39,319] Thread-5 - riemann.config - clojure.lang.LazySeq@841649b8 threw
09:45:39 riemann.1      | java.lang.ClassCastException: clojure.lang.LazySeq cannot be cast to clojure.lang.IFn
09:45:39 riemann.1      |   at riemann.config$eval66$stream__70$fn__75.invoke(riemann.development.config:34)
09:45:39 riemann.1      |   at riemann.config$eval66$stream__70.invoke(riemann.development.config:45)
09:45:39 riemann.1      |   at riemann.streams$match$stream__3514$fn__3525.invoke(streams.clj:1209)
09:45:39 riemann.1      |   at riemann.streams$match$stream__3514.invoke(streams.clj:1209)
09:45:39 riemann.1      |   at riemann.streams$default$stream__3731$fn__3742.invoke(streams.clj:1328)
09:45:39 riemann.1      |   at riemann.streams$default$stream__3731.invoke(streams.clj:1328)
09:45:39 riemann.1      |   at riemann.core$stream_BANG_$fn__4415.invoke(core.clj:19)
09:45:39 riemann.1      |   at riemann.core$stream_BANG_.invoke(core.clj:18)
09:45:39 riemann.1      |   at riemann.core$reaper$worker__4529$fn__4539.invoke(core.clj:303)
09:45:39 riemann.1      |   at riemann.core$reaper$worker__4529.invoke(core.clj:297)
09:45:39 riemann.1      |   at riemann.service.ThreadService$thread_service_runner__1973$fn__1974.invoke(service.clj:71)
09:45:39 riemann.1      |   at riemann.service.ThreadService$thread_service_runner__1973.invoke(service.clj:70)
09:45:39 riemann.1      |   at clojure.lang.AFn.run(AFn.java:22)
09:45:39 riemann.1      |   at java.lang.Thread.run(Thread.java:745)

誰か助けてくれませんか？ありがとう。

4

1 に答える 1

5

「clojure.lang.IFnにキャストできません」というエラーは、常に、そのように扱うことができない何かが関数に与えられることを期待していることを示しています...

(defn notify [& egroups]
  (for [egroup egroups]
    (rollup 1 60 (apply email (emails egroup)))))

これは、実際のストリームではなく、生成されたロールアップ ストリームの LazySeq を返します (Riemann では、ストリームは IFn です)。したがって、Riemann がストリームを IFn として呼び出そうとすると、エラーが発生します...

次のようなものはどうですか：

(defn notify [& egroups]
  (rollup 1 60 (apply email (mapcat emails egroups))))

ここでは、事前にグループのリストを電子メールのリストに変換してから、作業を進めます。

または、本当に複数のストリームが必要な場合 (たとえば、To: 行の共有を避ける)、それらをロールアップに適用します。

(defn notify [& egroups]
  (apply rollup 1 60 (map email (map emails groups))))

これが役に立てば幸いです。明らかに、構成全体が複製されていません。

于 2015-05-09T10:19:57.957 に答える