diff options
author | 2018-05-26 16:37:56 +0200 | |
---|---|---|
committer | 2018-05-26 16:37:56 +0200 | |
commit | 1f4b827b439e236a24a811404dcb5c2e278f206d (patch) | |
tree | 4fa1251fe338a38dc3f955fa7783cac497b563ca /config.py | |
parent | automatically clean up queues and message to reduce rabbitmq memory footprint (diff) |
add rabbitmq mgmt webinterface, handle container autodiscovery better, minor code optimisations, update readme
Diffstat (limited to 'config.py')
-rw-r--r-- | config.py | 24 |
1 files changed, 11 insertions, 13 deletions
@@ -1,27 +1,25 @@ import os -def attempt_automatically_finding_the_ip_of_rmq(): +def autodiscover(): + container_names = ["rmq", "pdrmq", "snekbox_pdrmq_1"] try: import docker client = docker.from_env() - containers = client.containers.get('snekbox_pdrmq_1') - HOST = list(containers.attrs.get('NetworkSettings').get('Networks').values())[0]['IPAddress'] - return HOST + for name in container_names: + container = client.containers.get(name) + if container.status == "running": + host = list(container.attrs.get('NetworkSettings').get('Networks').values())[0]['IPAddress'] + return host except Exception: return '172.17.0.2' -USERNAME = 'guest' -PASSWORD = 'guest' -HOST = os.environ.get('RMQ_HOST', attempt_automatically_finding_the_ip_of_rmq()) +USERNAME = os.environ.get('RMQ_USERNAME', 'rabbits') +PASSWORD = os.environ.get('RMQ_PASSWORD', 'rabbits') +HOST = os.environ.get('RMQ_HOST', autodiscover()) PORT = 5672 -EXCHANGE_TYPE = 'direct' - QUEUE = 'input' EXCHANGE = QUEUE ROUTING_KEY = QUEUE - -RETURN_QUEUE = 'return' -RETURN_EXCHANGE = RETURN_QUEUE -RETURN_ROUTING_KEY = RETURN_QUEUE +EXCHANGE_TYPE = 'direct' |