roles/collectd/fcomm-queue/files/fcomm-queue-collectd.py


1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21

#!/usr/bin/env python
import retask.queue
import socket
import time

interval = 2

# Use FQDN
hostname = socket.gethostname()

queue = retask.queue.Queue('fedora-packages')
queue.connect()

while True:
    print "PUTVAL %s/redis/queue_length interval=%i %i:%i" % (
        hostname,
        interval,
        int(time.time()),
        queue.length,
    )
    time.sleep(interval)