blob: 7214318c7e00dc5ad5d8a6b8c79a13551e3d9336 (
plain) (
blame)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
|
import os
import docker
from docker.errors import NotFound
import traceback
def autodiscover():
container_names = ["rmq", "pdrmq", "snekbox_pdrmq_1"]
client = docker.from_env()
for name in container_names:
try:
container = client.containers.get(name)
if container.status == "running":
host = list(container.attrs.get('NetworkSettings').get('Networks').values())[0]['IPAddress']
return host
except NotFound:
continue
except Exception:
pass
#print(traceback.format_exc())
return '127.0.0.1'
USERNAME = os.environ.get('RMQ_USERNAME', 'guest')
PASSWORD = os.environ.get('RMQ_PASSWORD', 'guest')
HOST = os.environ.get('RMQ_HOST', autodiscover())
PORT = 5672
QUEUE = 'input'
EXCHANGE = QUEUE
ROUTING_KEY = QUEUE
EXCHANGE_TYPE = 'direct'
|
