Hi,
I have created a simple sensu set-up and want to have a try of its transport handler.
Following https://sensuapp.org/docs/0.26/guides/getting-started/intro-to-handlers.html#create-a-transport-handler, I created a check to make sure events been created:
{
“checks”: {
“http-server4”: {
“type”: “metric”,
“command”: “http.py -s google.com”,
“standalone”: true,
“interval”: 5,
“handler”: “transport”
}
}
}
``
And the handler:
{
“handlers”: {
“transport”: {
“type”: “transport”,
“pipe”: {
“type”: “direct”,
“name”: “test_transport”
}
}
}
}
``
Then I write a simple code hope to get event data:
#!/usr/bin/env python
import pika
credentials = pika.PlainCredentials(‘sensu’, ‘secret’)
parameters = pika.ConnectionParameters(‘10.116.222.133’,5672,"/sensu",credentials)
connection = pika.BlockingConnection(parameters)
channel = connection.channel()
channel.queue_declare(queue=‘transport_bind’)
def callback(ch, method, properties, body):
print(" Received %r" % body)
channel.basic_consume(callback, queue=‘test_transport’, no_ack=True)
print(’ Waiting for messages. To exit press CTRL+C’)
channel.start_consuming()
``
But, I get nothing.
Anything I missed ??