Tag: django-celery
Django-Sellerie enthält Sellerie integration für Django.
3
Antworten
Ich versuche zu implementieren ein einfaches Beispiel für die Sellerie in meinem Produktions-server habe ich folgte dem tutorial, in dem Sellerie website über das ausführen von Sellerie als daemon http://docs.celeryproject.org/en/latest/tutorials/daemonizing.html#daemonizing, und ich habe die config-Datei in /etc/default/celeryd
2
Antworten
Ich bin mit Sellerie-django-Warteschlange-Aufgaben auf meiner Website backend. Ich bin versucht, erstellen Sie eine setup wo ich zwei queues mit dem Namen "low" und "high" und zwei Arbeiter W1 und W2. Ich will, dass Sie verbrauchen die
3
Antworten
Hier ist mein setup: django 1.3 Sellerie 2.2.6 django-celery 2.2.4 djkombu 0.9.2 In meinem settings.py Datei habe ich BROKER_BACKEND = "djkombu.transport.DatabaseTransport" d.h. ich bin nur mit der Datenbank in die Warteschlange Aufgaben. Nun zu meinem problem: ich
6
Antworten
Ich versuche zu setup Sellerie und django, aber der celery_taskmeta Tabelle wird nicht erstellt. Habe ich folgten zahlreiche (Aktuelle) tutorials Hinzugefügt djcelery und djkombu zu meinem installed_apps. Hinzugefügt wurde die 'BROKER_TRANSPORT = "djkombu.transport.DatabaseTransport" " Linie, um meine
2
Antworten
Habe ich einige asynchrone Aufrufe in meinem code. Wie diese: send_message_to_install.delay(install, alert.message, badge, code, campaign=alert.campaign, **kwargs) Ich bin nicht daran interessiert, immer alle Ergebnisse zurück, es ist nur wichtig, dass die Funktion ausgeführt wird, synchron während der
2
Antworten
Ich habe ein system eingerichtet, die derzeit mit Sellerie-mit redis backend tun eine Menge asynchrone Aufgaben wie das versenden von E-Mails, ziehen soziale Daten, krabbeln,etc. Alles funktioniert Super, aber ich bin mit der Gruppe herauszufinden, wie das
2
Antworten
Bin ich mit einem django-celery-Anwendung auf Ubuntu-12.04. Wenn ich eine Sellerie Aufgabe von meinem web-interface, bekomme ich die folgende Fehlermeldung, form angenommen postgresql-9.3 logfile (Maximalwert der log): 2013-11-12 13:57:01 GMT tss_usr 8113 LOG: could not receive data
2
Antworten
Habe ich eine django-celery-Anwendung wie in der Anleitung unter: http://docs.celeryproject.org/en/master/django/first-steps-with-django.html Funktioniert alles einwandfrei wenn ich es ohne parameter ein, wie in: $ python manage.py celery worker -l info aber ich kann es nicht starten Sie es mit
2
Antworten
Wenn ich etwas wie das folgende group1 = group(task1.si(), task1.si(), task1.si()) group2 = group(task2.si(), task2.si(), task2.si()) workflow = chain(group1, group2, task3.si()) Die intuitive interpretation ist, dass task3 sollte nur ausgeführt werden, wenn alle Aufgaben in der Gruppe
3
Antworten
Ich würde mehrere Aufgaben hinzufügen, um Sellerie Warteschlange und warten auf Ergebnisse. Ich habe verschiedene Ideen, wie ich dies erreichen, nutzen Sie irgendeine form von shared storage (memcached, redis, db, etc.), allerdings hätte ich gedacht, es ist
1
Antworten
Ich habe setup Sellerie in einem Django-Projekt, auf dem ich arbeite. Ich würde gerne trennen Sie die Protokollierung für Sellerie Aufgaben vs den Rest der Sellerie-Protokolle (celerycam, celerybeat, etc). Basiert auf Sellerie-Dokumentation (http://docs.celeryproject.org/en/latest/userguide/tasks.html#logging) wie es scheint, ich
2
Antworten
Unter Berücksichtigung der Sellerie ist bereits ein Teil des in den stack task-Warteschlangen (d.h. es wird nicht Hinzugefügt, nur für die Ausführung von crons, das scheint ein overkill, IMHO ). Wie kann seine "wiederkehrende Aufgaben" - Funktion
10
Antworten
Wie wird man prüfen, ob eine Aufgabe ausgeführt wird, in der Sellerie (genauer gesagt, ich bin mit Sellerie-django)? Ich habe die Dokumentation gelesen, und ich habe gegoogelt, aber ich kann nicht sehen, ein Anruf wie: my_example_task.state() ==
2
Antworten
Den ich nutzen möchte .Verzögerung zu erreichen, das asynchrone Verhalten. Der Hauptgrund für die Verwendung dieser ist die Beschleunigung meiner Sicht. Mache ich das falsch? Wenn ja, wie soll ich es richtig machen? Unten ist der Beispiel-code:
1
Antworten
Ich bekomme immer diese keyError. Ich bin senden von Zeichenfolgen-und die id (Integer) der Aufgabe-Funktion, so dass ich nicht denke, es ist die Serialisierung Problem. Auch sagt es, dass der keyerror ist auf dem Weg an die
2
Antworten
Habe ich gesehen, die anderen Beiträge auf stackoverflow in irgendeiner Weise auf die lächerliche Frage, die ich bin, zu Fragen, aber keiner von Ihnen verdummt es nach unten genug für mich zu bekommen, was ich gesucht hatte.
3
Antworten
Ich bin ziemlich neu auf Sellerie und django im Allgemeinen, so bitte entschuldigen Sie meinen Mangel an wissen. Ich bin versucht zu laufen, ein test, um zu tun einige Berechnungen und warten, bis der test abgeschlossen, so
5
Antworten
Ich versuche bis celeryd mit django und rabbit-mq. Bisher habe ich Folgendes getan: Installiert Sellerie aus der pip - Installierten rabbitmq über die debs verfügbar, von seinem Depot Hinzugefügt, ein Benutzer-und vhost zu rabbitmq über rabbitmqctl, sowie
6
Antworten
Ich will eine Aufgabe, die ausgeführt wird, alle 5 Minuten, aber es wird warten, für die Letzte Ausführung beendet ist, und dann zählen diese 5 Minuten. (So kann ich auch sicher sein, dass es nur eine task
1
Antworten
Wie Sie diagnostizieren, warum manage.py celerybeat wird nicht ausgeführt alle Aufgaben? Ich bin mit celerybeat über supervisord mit dem Befehl: /usr/local/myapp/src/manage.py celerybeat --schedule=/tmp/celerybeat-schedule-myapp --pidfile=/tmp/celerybeat-myapp.pid --loglevel=INFO Supervisord erscheint laufen celerybeat ganz gut, und die log-Datei zeigt: [2013-06-12 13:17:12,540:
2
Antworten
Habe ich ein kleines Skript, dass die Warteschlange einreiht, Aufgaben zur Bearbeitung. Dieses Skript macht eine ganze Menge Datenbank Abfragen, um die Elemente zu erhalten, sollte in die Warteschlange eingereiht. Das Problem, das ich bin vor ist,
5
Antworten
Habe ich im folgenden setup mit einem frisch installierten Sellerie und django 1.4: settings.py: import djcelery djcelery.setup_loader() BROKER_HOST = 'localhost' BROKER_PORT = 5672 BROKER_USER = 'user' BROKER_PASSWORD = 'password' BROKER_VHOST = 'test' [...] INSTALLED_APPS = [ 'django.contrib.auth',
6
Antworten
Ich versuche, mit django-celery in meinem Projekt In settings.py ich habe CELERY_RESULT_BACKEND = "amqp" Den server gestartet fein mit python manage.py celeryd --setting=settings Aber wenn ich zugreifen will, ein Ergebnis von einer Aufgabe verzögert, bekomme ich die
2
Antworten
Ich versuche zu Folgen tutorial-Installation von django-celery. Nach der Installation muss ich ausführen, migrieren, um die notwendigen Tabellen, sondern erscheint dieser Fehler: Traceback (most recent call last): File "manage.py", line 10, in <module> execute_from_command_line(sys.argv) File "/home/guilherme/.virtualenvs/martizi-api/local/lib/python2.7/site-packages/django/core/management/__init__.py", line
2
Antworten
Meine app sammelt eine Reihe von Telefonnummern auf einer Seite. Sobald der Nutzer auf den submit-button erstelle ich eine Sellerie-Aufgabe zu nennen, jede Zahl und geben Sie eine erinnerungsmeldung, dann leiten Sie Sie zu einer Seite, wo
4
Antworten
Benutze ich: Sellerie Django-Celery RabbitMQ Sehe ich alle meine Aufgaben in der Django-admin-Seite, aber im moment hat es nur wenige Staaten, wie: ERHIELT WIEDERHOLEN WIDERRUFEN ERFOLG BEGANN FEHLER AUSSTEHENDE Es ist nicht genug information für mich. Ist
6
Antworten
Ich versuche zu starten Sellerie-worker-server von einer Befehlszeile aus: celery -A tasks worker --loglevel=info Den code in tasks.py: import os os.environ[ 'DJANGO_SETTINGS_MODULE' ] = "proj.settings" from celery import task @task() def add_photos_task( lad_id ): ... Bekomme ich
2
Antworten
Arbeite ich an einem Projekt mit django und Sellerie(django-celery). Unser team hat sich entschieden, wickeln Sie alle Daten Zugriff-code innerhalb (app-name)/manager.py(NICHT wickeln, in die Führungskräfte wie die django Weg), und lassen Sie code in (app-name)/task.py nur den
2
Antworten
Ich habe setup Sellerie mit Django ORM als back-end. Versuchen, zu überwachen, was Los ist hinter den kulissen. Habe ich begonnen celeryd mit -E-flag python manage.py celeryd -E -l INFO -v 1 -f /path/to/celeryd.log Begann celerycam mit
9
Antworten
Wie wird man prüfen, ob eine Aufgabe ausgeführt wird, in der Sellerie (genauer gesagt, ich bin mit Sellerie-django)? Ich habe die Dokumentation gelesen, und ich habe gegoogelt, aber ich kann nicht sehen, ein Anruf wie: my_example_task.state() ==
3
Antworten
Standardmäßig Sellerie senden alle Aufgaben, 'Sellerie' Warteschlange, aber Sie können dieses Verhalten ändern, durch hinzufügen von zusätzliche parameter: @task(queue='celery_periodic') def recalc_last_hour(): log.debug('sending new task') recalc_hour.delay(datetime(2013, 1, 1, 2)) # for example Scheduler-Einstellungen: CELERYBEAT_SCHEDULE = { 'installer_recalc_hour': {
2
Antworten
Ich habe Probleme bei der Wiederholung von Aufgaben, hier ist das, was eine test-Aufgabe aussieht from celery.decorators import task @task() def add(x, y): if not x or not y: raise Exception("test error") return x+y Ich finde keine
2
Antworten
Ich bin mit Sellerie und django-celery. Ich habe eine regelmäßige Aufgabe, die ich gerne testen möchte. Ist es möglich, die periodische Abfrage aus der shell manuell, so dass ich die Ausgabe in der Konsole? InformationsquelleAutor der Frage
4
Antworten
Ich versuche, mit den Methoden der Klasse als die django-celery Aufgaben, markieren es mit @Aufgabe Dekorateur. Die gleiche situation wird beschrieben,hiergefragt von Anand Jeyahar. Es ist so etwas wie das class A: @task def foo(self, bar): ...
2
Antworten
Für eine Aufgabe wie diese: from celery.decorators import task @task() def add(x, y): if not x or not y: raise Exception("test error") return self.wait_until_server_responds( wenn es eine exception wirft und ich will versuchen es aus der daemon-Seite,
10
Antworten
Bin ich mit django-celery für meinen django-Projekt. Letzten Tag habe ich geändert mein computer der hostname (ich verwende Ubuntu 12.04, bearbeitet die Datei '/etc/hostname'), und nach dem nächsten Neustart django-celery scheiterte mit Fehler Consumer: Connection Error: [Errno
3
Antworten
Ich versuche, Sellerie Protokollierung der Arbeit mit Django. Ich habe die Protokollierung set-up in settings.py gehen auf die Konsole (das funktioniert so wie ich bin-hosting auf Heroku). An der Spitze der einzelnen module, die ich habe: import
1
Antworten
Ich habe für die Bekämpfung der Django/Sellerie-Dokumentation für eine Weile jetzt, und brauche etwas Hilfe. Ich würde gerne in der Lage sein zu laufen, Periodischen Aufgaben, die mit django-celery. Ich habe gesehen, rund um das internet (und
3
Antworten
Ich bin mit Sellerie asynchrone Aufgaben zu verwalten. Gelegentlich ist jedoch die Sellerie-Prozess geht nach unten, die bewirkt, dass keine der Aufgaben ausgeführt werden. Ich möchte in der Lage sein zu überprüfen, den status von Sellerie und