Where is the documentation to connect Carbon to RabbitMQ?
I'm trying to get data from the message queue of RabbitMQ, but so far unsuccessful.
/etc/rabbitmq/
[{kernel,
/etc/rabbitmq/
export RABBITMQ_
export RABBITMQ_
export ERL_EPMD_
export RABBITMQ_
/etc/carbon/
AMQP_VERBOSE = True
AMQP_HOST = rabbit@localhost
AMQP_PORT = 5672
AMQP_VHOST = /
AMQP_USER = guest
AMQP_PASSWORD = guest
AMQP_EXCHANGE = graphite
AMQP_METRIC_
Script to push data to RabbitMQ:
#!/usr/bin/env python
import subprocess, time
import pika # imported via a virtual environment (local pip)
def get_data():
command = subprocess.
return(command, int(time.time()))
def sort_data(data):
data = data.replace("/", " ").rstrip("\n")
data_l = data.split(" ")
data_
return(
def send_data(data_s, queue_name, server):
connection = pika.BlockingCo
channel = connection.
channel.
channel.
connection.
def main():
server = "localhost"
queue_name = "graphite"
metric_paths = ("rabbitmq.
data, timestamp = get_data()
data_t = sort_data(data)
for metric in range(len(
data_s = "%s, %d, %d" % (metric_
if __name__ == "__main__":
main()
Data is pushed to RabbitMQ:
[root@gtw1 carbon]# rabbitmqctl list_queues
Listing queues ...
graphite 12
...done.
But Carbon doesn't get the data from the queue. I think this has to do with the exchange types. The default in the configuration file is set to 'AMQP_EXCHANGE = graphite', but when I run:
[root@gtw1 carbon]# rabbitmqctl list_exchanges
Listing exchanges ...
direct
amq.direct direct
amq.fanout fanout
amq.headers headers
amq.match headers
amq.rabbitmq.log topic
amq.rabbitmq.trace topic
amq.topic topic
...done.
I don't get that exchange. I can't find any documentation about this setup. Is there any?
Question information
- Language:
- English Edit question
- Status:
- Expired
- For:
- Graphite Edit question
- Assignee:
- No assignee Edit question
- Last query:
- Last reply: