x/stacktach-sandbox
Code Issues Proposed changes

Include monitor.error queue

Browse Source 
Also buffed stv3_status.py to handle api nodes.

Change-Id: I70bfc55007d8ced37f47c27c3e31753d42e83492
This commit is contained in:
Sandy Walsh 2015-01-28 06:37:30 -08:00
parent c6e111f645
commit b636a67497
2 changed files with 23 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
ansible/roles/stv3-workers/templates/yagi.conf.j2
View File

@ -23,7 +23,7 @@ default_level = {{ yagi_log_level }}
#config_file = /etc/stv3/logging.conf #config_file = /etc/stv3/logging.conf
[consumers] [consumers]
queues = monitor.info queues = monitor.info,monitor.error
[consumer:monitor.info] [consumer:monitor.info]
#apps = yagi.handler.shoebox_handler.ShoeboxHandler #apps = yagi.handler.shoebox_handler.ShoeboxHandler
@ -34,6 +34,14 @@ routing_key = monitor.info
durable = True durable = True
max_messages = 100 max_messages = 100
[consumer:monitor.error]
apps = winchester.yagi_handler.WinchesterHandler
exchange = monitor
exchange_type = topic
routing_key = monitor.error
durable = True
max_messages = 100
[filters] [filters]
cufpub = compute.instance.exists.verified,compute.instance.exists cufpub = compute.instance.exists.verified,compute.instance.exists

14
bin/stv3_status.py
View File

@ -66,6 +66,7 @@ username = config.get('username')
password = config.get('password') password = config.get('password')
worker_hostnames = config['worker_hostnames'] worker_hostnames = config['worker_hostnames']
rabbit_hostnames = config['rabbit_hostnames'] rabbit_hostnames = config['rabbit_hostnames']
api_hostnames = config['api_hostnames']
port = int(config.get('ssh_port', 22)) port = int(config.get('ssh_port', 22))
vhost = config.get('vhost', '/') vhost = config.get('vhost', '/')
lines = config.get('tail_lines', '100') lines = config.get('tail_lines', '100')
@ -86,6 +87,19 @@ for worker in worker_hostnames:
with open("%s-yagi-%s.log" % (worker, cell), "w") as o: with open("%s-yagi-%s.log" % (worker, cell), "w") as o:
o.write(ret[i+1]) o.write(ret[i+1])
for api in api_hostnames:
commands = ["ps aux | grep -E 'gunicorn'",
"tail --lines %s /var/log/stv3/gunicorn.log" % (lines, ))
]
print "--- api: %s" % (api, )
ret = ssh(worker, commands, username, password, port)
print ret[0]
print "Writing %s-gunicorn.log" % (worker,)
with open("%s-gunicorn.log" % (worker,), "w") as o:
o.write(ret[1])
prefixes = '|'.join(queue_prefixes) prefixes = '|'.join(queue_prefixes)
for rabbit in rabbit_hostnames: for rabbit in rabbit_hostnames:
print "--- RabbitMQ: %s vhost: %s" % (rabbit, vhost) print "--- RabbitMQ: %s vhost: %s" % (rabbit, vhost)