vent.core.rmq_es_connector package¶
Submodules¶
vent.core.rmq_es_connector.rmq_es_connector module¶
-
class
vent.core.rmq_es_connector.rmq_es_connector.
RmqEs
(es_host='elasticsearch', rmq_host='rabbitmq')[source]¶ Bases:
object
opens a connection to rabbitmq and receives messages based on the provided binding keys and then takes those messages and sends them to an elasticsearch index
-
callback
(ch, method, properties, body)[source]¶ callback triggered on rabiitmq message received and sends it to an elasticsearch index
-
channel
= None¶
-
connections
(wait)[source]¶ wait for connections to both rabbitmq and elasticsearch to be made before binding a routing key to a channel and sending messages to elasticsearch
-
es_conn
= None¶
-
es_host
= None¶
-
es_port
= 9200¶
-
queue_name
= None¶
-
rmq_host
= None¶
-
rmq_port
= 5672¶
-
vent.core.rmq_es_connector.test_rmq_es_connector module¶
-
class
vent.core.rmq_es_connector.test_rmq_es_connector.
Method
(routing_key='foo.bar')[source]¶ Bases:
object
create mock method object
-
routing_key
= None¶
-
-
vent.core.rmq_es_connector.test_rmq_es_connector.
test_rmq_es_connector_callback
()[source]¶ tests the callback function