huhongbo / collectd-amqp-graphite-opentsdb-gateway Goto Github PK

AMQP to Graphite and OpenTSDB gateways.

Input format is assumed to be either in graphite format:

some.metric.name.datacenter.host value timestamp

Or in json format:
{"datacenter":"east_coast","timestamp":12345678,"value":123.12,"metric":"some.metric.name","host":"127.0.0.1"}

Note: Multiple metrics can be sent in one AMQP message, as long as each entry is seperated by a newline character (\n)

The OpenTSDB gateway will transform datacenter and host to be tags.

The compression option specifies that the data is compressed with Snappy. Requires Compress::Snappy perl module to be installed.

Command line options:

perl amqp_consumer_opentsdb.pl \
--var amqp_host=127.0.0.1 \
--var amqp_port=5672 \
--var amqp_user=username \
--var amqp_password=password \
--var amqp_vhost=/vhost \
--var amqp_exchange=metrics \
--var amqp_queue=queue \
--var opentsdb_host=127.0.0.1 \
--var opentsdb_port=4242 \
--var debug=1 \
--var input_format=<json|graphite> \
--var compress=<1|0>
TODO: