Django command to monitor celeryd

dj_monit_celeryd.py

import sys

from django.core.management.base import BaseCommand
from celery.task.control import ping


class Command(BaseCommand):
    def ok(self, message):
        self.stdout.write('OK: %s' % message)
        sys.exit(0)

    def warning(self, message):
        self.stdout.write('WARNING: %s' % message)
        sys.exit(1)

    def critical(self, message):
        self.stdout.write('CRITICAL: %s' % message)
        sys.exit(2)

    def handle(self, *args, **options):
        rl = ping()
        if not rl:
            self.critical('celery is down')

        for r in rl:
            for name, resp in r.items():
                if resp != 'pong':
                    self.critical(
                        'ping %s: got %r (expected "pong")' % (name, resp))

        self.ok(repr(rl))