Skip to content

Fukász Rómeó Ervin / cloud

Go to a project
Commit f06fe9b9 by Kálmán Viktor
Options

monitor: agent and net queue

parent 3debd325
Showing with 10 additions and 1 deletions
circle/monitor/tasks/local_periodic_tasks.py
...@@ -60,12 +60,21 @@ def check_celery_queues(): ...@@ -60,12 +60,21 @@ def check_celery_queues():
metrics.append(graphite_string("circle", n.host.hostname, metrics.append(graphite_string("circle", n.host.hostname,
"vm-" + s, is_queue_alive, time())) "vm-" + s, is_queue_alive, time()))
is_net_queue_alive = check_queue(n.host.hostname, "net", "fast")
metrics.append(graphite_string("circle", n.host.hostname,
"net-fast", is_net_queue_alive, time()))
is_agent_queue_alive = check_queue(n.host.hostname, "agent")
metrics.append(graphite_string("circle", n.host.hostname, "agent",
is_agent_queue_alive, time()))
for ds in DataStore.objects.all(): for ds in DataStore.objects.all():
for s in ["fast", "slow"]: for s in ["fast", "slow"]:
is_queue_alive = check_queue(ds.hostname, "vm", s) is_queue_alive = check_queue(ds.hostname, "vm", s)
metrics.append(graphite_string("storage", ds.hostname, metrics.append(graphite_string("storage", ds.hostname,
"vm-" + s, is_queue_alive, time())) "storage-" + s, is_queue_alive,
time()))
Client().send(metrics) Client().send(metrics)
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or sign in to comment