Tag: celery
Sellerie ist ein distributed task queue-framework für Python, für die asynchrone und parallele Ausführung.
Sellerie - errno 111 connection refused
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
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
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
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
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?
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
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
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?
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?
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:
Warum Sellerie Rückkehr eine KeyError bei der Ausführung meiner Aufgabe?
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
ImportError: No module named dateutil
2 Antworten
Ich versuche, diesem Beispiel zu Folgen in der "Erste Schritte mit Sellerie" - Dokument. Ich habe installiert Sellerie mit pip. Ich habe eine Datei namens tasks.py in ~/python/Sellerie, und es enthält die folgenden: from celery import Celery
Luftstrom - Python-Datei NICHT in der gleichen DAG-Ordner
4 Antworten
Ich versuche, mit Luftstrom, der die Ausführung einer einfachen Aufgabe python. from __future__ import print_function from airflow.operators.python_operator import PythonOperator from airflow.models import DAG from datetime import datetime, timedelta from pprint import pprint seven_days_ago = datetime.combine(datetime.today() - timedelta(7),
Sellerie ImportError: No module named Aufgaben
1 Antworten
Ich erstelle ein test-Szenario für Sellerie/RabbitMQ/Django. Nach dem surfen/Lesen der verschiedenen Beiträge, so wie meiner, fand ich diese, die nächste, aber immer noch nicht mir helfen. Ich bin mit dem "ImportError: no module named Aufgaben" Fehler beim
Überwachung Sellerie, was sollte ich verwenden?
2 Antworten
Bin ich mit Django, Celery, und Django-Celery. Ich möchte zum überwachen des Status/Ergebnisse meiner Aufgaben, aber ich bin ein wenig verwirrt, wie das zu tun. Verwende ich ./manage.py celeryev, ./manage.py celerymon, ./manage.py celerycam? Führe ich sudo /etc/init.d/celeryevcam
Wie zum ausführen von Sellerie auf windows?
6 Antworten
Wie laufen Sellerie Arbeiter, die unter Windows ohne erstellen von Windows-Service? Gibt es eine Analogie zu $ celery -A your_application worker? InformationsquelleAutor nicks | 2016-05-16
RabbitMQ set_permissions syntax noob
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.
immer Fehler distributionNotFound
1 Antworten
Habe ich installiert celeryD und redis auf meinem system. wenn ich auf den Befehl mit celery. iam immer folgende Fehlermeldung. Traceback (most recent call last): File "/usr/local/bin/celeryd", line 5, in <module> from pkg_resources import load_entry_point File "/usr/lib/python2.7/dist-packages/pkg_resources.py",
Ermöglicht RabbitMQ-Server-Verbindungen
1 Antworten
Ich versuche zu bekommen eine Django-Celery-Arbeiter, um eine Verbindung zu einem RabbitMQ-server laufen alle auf dem gleichen host. Jedoch, wenn ich manage.py celery worker alles was ich bekomme ist: [2013-06-11 17:33:41,185: WARNING/MainProcess] celery@localhost has started. [2013-06-11 17:33:44,192:
Sellerie task-Status immer anhängig
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
Sellerie Bekommen Liste Der Registrierten Aufgaben
1 Antworten
Gibt es eine Möglichkeit, um eine Liste der registrierten Aufgaben? Habe ich versucht: celery_app.tasks.keys() Welche gibt nur gebaut Sellerie Aufgaben wie Sellerie.Akkord, Sellerie.Kette etc. haben Sie überprüft, aus diesem thread so? stackoverflow.com/questions/12651872/... InformationsquelleAutor Richard Knop | 2014-09-26
Consumer Connection error mit django und Sellerie+rabbitmq?
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
python-Sellerie - ImportError: No module named _curses - beim Versuch zu laufen manage.py celeryev
1 Antworten
Hintergrund Windows 7 x 64 Python 2.7 Django 1.4 Sellerie mit Redis-bundle Beim ausführen manage.py celeryev, bekomme ich die folgende Fehlermeldung im terminal import curses File 'c:\Python2\lib\curses\__init__.py', line 15, in <module> from _curses import * ImportError: No
OSError: dlopen(libSystem.dylib, 6): Bild nicht gefunden
4 Antworten
Gerade aktualisiert mein Mac zu El Capitan 10.11. Ich versuche zu laufen Django 1.6 mit Sellerie 3.1 und ich bin immer diese Fehlermeldung jetzt: Unhandled exception in thread started by <function wrapper at 0x10f861050> Traceback (most recent
Kolben mit create_app, SQLAlchemy und Sellerie
2 Antworten
Ich bin wirklich kämpfen, um das richtige setup für Flask, SQLAlchemy und Sellerie. Ich habe ausgiebig gesucht und versucht, verschiedene Ansätze, nichts wirklich zu funktionieren scheint. Entweder verpasste ich den Anwendungskontext oder kann nicht ausgeführt werden die
Sellerie Zeitplan für die Aufgabe (Sellerie, Django und RabbitMQ)
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
Wie kann ich das verzögern der Ausführung von Sellerie Aufgaben?
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,
Sellerie: Fehler bei der Verbindung zu RabbitMQ-Server
2 Antworten
Bin ich angefangen zu verwenden, Sellerie, indem Sie die folgenden dieses "Erste Schritte mit Sellerie". Ich genau die tasks.py angegeben link an. Jedoch, wenn lief ich die Aufgabe mit, celery -A tasks worker --loglevel=info Bin ich immer
Sellerie-Logs in Datei
2 Antworten
Kann mir bitte jemand helfen und mir sagen, wie man den Sellerie Aufgabe debug-details in einer log-Datei? Ich habe eine Anforderung, die details des Sellerie Aufgabe angemeldet .log-Datei. Können Sie bitte einige Vorschläge machen, wie dies getan
Warum ist RabbitMQ nicht persistenten Nachrichten auf einem dauerhaften Warteschlange?
3 Antworten
Ich bin mit RabbitMQ mit Django durch Sellerie. Ich bin mit dem meisten basic-setup: # RabbitMQ connection settings BROKER_HOST = 'localhost' BROKER_PORT = '5672' BROKER_USER = 'guest' BROKER_PASSWORD = 'guest' BROKER_VHOST = '/' Ich importierte eine Sellerie
Sellerie: die automatische Erkennung nicht finden, Aufgaben-Modul in der app
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',
Wie man richtig konfigurieren djcelery Ergebnisse backend-Datenbank
3 Antworten
Ich versuche zu setup djangocelery speichern die Ergebnisse der Aufgabe in die databse. Ich: CELERY_RESULT_BACKEND = 'djcelery.backends.database.DatabaseBackend' dann habe ich synchronisiert und die Migration der db (keine Fehler). Sellerie ist arbeiten und Aufgaben verarbeitet (ich kann die
Läuft Sellerie als root
3 Antworten
Muss ich laufen, mein Django zusammen mit Sellerie als root für den Zugriff von Gründen. Es sagt, ich brauche, um C_FORCE_ROOT Umgebungsvariable. Wie/wo setze ich die Umgebungsvariablen? InformationsquelleAutor der Frage ATOzTOA | 2013-12-03
ImportError: No module named timeutils
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
Vor-und Nachteile zu verwenden, Sellerie vs. RQ
2 Antworten
Momentan bin ich auf python-Projekt, das erfordert, dass mit der Umsetzung einiger hintergrund-jobs (vor allem für E-Mail-Versand und stark Datenbank-updates). Ich benutze Redis für die Aufgabe, die broker. Also in diesem Punkt habe ich zwei Kandidaten: Sellerie
Sellerie - Aufgaben, die ausgeführt werden müssen in der Priorität
1 Antworten
In meiner website können die Benutzer AKTUALISIEREN Sie profile (manuelle) jedes mal, wenn er will, oder automatisch einmal am Tag. Diese Aufgabe wird verteilt mit Sellerie jetzt. Aber ich habe ein "problem" : Jeden Tag im automatischen
Erstellen Sellerie Aufgaben, die dann synchron laufen
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
Sellerie. Verringern Sie die Anzahl der Prozesse
4 Antworten
Gibt es eine Möglichkeit, um auf die Anzahl der Arbeitnehmer in Sellerie? Ich habe kleine server und Sellerie erzeugt immer 10 Prozesse am 1 core-Prozessor. Ich möchte, beschränkt diese Anzahl auf 3 Prozesse. InformationsquelleAutor der Frage Nikolay
Wie zu reinigen, die alle Aufgaben in einer bestimmten Warteschlange mit Sellerie in python?
3 Antworten
Wie zu entfernen alle geplanten und ausgeführten Aufgaben eines bestimmten que mit Sellerie in python? Die Fragen, die scheint ziemlich straigtforward, aber hinzufügen, ich bin nicht auf der Suche nach der Befehlszeile code Habe ich die folgende
Warum kann es nicht finden, mein Sellerie config-Datei?
4 Antworten
/home/myuser/mysite-env/lib/python2.6/site-packages/Sellerie/Frontlader/default.py:53: NotConfigured: Nein celeryconfig.py Modul gefunden!!! Bitte stellen Sie sicher, dass es vorhanden und verfügbar ist, um Python. NotConfigured) Ich sogar in meiner /etc/profile, und auch in meiner virtuellen Umgebung "aktivieren". Aber es ist nicht, es zu
Wie zu stoppen Sellerie Arbeitsprozess
3 Antworten
Habe ich ein Django-Projekt auf einer Ubuntu-EC2-Knoten, die ich verwende zum einrichten eines asynchronen Verwendung Celery. Ich bin nach diese zusammen mit den docs. Ich in der Lage gewesen, um eine grundlegende Aufgabe, die arbeiten auf der
Gewusst wie: Debuggen von Sellerie/Django Aufgaben vor Ort läuft in Eclipse
5 Antworten
Ich Debuggen müssen, Sellerie Aufgabe aus dem Eclipse-debugger. Ich bin mit Eclipse PyDev und Django. Erste, ich öffne mein Projekt in Eclipse und setzen einen breakpoint an den Anfang der Aufgabe-Funktion. Dann, ich bin ab den Sellerie
Daemonizing Sellerie
3 Antworten
Folgende Anleitung gefunden hierkopierte ich das Skript von github in /etc/init.d/celeryddann machte es ausführbar; $ ll /etc/init.d/celeryd -rwxr-xr-x 1 root root 9481 Feb 19 11:27 /etc/init.d/celeryd* Ich erstellte config-Datei /etc/default/celeryd gemäß den Anweisungen: # Names of nodes
Ab Kolben-server im hintergrund
3 Antworten
Ich habe eine flask Anwendung, die ich bin derzeit in der Inbetriebnahme in der folgenden Weise: #phantom.py __author__ = 'uruddarraju' from phantom.api.v1 import app app.run(host='0.0.0.0', port=8080, debug=True) und wenn ich dieses Skript ausführen, wird es erfolgreich ausgeführt
supervisor - how für die Ausführung mehrerer Befehle
1 Antworten
Ich bin Geschäftsführer einer Sellerie-Arbeiter, die Prozesse Warteschlange über Supervisor. Hier ist meine /etc/supervisor/Sellerie.conf: [program:celery] command = /var/worker/venv/bin/celery worker -A a_report_tasks -Q a_report_process --loglevel=INFO directory=/var/worker user=nobody numprocs=1 autostart=true autorestart=true startsecs=10 stopwaitsecs = 60 stdout_logfile=/var/log/celery/worker.log stderr_logfile=/var/log/celery/worker.log killasgroup=true priority=998
Beginnend Sellerie: AttributeError: 'module' Objekt hat kein Attribut 'Sellerie'
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
Sellerie Aufgabe, die läuft mehr Aufgaben
3 Antworten
Ich bin mit celerybeat zum Auftakt eine primäre Aufgabe, die Tritte, der eine Reihe von sekundären Aufgaben. Ich habe beide Aufgaben bereits geschrieben. Gibt es eine Möglichkeit, dies ganz einfach? Tut Sellerie ermöglichen die Ausführung von Aufgaben
AMQP vs Websphere MQ
2 Antworten
Wir arbeiten an einer Anwendung, die unterstützt AMQP für queuing. Einige unserer Kunden werden mithilfe von Websphere MQ. Ich Frage mich nur, auf einem hohen Niveau, wie austauschbar diese beiden Protokolle sind in Bezug auf Funktionalität. Ich
konfigurieren und ausführen, Sellerie Arbeiter auf dem remote-system
5 Antworten
arbeite ich auf Sellerie und mit rabbitmq-server und erstellt ein Projekt in django-Projekt in einem server(wo die message queue-Datenbank vorhanden ist) und es ist in Ordnung, habe ich mehrere Arbeitnehmer auch from kombu import Exchange, Queue CELERY_CONCURRENCY
Sellerie Aufgabe und anpassen, Dekorateur
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