produce data into amqp and read by carbon-cache

Asked by Jan Doberstein on 2011-07-01

We try to use RabbitMQ to get some Data into Graphite. As we see CarbonCache bind to an exchange point an not a queue.

But how should a message be, so that Graphite can work with?


Question information

English Edit question
Graphite Edit question
No assignee Edit question
Solved by:
Jan Doberstein
Last query:
Last reply:
chrismd (chrismd) said : #1

Carbon declares its own exclusive queue. It creates a binding for that queue to the exchange for each bind pattern specified in the BIND_PATTERNS setting.

You can send messages one of two ways, depending on how you set the AMQP_METRIC_IN_BODY setting. If it is False, the messages you send should have the metric path as the routing key and the body of the message will be

<value> <timestamp>\n

If AMQP_METRIC_IN_BODY is True however, the routing key can be anything you want and the contents of the message must be:

<metric-path> <value> <timestamp>\n

Hope that helps.

Jan Doberstein (jalogisch) said : #2

Thanks for your help!

we digged into the source code, and found a bug in txamqp, we need to upgrade (via easy_install) to 0.4 and also need to upgrade twisted to the latest.

after that (and a little modification on txamqp, we are now able to use the input via amqp.

i like graphite very much, but the documentation should be a little bit better, so that you didn't need to look into the source to understand what todo!

go on with the work!