Tag: celery

Sellerie ist ein distributed task queue-framework für Python, für die asynchrone und parallele Ausführung.

Django Sellerie Erhalten unregistrierte Aufgabe des Typs " appname.Aufgaben.hinzufügen'

Anzahl der Antworten 1 Antworten
Folgenden die Dokumentation und die Demo-Django-Projekt hier https://github.com/celery/celery/tree/3.1/examples/django Projektstruktur piesup2 | piesup2 | |__init__.py | |celery.py | |settings.py | |urls.py reports |tasks.py |models.py |etc.... Mein Code piesup2/celery.py from __future__ import absolute_import import os from celery import Celery

Wie rate-limit auf einem Sellerie-queue?

Anzahl der Antworten 3 Antworten
Ich gelesen das in Sellerie-Dokumentation : Aufgabe.rate_limit http://celery.readthedocs.org/en/latest/userguide/tasks.html#Task.rate_limit Beachten Sie, dass dies ist eine pro-worker-Instanz limit und nicht ein global limit. Zur Durchsetzung einer globalen rate limit (z.B. für eine API mit einer maximalen Anzahl von Anfragen

Sollte django-Modell Objekt-Instanzen übergeben werden, die Sellerie?

Anzahl der Antworten 2 Antworten
# models.py from django.db import models class Person(models.Model): first_name = models.CharField(max_length=30) last_name = models.CharField(max_length=30) text_blob = models.CharField(max_length=50000) # tasks.py import celery @celery.task def my_task(person): # example operation: does something to person # needs only a few of

Sellerie verpasste Herzschlag (on_node_lost)

Anzahl der Antworten 3 Antworten
Ich nur ein Upgrade auf Sellerie 3.1 und jetzt sehe ich, das ich meine logs :: on_node_lost - INFO - missed heartbeat from [email protected]_name for every queue/worker in my cluster. Laut der docs BROKER_HEARTBEAT ist standardmäßig ausgeschaltet

Warum sind celery_taskmeta und andere Tabellen nicht erstellt werden, wenn ein syncdb in django?

Anzahl der Antworten 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

Sellerie gibt connection reset by peer

Anzahl der Antworten 2 Antworten
Richte ich das rabbitmqserver und fügte hinzu, die Benutzer mit den folgenden Schritten: [email protected]*******:/usr/lib/rabbitmq/lib/rabbitmq_server-3.2.3$ sudo rabbitmqctl list_users Listing users ... guest [administrator] phantom [administrator] phantom1 sudo rabbitmqctl set_permissions -p phantom phantom1 ".*" ".*" ".*" [email protected]******:/usr/lib/rabbitmq/lib/rabbitmq_server-3.2.3$ sudo

Einstellung CELERY_ALWAYS_EAGER True wirft Fehler

Anzahl der Antworten 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

Probleme mit Sellerie & Redis Backend

Anzahl der Antworten 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

Sellerie hat nicht gut funktionieren, weil der Fehlercode 104

Anzahl der Antworten 2 Antworten
Ich habe ein problem mit der Ausführung Sellerie auf rabbitmq-server. Ich suchte und fand ein link, aber es hilft mir nicht. Mein env ist ubuntu 14.04, python 2.7.6, Sellerie 3.1.15, Django 1.7. Referenzierung ein link, die ich

Sellerie und benutzerdefinierte Verbraucher

Anzahl der Antworten 3 Antworten
Meines Wissens Sellerie wirkt sowohl als Produzent und konsument von Nachrichten. Dies ist nicht das, was ich erreichen will. Ich will Sellerie zu handeln, wie der Verbraucher ist, nur, um Feuer zu bestimmten Aufgaben auf der Grundlage

Sellerie: Wenn Sie wählen sollten, Redis als message-broker über RabbitMQ?

Anzahl der Antworten 1 Antworten
Mein grobes Verständnis ist, dass Redis ist besser, wenn Sie die in-memory key-value-store-Funktion, jedoch bin ich nicht sicher, wie das zu tun hat mit der Verteilung von Aufgaben? Heißt das, wir sollten verwenden Redis als message-broker, WENN

python-celery kein Modul mit dem Namen app.Aufgaben

Anzahl der Antworten 1 Antworten
Ich versuche zu laufen, die demo-Anwendung von Sellerie das Projekt-Verzeichnis ist /usr/local/proj [[email protected] proj]# ls -lh total 16K -rw-r--r--. 1 root root 363 Dec 23 00:36 celery.py -rw-r--r--. 1 root root 522 Dec 23 00:36 celery.pyc -rw-r--r--.

Wie kann ich die in die Warteschlange eingereiht Aufgaben in RabbitMQ?

Anzahl der Antworten 4 Antworten
Ich bin mit RabbitMQ als meine message broker und meine Arbeiter sind Sellerie Aufgaben. Ich bin versuchen, um ein Problem zu diagnostizieren, wo ich bin enqueue Aufgaben zu RabbitMQ aber Sellerie nicht abholen, dann nach oben. Gibt

Schließen Sie neue Sellerie regelmäßige Aufgabe in django

Anzahl der Antworten 2 Antworten
Es ist keine Frage, sondern Hilfe, um diejenigen, die finden, dass die Erklärung von regelmäßigen Aufgaben in der Sellerie 4.0.1-Dokumentation ist schwer zu integrieren in django: http://docs.celeryproject.org/en/latest/userguide/periodic-tasks.html#entries kopieren-einfügen, Sellerie config-Datei main_app/celery.py: from celery import Celery from celery.schedules

TypeError: urlopen() got an unexpected keyword argument 'Header'

Anzahl der Antworten 2 Antworten
Bin ich mit der rest-api zum senden von push-Benachrichtigungen. Docs sind Sie hier. Ich bin mit der Pyramide und Einplanung dieser push-Benachrichtigungen mit Sellerie. Dies ist mein code-Beispiel: result = urllib2.urlopen(urlRequest, headers={ "X-Parse-Application-Id": settings["parse.application.id"], "X-Parse-REST-API-Key": settings["parse.restapi.key"], "Content-Type":

Django Asynchrone Verarbeitung

Anzahl der Antworten 2 Antworten
Ich habe eine Reihe von Django-requests, die führt einige mathematische Berechnungen ( in C geschrieben und ausgeführt werden, die über eine Cython-Modul ), die in einer unbestimmten Menge ( in der Größenordnung von 1 Sekunde ) der

Ausführen von Python-Sellerie auf Elastic Beanstalk mit Django

Anzahl der Antworten 1 Antworten
Ich überlege mir ein Wechsel zu Elastic Beanstalk (wegen der Preise). Die Blockade ist, dass ich keine Ahnung habe, wie das einrichten Sellerie auf ein python-app (Django, in meinem Fall) bereitgestellten service. Hat jemand geschafft, setup Sellerie

Vermeidung von doppelten Aufgaben in Sellerie broker

Anzahl der Antworten 4 Antworten
Ich möchte zu erstellen, der folgende Ablauf mit Sellerie-Konfiguration\api: Senden TaskA(argB) Nur, wenn Sellerie Warteschlange hat keine TaskA(argB) bereits anhängig Ist es möglich? wie? InformationsquelleAutor arikg | 2014-11-09

Sellerie - call-Funktion auf die Aufgabe

Anzahl der Antworten 1 Antworten
Ich bin mit Sellerie mit django und rabbitmq zum erstellen einer message queue. Ich habe auch ein Arbeiter, der ursprünglich aus einer anderen Maschine. In einem django, das ich beginne einem Prozess wie diesem: def processtask(request, name):

Immer task_id innerhalb einer Sellerie Aufgabe

Anzahl der Antworten 3 Antworten
Dies ist wahrscheinlich eine dumme Frage aber die hat mich ratlos aus einem Rubinroten hintergrund. Ich habe ein Objekt, das so aussieht, wenn ich versuche, es zu drucken. print celery.AsyncResult.task_id >>><property object at 0x10c383838> Ich hatte erwartet,

Rückruf für Sellerie apply_async

Anzahl der Antworten 2 Antworten
Benutze ich celery in meiner Anwendung zur Ausführung periodischer Aufgaben. Mal sehen, einfache Beispiel unten from myqueue import Queue @perodic_task(run_every=timedelta(minutes=1)) def process_queue(): queue = Queue() uid, questions = queue.pop() if uid is None: return job = group(do_stuff(q)

Mit mock zu patch Sellerie Aufgabe in Django unit-tests

Anzahl der Antworten 2 Antworten
Ich versuche, verwenden Sie die python-mock-Bibliothek zu patchen Sellerie Aufgabe, die ausgeführt wird, wenn ein Modell gespeichert wird, in meinem django-app, um zu sehen, dass es aufgerufen wird, richtig. Grundsätzlich die Aufgabe definiert ist, innerhalb myapp.tasks, und

RabbitMQ auf EC2 Verbraucht Unmengen von CPU

Anzahl der Antworten 2 Antworten
Ich versuche, RabbitMQ mit Sellerie und Django geht auf eine EC2-Instanz zu tun, ein paar ziemlich grundlegende hintergrund-Verarbeitung. Ich bin mit rabbitmq-server 2.5.0 auf einem großen EC2-Instanz. Ich heruntergeladen und installiert die test-client nach der Anleitung hier

Ausführen while-Schleife, die gleichzeitig mit Kolben-server

Anzahl der Antworten 2 Antworten
Ich aktualisiere einige LEDs mit python. Ich mache das bereits so: from LEDs import * myLEDs = LEDs() done = False while not done: myLEDs.iterate() Wollte ich mit Flask als eine Brücke zwischen einige gut aussehende ReactJS

Wie debug "could not receive data from client: Connection reset by peer"

Anzahl der Antworten 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

Wie man eine Sellerie Aufgabe scheitern innerhalb der Aufgabe?

Anzahl der Antworten 3 Antworten
Unter bestimmten Bedingungen, ich möchte eine Sellerie-Aufgabe nicht aus, dass innerhalb dieser Aufgabe. Ich habe versucht, die folgenden: from celery.task import task from celery import states @task() def run_simulation(): if some_condition: run_simulation.update_state(state=states.FAILURE) return False Jedoch die Aufgabe

Verständnis Sellerie Aufgabe prefetching

Anzahl der Antworten 4 Antworten
Ich habe gerade herausgefunden über die Konfigurations-option CELERYD_PREFETCH_MULTIPLIER (docs). Die Standardeinstellung ist 4, aber (ich glaube) möchte ich das prefetching auszuschalten oder so gering wie möglich. Ich setzen Sie ihn auf 1, und das ist nahe genug,

ImproperlyConfigured(“Einstellungen.DATENBANKEN ist nicht richtig konfiguriert. ") Fehler beim einrichten Django

Anzahl der Antworten 3 Antworten
Versucht, Folgen Sie den Anweisungen hier die Einrichtung einer Django-Instanz auf Heroku. Habe soweit die installation von Sellerie, bis auf folgenden Schritt: $ python manage.py syncdb Wann bekomme ich die folgende Fehlermeldung: erhöhen ImproperlyConfigured("Einstellungen.DATENBANKEN ist falsch konfiguriert".

so entfernen Sie den task aus Sellerie mit redis broker?

Anzahl der Antworten 3 Antworten
Ich Habe fügen Sie einige falsche task zu einem celery mit redis broker aber das will ich jetzt entfernen Sie die falsche task und ich finde keine Möglichkeit, dies zu tun Gibt es einige Befehle oder einige

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

Anzahl der Antworten 2 Antworten
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

Sellerie ImportError: No module named proj

Anzahl der Antworten 2 Antworten
Ich versuche, setup-Sellerie mit Django. Ich habe den guide befolgt: project/project/celery.py: from __future__ import absolute_import import os from celery import Celery from django.conf import settings # set the default Django settings module for the 'celery' program. os.environ.setdefault('DJANGO_SETTINGS_MODULE',

Sellerie - Speicherverbrauch minimieren

Anzahl der Antworten 4 Antworten
Haben wir ~300 celeryd Prozesse laufen unter Ubuntu 10.4 64-bit , im idle-jeder Prozess braucht ~19 MB RES, ~174mb VIRT, so sind es rund 6 GB RAM im idle-Modus für alle Prozesse. Im aktiven Status - Prozess

Sellerie - Verkettung Gruppen und Teilaufgaben. -> out-of-order execution

Anzahl der Antworten 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

Führen Sie eine Sellerie-Arbeiter in den hintergrund

Anzahl der Antworten 1 Antworten
Ich bin mit einem Sellerie-Arbeiter wie diese: celery worker --app=portalmq --logfile=/tmp/portalmq.log --loglevel=INFO -E --pidfile=/tmp/portalmq.pid Nun möchte ich laufen diese Arbeiter im hintergrund. Ich habe versucht mehrere Dinge, einschließlich: nohup celery worker --app=portalmq --logfile=/tmp/portal_mq.log --loglevel=INFO -E --pidfile=/tmp/portal_mq.pid >>

Kann nicht sehen, mein Sellerie-Protokolle beim ausführen schlagen

Anzahl der Antworten 2 Antworten
Ich mich ab, Sellerie via supervisord, siehe den Eintrag unten. [program:celery] user = foobar autostart = true autorestart = true directory = /opt/src/slicephone/cloud command = /opt/virtenvs/django_slice/bin/celery beat --app=cloud -l DEBUG -s /home/foobar/run/celerybeat-schedule --pidfile=/home/foobar/run/celerybeat.pid priority = 100 stdout_logfile_backups

Add n Aufgaben Sellerie Warteschlange und warten auf die Ergebnisse

Anzahl der Antworten 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

Zugriff verweigert für Benutzer rabbitmq & Sellerie

Anzahl der Antworten 4 Antworten
Ich erstelle vhost: rabbitmqctl add_vhost test Dann Benutzer: rabbitmqctl add_user user 123456 Dann nehme ich die Berechtigungen, die dem Benutzer: rabbitmqctl set_permissions -p test user "test" "test" "test" Ich verwende Sellerie, in tasks.py: app = Celery('tasks', broker='amqp://user:[email protected]/test',

Python task-queue alternativen und Rahmenbedingungen

Anzahl der Antworten 3 Antworten
Scheint es verschiedene Implementierungen von Aufgabe/job-Warteschlangen für Python 3: Sellerie, beliebt aber anscheinend nicht mehr gepflegt und veraltet; RQ, von denen habe ich wenig Informationen; TaskTiger, ähnlich RQ ich weiß wenig über ihn; Huey , ähnlich RQ

Sellerie-Blumen-Sicherheit in der Produktion

Anzahl der Antworten 4 Antworten
Ich bin auf der Suche zu verwenden, Blume (https://github.com/mher/flower) zu überwachen, meine Sellerie Aufgaben an die Stelle der django-admin als empfehlenswert in Ihre docs (http://docs.celeryproject.org/en/latest/userguide/monitoring.html#flower-real-time-celery-web-monitor). Allerdings, denn ich bin neu in diesem, ich bin ein wenig verwirrt

Sellerie Speicher nicht freigegeben werden

Anzahl der Antworten 4 Antworten
Sieht es aus wie Sellerie Speicher nicht freigegeben werden, nachdem Aufgabe beendet. Jedes mal, wenn eine Aufgabe abgeschlossen ist, es wäre 5m-10m-memory-Leck. So mit tausenden von Aufgaben, bald wird es zu verwenden, bis alle Speicher. BROKER_URL =

Sellerie - errno 111 connection refused

Anzahl der Antworten 2 Antworten
Mein Sellerie Aufgaben aufhört, ausgeführt zwischen. Meine rabbitmq Haltestellen dazwischen und dann muss ich manuell neu starten. Beim letzten mal(15-16 Stunden zurück), ähnliches problem aufgetreten ist, habe ich Folgendes (manuell), und es begann wieder zu arbeiten. Ich

Gurke weigert sich zu serialisieren Inhalte mit Sellerie reporting ContentDisallowed: die Weigerung zu Deserialisieren nicht Vertrauenswürdige Inhalte von Typ-Gurke

Anzahl der Antworten 1 Antworten
Ich versuche, einige python-Objekt meist json serialisierbar außer datetime.datetime in rabbitmq Warteschlange und so mit pickle serialisieren. celery_config Datei: CELERY_TASK_SERIALIZER = 'pickle' CELERY_RESULT_SERIALIZER = 'pickle' Ist es eine Ausnahme, die sagen: File "/usr/local/lib/python2.7/dist-packages/kombu/serialization.py", line 174, in loads

Django-Celery-Task-Protokollierung

Anzahl der Antworten 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

Sellerie AttributeError: async-error

Anzahl der Antworten 6 Antworten
Ich habe RabbitMQ und Sellerie läuft lokal auf meinem Mac (OS/X 10.13.4), der folgende code funktioniert lokal bei mir laufen hinzufügen.Verzögerung(x,y): #!/usr/bin/env python from celery import Celery from celery.utils.log import get_task_logger logger = get_task_logger(__name__) app = Celery('tasks',

läuft Sellerie als daemon mit Vorgesetzten nicht arbeiten

Anzahl der Antworten 3 Antworten
Habe ich eine django-app, in der es eine Sellerie-Funktionalität, so kann ich in der Lage zu laufen, den Sellerie erfolgreich wie unten celery -A tasks worker --loglevel=info aber als eine bekannte Tatsache, dass wir brauchen, um es

Warum würde die Ausführung geplanter Aufgaben mit Sellerie werden bevorzugt über crontab?

Anzahl der Antworten 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

Registrieren Sellerie-Klasse-basierte Aufgaben

Anzahl der Antworten 2 Antworten
Python 3.x -, Sellerie-4.x... Habe ich eine Klasse-basierten Aufgabe. myproj/celery.py from celery import Celery # django settings stuff... app = Celery('myproj') app.autodiscover_tasks() app1/tasks.py import celery class EmailTask(celery.Task): def run(self, *args, **kwargs): self.do_something() Wenn ich das Tue: $

Wie zu reinigen, die Aufgaben in Sellerie-Warteschlangen verwenden Redis als der broker

Anzahl der Antworten 2 Antworten
Part1 Habe ich gelesen und versucht verschiedene SO threads löschen der Sellerie Aufgaben unter Verwendung von Redis, aber keiner von Ihnen arbeitete. Bitte lassen Sie mich wissen, wie zu reinigen, die Aufgaben in Sellerie verwenden Redis als

Wie überprüfen Sie den task-status in Sellerie?

Anzahl der Antworten 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() ==

Wie zu verwenden .delay () - Methode in django-celery?

Anzahl der Antworten 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: