{:deps {mrmcc3/aws-metrics-collector
{:git/url "https://github.com/mrmcc3/aws-metrics-collector"
:sha "a16baa17c7b71a684b2085c0e40913315fb85c6b"}}}
Clojure AWS Cloudwatch metric collector.
A collector is a core.async channel that:
accepts metrics as vanilla clojure data
drops non-conforming metrics
batches metrics according to AWS limits
sends the batches periodically to Cloudwatch using the AWS Java SDK
{:deps {mrmcc3/aws-metrics-collector
{:git/url "https://github.com/mrmcc3/aws-metrics-collector"
:sha "a16baa17c7b71a684b2085c0e40913315fb85c6b"}}}
(require
'[mrmcc3.aws.metrics.collector :as c]
'[clojure.core.async :as a])
;; define a collector channel with a Cloudwatch metrics namespace
(def collector (c/collector {:namespace "Test"}))
;; put a single metric
(a/put! collector {:name "im-a-metric" :value 3.14})
;; for multiple metrics use a/onto-chan
(a/onto-chan
collector
{:ResponseTime 125
:RenderTime 55.2}
false)
;; close the collector when finished
(a/close! collector)
Note by default collector
will use a default AWS Cloudwatch client
so make sure the you have AWS credentials setup somewhere in the
default chain with the permission to PutMetricData.
See the specs in the code for more info about the collector options and valid metric data. Dimensions, aggregated statistics, storage resolution, timestamps and units are all supported!
Can you improve this documentation?Edit on GitHub
cljdoc is a website building & hosting documentation for Clojure/Script libraries
× close