Wie können Sie Django RQ-Jobs aus einer Warteschlange löschen?

Question

Ich fühle mich ein bisschen dumm für die Frage, aber es scheint nicht in der documentation for RQ zu sein. Ich habe eine "gescheiterte" Warteschlange mit Tausenden von Elementen darin und möchte sie über die Django Admin-Oberfläche löschen. Die Admin-Oberfläche listet sie auf und erlaubt es mir, sie einzeln zu löschen und neu zu ordnen, aber ich kann nicht glauben, dass ich in die Django-Shell eintauchen muss, um es in großen Mengen zu tun.

Was habe ich verpasst?

Answer 1

Der redis-cli erlaubt FLUSHDB, groß für meine lokale Umgebung, wie ich eine bizzallion Jobs erzeuge.

Mit einer funktionierenden Django Integration werde ich updaten. Einfach $ 0,02 hinzufügen.

Answer 2

Die Queue Klasse hat eine empty() Methode, wie zugegriffen werden kann:

import django_rq 
q = django_rq.get_failed_queue() 
q.empty() 

aber in meinen Tests, dass nur die ausgefallenen Liste Schlüssel in Redis gelöscht, nicht die Job-Tasten selbst. Ihre Tausenden von Jobs würden also immer noch Redis Speicher belegen. Um zu verhindern, dass nicht passiert, können Sie die Aufträge einzeln entfernen müssen:

import django_rq 
q = django_rq.get_failed_queue() 
while True: 
    job = q.dequeue() 
    if not job: 
     break 
    job.delete() # Will delete key from Redis 

Wie für eine Schaltfläche in der Admin-Interface mit, dann würden Sie haben django-rq/templates/django-rq/jobs.html Vorlage zu ändern, die admin/base_site.html erstreckt, und scheint nicht zu geben Jeder Raum zum Anpassen.