Detect whether Celery is Available/Running

by

Here’s the code I’ve been using. celery.task.control.Inspect.stats() returns a dict containing lots of details about the currently available workers, None if there are no workers running, or raises an IOError if it can’t connect to the message broker. I’m using RabbitMQ – it’s possible that other messaging systems might behave slightly differently. This worked in Celery 2.3.x and 2.4.x; I’m not sure how far back it goes.

def get_celery_worker_status():
    ERROR_KEY = "ERROR"
    try:
        from celery.task.control import inspect
        insp = inspect()
        d = insp.stats()
        if not d:
            d = { ERROR_KEY: 'No running Celery workers were found.' }
    except IOError as e:
        from errno import errorcode
        msg = "Error connecting to the backend: " + str(e)
        if len(e.args) > 0 and errorcode.get(e.args[0]) == 'ECONNREFUSED':
            msg += ' Check that the RabbitMQ server is running.'
        d = { ERROR_KEY: msg }
    except ImportError as e:
        d = { ERROR_KEY: str(e)}
    return d

More Related Contents:

  1. Django Celery Logging Best Practice
  2. Cancel an already executing task with Celery?
  3. How to check task status in Celery?
  4. Running “unique” tasks with celery
  5. Reporting yielded results of long-running Celery task
  6. How can I schedule a Task to execute at a specific time using celery?
  7. Distributed task queues (Ex. Celery) vs crontab scripts
  8. Running Scrapy spiders in a Celery task
  9. What is related_name used for?
  10. How to debug in Django, the good way? [closed]
  11. Django DB Settings ‘Improperly Configured’ Error
  12. How to create an object for a Django model with a many to many field?
  13. Count frequency of values in pandas DataFrame column
  14. django abstract models versus regular inheritance
  15. Getting TypeError: __init__() missing 1 required positional argument: ‘on_delete’ when trying to add parent table after child table with entries
  16. How to set the timezone in Django
  17. Python + Django page redirect
  18. Python and character normalization
  19. Pass extra arguments to Serializer Class in Django Rest Framework
  20. Django: AppRegistryNotReady()
  21. Count() vs len() on a Django QuerySet
  22. Customize/remove Django select box blank option
  23. Duplicating model instances and their related objects in Django / Algorithm for recusrively duplicating an object
  24. Add class to Django label_tag() output
  25. Sorting related items in a Django template
  26. django.core.exceptions.ImproperlyConfigured: Error loading MySQLdb module: No module named MySQLdb
  27. How to use csrf_token in Django RESTful API and React?
  28. Run manage.py from AWS EB Linux instance
  29. How to perform filtering with a Django JSONField?
  30. Multiple lookup_fields for django rest framework

Leave a Comment