Ugh

horror.clj

(defmacro single-key-aggregate-writer [name update-builder table]
  `(defbolt ~name [] [~'tuple ~'collector]
     (let [~'count-maps (tfield "count-maps")]
       (try
         (doseq [[~'agg-id ~'count-map] ~'count-maps]
           (let [~'update-map (~update-builder ~'count-map)]
             (dynamodb/update-item base/aws-credential ~table ~'agg-id ~'update-map)))
         (ack! ~'collector ~'tuple)
         (catch Exception ~'e
           (log/error (str "Exception commiting to " ~table) (seq (.getStackTrace ~'e)))
           (log/error ~'e)
           (fail! ~'collector ~'tuple))))))