Wie, um eine Liste der Elemente in der Warteschlange in Sellerie?

Habe ich ein Django-Projekt auf einer Ubuntu-EC2-Knoten, die ich verwende zum einrichten eines asynchronen Verwendung Celery.

Ich bin nach http://michal.karzynski.pl/blog/2014/05/18/setting-up-an-asynchronous-task-queue-for-django-using-celery-redis/ zusammen mit den docs.

Ich in der Lage gewesen, um eine grundlegende Aufgabe, die arbeiten auf der Kommandozeile mit:

(env1)ubuntu@ip-172-31-22-65:~/projects/tp$ celery --app=myproject.celery:app worker --loglevel=INFO

Ich erkannte, dass ich habe eine Reihe von Aufgaben, die in meiner Warteschlange, die noch nicht ausgeführt:

[2015-03-28 16:49:05,916: WARNING/MainProcess] Restoring 4 unacknowledged message(s).
(env1)ubuntu@ip-172-31-22-65:~/projects/tp$ celery -A tp purge
WARNING: This will remove all tasks from queue: celery.
         There is no undo for this operation!

(to skip this prompt use the -f option)

Are you sure you want to delete all tasks (yes/NO)? yes
Purged 81 messages from 1 known task queue.

Wie bekomme ich eine Liste der Elemente in der Warteschlange von der Kommandozeile aus?

InformationsquelleAutor user61629 | 2015-03-28
  1. 16

    Wenn Sie möchten, um alle geplanten Aufgaben,

    celery inspect scheduled

    Finden Sie alle aktiven Warteschlangen

    celery inspect active_queues

    Status

    celery inspect stats

    Für alle Befehle

    celery inspect

    Wenn Sie wollen, um es zu bekommen Fällen.Da Sie über redis als Warteschlange.Dann

    redis-cli

>KEYS * #find all keys

    Dann finden Sie heraus, etwas zu celery

    >LLEN KEY # i think it gives length of list
    • Danke!!! Ich erhalte eine Fehlermeldung mit diesem obwohl: stackoverflow.com/questions/29331280/...
    • Ich habe ein follow-up auf stackoverflow.com/questions/29377944/..., wenn Sie gelangweilt sind.
    • Ein weiteres follow-up in stackoverflow.com/questions/29402447/...
    • Dies ist nützlich, Informationen, aber nicht wirklich eine Antwort auf die Frage. Ich bin auch interessiert in der Liste " alle tasks in der Warteschlange. Das Lesen von man-pages und-help von Sellerie, die ich gefunden habe, diese Befehle, aber Sie können nur Aufgaben auflisten, die entweder geplant, aktiv oder reserviert. Wenn Sie denken, nicht geplante Aufgaben (eta/count), die Bündel von Aufgaben, die nur darauf warten in der Warteschlange. Die redis-Zeug ist ein bisschen hacky, und nicht irgendwelche Informationen neben der Anzahl der Aufgaben. Ist das einfach nicht möglich mit Sellerie ???
    InformationsquelleAutor itzMEonTV
  2. 6

    Hier ist ein copy-paste-Lösung für Redis:

    def get_celery_queue_len(queue_name):
    from yourproject.celery import app as celery_app
    with celery_app.pool.acquire(block=True) as conn:
        return conn.default_channel.client.llen(queue_name)


def get_celery_queue_items(queue_name):
    import base64
    import json
    from yourproject.celery import app as celery_app

    with celery_app.pool.acquire(block=True) as conn:
        tasks = conn.default_channel.client.lrange(queue_name, 0, -1)

    decoded_tasks = []

    for task in tasks:
        j = json.loads(task)
        body = json.loads(base64.b64decode(j['body']))
        decoded_tasks.append(body)

    return decoded_tasks

    Funktioniert es mit Django. Vergiss nur nicht, Sie zu ändern yourproject.celery.

    • Wie wissen Sie, was der name der Warteschlange ist?
    • die Standard-queue name "Sellerie".
    • Danke, ich fragte mich, was falsch war mit meinem Sellerie. Es stellt sich heraus, ich hatte 57,000 Aufgaben in der Warteschlange von einem bug in der vergangenen Woche.
    InformationsquelleAutor Max Malysh
Schreibe einen Kommentar