Tag: celery

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

Wie führen Sie Sellerie als daemon in der Produktion?

5 Antworten

erstellte ich eine celeryd Datei in /etc/defaults/aus dem code hier: https://github.com/celery/celery/blob/3.0/extra/generic-init.d/celeryd Wenn ich jetzt ausführen will, celeryd als daemon und dies tun: sudo /etc/init.d/celerdy es sagt Befehl nicht gefunden. Wo mache ich falsch? InformationsquelleAutor der Frage Hick

Warum Sellerie Arbeit in der Python-shell, aber nicht in meiner Django-views? (import problem)

3 Antworten

Ich installiert Sellerie (die aktuelle stabile version.) Ich habe ein Verzeichnis namens /home/myuser/fable/jobs. In diesem Verzeichnis habe ich eine Datei namens tasks.py: from celery.decorators import task from celery.task import Task class Submitter(Task): def run(self, post, **kwargs): return

celery django import python unix

Wie kann ich einen Task planen, ausführen zu einer bestimmten Zeit mit Sellerie?

5 Antworten

Ist, habe ich mich in PeriodicTaskaber die Beispiele decken nur machen Sie wiederholen. Ich bin auf der Suche nach etwas mehr wie cron's Fähigkeit zu sagen "diese Aufgabe auszuführen, jeden Montag um 1 Uhr" InformationsquelleAutor der Frage

celery django python scheduled-tasks

Sellerie und Django einfaches Beispiel

1 Antworten

Nehmen wir ein einfaches Django Beispiel. app/models.py from django.db import models from django.contrib.auth.models import User class UserProfile(models.Model): user = models.OneToOneField(User) token = models.CharField(max_length=32) app/views.py from django.http import HttpResponse from django.views.decorators.csrf import csrf_exempt from forms import RegisterForm from

celery django python scalability

Der Name _uuid_generate_random kann nicht in heroku django importiert werden

3 Antworten

Arbeite ich an einem Projekt, das durchsucht Benutzer-Google Mail-Posteingang und liefert einen Bericht. Ich bereitgestellt haben es in heroku mit folgenden Spezifikationen: Sprache: Python 2.7 Rahmen: Django 1.8 Task scheduler: Sellerie (Rabbitmq-Bonze für die broker-url) Nun, wenn

celery django heroku python

Sellerie neu starten, ohne Aufgaben zu verzögern

7 Antworten

Verwenden wir Sellerie mit unserer Django webapp zum verwalten von offline-Aufgaben; einige dieser Aufgaben ausführen kann, bis zu 120 Sekunden. Wenn wir keine code-änderungen, müssen wir neu starten, Sellerie, um es neu laden der neuen Python-code. Unsere

celery celeryd django linux pid

Verwendung des @shared_task-Dekorators für klassenbasierte Aufgaben

2 Antworten

Als man auf der Dokumentation die @shared_task decorator erlaubt das anlegen von Aufgaben ohne konkrete app-Instanz. Die gegebenen Beispiele zeigen, wie zu schmücken eine Funktion-basierte Aufgabe. Wie dekorieren ein Klasse basierte Aufgaben? InformationsquelleAutor der Frage Juan Riaza

celery python

Django Sellerie: Admin-Oberfläche mit null Aufgaben / Arbeiter

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

celery django-celery

Warum Sellerie anstelle von RabbitMQ verwenden?

2 Antworten

Aus meinem Verständnis, Sellerie ist eine verteilte Warteschlange Aufgabe, was bedeutet, dass die einzige Sache, die Sie tun sollten, ist das versenden Aufgaben/Aufträge an andere Server und bekommt das Ergebnis zurück. RabbitMQ ist ein message queue, und

celery message-queue python rabbitmq

Wie man Flask-SQLAlchemy in einer Sellerie-Aufgabe verwendet

4 Antworten

Habe ich vor kurzem wechseln Sellerie 3.0. Vorher war ich mit Kolben-Sellerieum Sie zu integrieren Sellerie mit Kolben. Obwohl es viele Probleme wie verstecken einige mächtige Sellerie Funktionalitäten, sondern es erlaubte mir, verwenden Sie den vollständigen Kontext

celery flask flask-sqlalchemy python

So prüfen und stornieren Sie Sellerie-Aufgaben nach Aufgabenname

4 Antworten

Ich bin mit Sellerie (3.0.15) mit Redis als broker. Gibt es eine unkomplizierte Möglichkeit zur Abfrage der Zahl der Aufgaben, die mit einem bestimmten Namen vorhanden sind, in einer Sellerie-Warteschlange? Und, als Nachtrag, gibt es eine Möglichkeit

celery python redis

Warum wirft Sellerie KEINE Exception, wenn die zugrundeliegende Task eine Exception auslöst

4 Antworten

Sellerie scheint nicht in der Behandlung von Ausnahmen richtig. Wenn ich die Aufgabe: def errorTest(): raise Exception() und dann rufe ich r = errorTest.delay() In [8]: r.result In [9]: r.state Out[9]: 'PENDING' Und es wird hängen, wie

celery exception-handling python

Finde heraus, ob es eine Sellerieaufgabe gibt

6 Antworten

Ist es möglich, herauszufinden, ob eine Aufgabe mit einer bestimmten Aufgabe, die id existiert? Wenn ich versuche, um den status, ich bekomme immer anhängig. >>> AsyncResult('...').status 'PENDING' Ich möchte wissen, ob für einen gegebenen task-id ist eine

celery python status task

Verteilte Aufgabenwarteschlangen (Ex. Sellerie) vs Crontab-Skripte

1 Antworten

Ich habe Schwierigkeiten zu verstehen, den Zweck der 'distributed task-queues'. Zum Beispiel, python -Sellerie-Bibliothek. Ich weiß, dass im Sellerie, das python-framework, können Sie zeitgesteuerte windows für Funktionen, die ausgeführt werden. Aber das kann auch leicht getan werden

celery django python

Sellerie - führen Sie verschiedene Arbeiter auf einem Server aus

4 Antworten

Ich habe 2 Arten von Aufgaben : Type1 - Ein paar hohe Priorität hat kleine Aufgaben. Typ2 - Viele schwere Aufgaben mit geringerer Priorität. Anfangs hatte ich einfache Konfiguration mit Standard-routing, keine routing-keys verwendet wurden. Es war

celery django

"Einzigartige" Aufgaben mit Sellerie ausführen

5 Antworten

Ich Sellerie verwenden, um eine Aktualisierung der RSS-feeds in meinem news-aggregation-site. Ich verwende eine @Aufgabe für jeden feed, und die Dinge scheinen schön zu arbeiten. Gibt es ein detail, dass ich nicht sicher bin, gut zu meistern,

celery django python

Sellerie Worker Database Verbindungspooling

6 Antworten

Ich bin mit Sellerie standalone (nicht in Django). Ich Plane, eine worker task-Ausführung auf mehreren physikalischen Maschinen. Die Aufgabe ist die folgende Akzeptiert ein XML-Dokument. Verwandeln. Machen mehrere Datenbank liest und schreibt. Ich verwende PostgreSQL, aber dies

celery connection-pooling postgresql python

Rufen Sie ein Aufgabenergebnisobjekt ab, das in Sellery eine `task_id` enthält

1 Antworten

Lagere ich die task_id aus einer celery.result.AsyncResult in einer Datenbank und stellt Sie in Beziehung zu dem Element, das die Aufgabe betrifft. Dies ermöglicht es mir, führen Sie eine Abfrage zum abrufen aller task_ids von Aufgaben, die

celery python

Was entspricht Pythons Sellery-Projekt für Java?

7 Antworten

Ich versuche zu finden, ein äquivalent von Sellerie Projekt für die Java-Umgebung, ich habe mir bei Spring Batch, aber gibt es bessere alternativen für verteilte task-Warteschlangen. Dank. InformationsquelleAutor der Frage Zakiullah Khan Mohamed | 2012-03-06

batch-processing celery java python spring-batch

Warum brauchen wir Nachrichtenbroker wie RabbitMQ über eine Datenbank wie PostgreSQL?

2 Antworten

Ich bin neu in message-Broker wie RabbitMQdie wir nutzen können, um Aufgaben erstellen /Nachrichten-queues für eine scheduling-system, wie Sellerie. Nun, hier ist die Frage: Ich eine Tabelle erstellen kann, in PostgreSQLdie können angefügt werden, mit neuen Aufgaben

celery message-queue postgresql rabbitmq redis

Sellerie Unterschied zwischen Nebenläufigkeit, Arbeiter und Autoscaling

1 Antworten

In meinem /etc/defaults/celeryd config-Datei, die ich eingestellt habe: CELERYD_NODES="agent1 agent2 agent3 agent4 agent5 agent6 agent7 agent8" CELERYD_OPTS="--autoscale=10,3 --concurrency=5" Verstehe ich, daß der Dämon spawnt 8 Sellerie-Arbeiter, aber ich bin mir voll nicht sicher, was autoscale und concurrency

celery concurrency python

Liste der Aufgaben in einer Warteschlange in Sellerie abrufen

9 Antworten

Wie kann ich abrufen einer Liste von Aufgaben in eine Warteschlange, die noch verarbeitet werden? InformationsquelleAutor der Frage bradley.ayers | 2011-04-04

celery python

Sellerie Arbeiter Fehler: ImportError kein Modul namens Sellerie

2 Antworten

Ich bin immer ein import error, wenn ich versuche zu starten, meine Sellerie-Arbeiter. Ich bin nicht sicher, was das Problem ist. Jegliche Hilfe würde sehr geschätzt werden. Mein Projekt: email/__init__.py /celery.py Ich versuche, führen Sie die Anwendung

celery celery-task flask python

Wie überprüft man den Aufgabenstatus in Sellerie?

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() ==

celery django-celery python web-services

Sellerie parallel verteilte Aufgabe mit Multiprocessing

4 Antworten

Habe ich eine CPU-intensive Sellerie Aufgabe. Ich würde gerne alle nutzen die Prozessorleistung (Kerne) auf viele EC2-Instanzen in diesem job zu erledigen schneller (Sellerie parallel distributed Aufgabe mit multiprocessing - ich denke). Den Bedingungen, threadingmultiprocessingdistributed computingverteilte parallele

celery django multiprocessing multithreading python

So senden Sie periodische Aufgaben an bestimmte Warteschlangen in Sellery

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': {

celery django-celery python

Führe eine Scrapy-Spinne in einer Sellerie-Aufgabe aus

4 Antworten

Ist dies nicht mehr funktioniertscrapy API geändert hat. Nun die Dokumentation, feature-ein Weg zu"Führen Sie Scrapy aus einem Skript", aber ich bekomme die ReactorNotRestartable Fehler. Meine Aufgabe: from celery import Task from twisted.internet import reactor from scrapy.crawler

celery scrapy twisted

Wie starte ich einen Sellerie-Arbeiter aus einem Skript / Modul main?

3 Antworten

Ich habe definieren einen Celery app in ein Modul, und nun will ich beginnen die Arbeiter aus dem gleichen Modul in seiner __main__d.h. durch ausführen des Moduls mit python -m statt celery von der Befehlszeile aus. Ich

celery celeryd python

Sich wiederholende Aufgaben mit Django-Sellerie - Django / Sellerie

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

celery django django-celery python scheduled-tasks

Wie kann ich eine periodische Sellerie-Aufgabe manuell von der Shell ausführen?

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

celery celery-task django django-celery python

Wie starte ich Sellerie Arbeiter anmutig?

6 Antworten

Während der Ausstellung eines neuen bauen, um update-code bei Arbeitnehmern wie kann ich neu starten, Sellerie Arbeitnehmer ordnungsgemäß? Edit: Was ich vorhabe zu tun ist, so etwas wie dieses. Worker ausgeführt wird, wahrscheinlich das hochladen einer 100

celery celeryd django

In Sellerie 3.1, machen Django periodische Aufgabe

2 Antworten

Dinge zu sehr verändert, in Django, so kann ich nicht verwenden 3.1. Ich brauche etwas Hilfe. Habe ich gelesen,eine Aufgabe, die in djangound Lesen Periodische Aufgaben Dokument. Aber ich weiß nicht, wie periodische Aufgaben in django. Ich

celery celerybeat django

Sellerie: WorkerLostError: Arbeiter vorzeitig verlassen: Signal 9 (SIGKILL)

1 Antworten

Ich verwende Sellerie mit RabbitMQ in meinem Django-app (Elastic Beanstalk) zum verwalten von hintergrund-tasks und ich daemonisierte es mit Vorgesetzten. Das problem jetzt ist, dass der Zeitraum Aufgabe, die ich definiert, ist nicht (nach einer Woche, in

amazon-ec2 celery django elastic-beanstalk supervisord

Sellerie mit RabbitMQ: AttributeError: 'DisabledBackend' Objekt hat kein Attribut '_get_task_meta_for'

4 Antworten

Ich bin mit den Erste Schritte mit Sellerie-Tutorial. Definieren wir die folgende Aufgabe: from celery import Celery app = Celery('tasks', broker='amqp://guest@localhost//') @app.task def add(x, y): return x + y Dann rufen Sie: >>> from tasks import add

celery python

Sellerie: Liste alle Aufgaben, geplant, aktiv * und * fertig

2 Antworten

Update für bounty Ich würde gerne eine Lösung, die nicht mit einem Monitor-thread, wenn möglich. Ich weiß, ich kann anzeigen geplanten und aktiv Aufgaben mit der Inspect Klasse meiner apps Control. i = myapp.control.inspect() currently_running = i.active()

celery celery-task

Löschen aller ausstehenden Aufgaben in Sellerie / Rabbitmq

7 Antworten

Wie lösche ich alle anstehenden Aufgaben, ohne zu wissen, die task_id für jede Aufgabe? InformationsquelleAutor der Frage nabizan | 2011-08-22

celery celery-task rabbitmq task

Umgang mit doppelten Primärschlüsseln beim Einfügen in SQLAlchemy (deklarativer Stil)

4 Antworten

Meine Anwendung eine session-scoped und dem deklarativen Stil von SQLALchemy. Es ist eine web-app und eine Menge von der DB Einfügungen ausgeführt werden, indem Celery ein Aufgabenplaner. In der Regel, wenn Sie entscheiden, um ein Objekt einfügen,

celery mysql python sqlalchemy

Django, ImportError: kann Name Sellerie nicht importieren, möglicher Kreisimport?

9 Antworten

Ging ich durch dieses Beispiel hier: http://docs.celeryproject.org/en/latest/django/first-steps-with-django.html Alle meine Aufgaben werden in Dateien namens tasks.py. Nach der Aktualisierung Sellerie und hinzufügen die Datei aus dem Beispiel django wirft die folgende Fehlermeldung, egal was ich versuche: ImportError: cannot

celery django importerror python

Wie testen Sie eine Sellerie-Aufgabe?

8 Antworten

Sellerie Dokumentation erwähnt testen Sellerie in Django aber nicht erklären, wie man zum testen eine Sellerie Aufgabe, wenn Sie nicht mit Django. Wie tun Sie dies? InformationsquelleAutor der Frage DavidM | 2012-08-22

celery python unit-testing

Wiederholen Sie Sellerie-Aufgaben mit exponentiellem Rückzug

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,

celery django-celery python

Wie halten Sie mehrere unabhängige Sellerie-Schlangen?

2 Antworten

Ich versuche, mehrere Sellerie-Warteschlangen mit unterschiedlichen Aufgaben und Arbeitnehmern in der gleichen redis-Datenbank. Wirklich nur ein Komfort Problem nur zu wollen, einen redis-server statt auf zwei auf meiner Maschine. Folgte ich dem Sellerie tutorial docs wörtlich, wie

celery python

Sellerie mit Amazon SQS

5 Antworten

Möchte ich Amazon SQS als Makler unterstützt von Sellerie. Es gibt den SQS-transport-Umsetzung für Kombudie Sellerie abhängt. Aber es ist nicht genug Dokumentation, um es, so kann ich nicht finden, wie zu konfigurieren SQS auf Sellerie. Gibt

amazon-sqs amazon-web-services celery kombu

AttributeError: 'Flask' Objekt hat kein Attribut 'user_options'

3 Antworten

So, ich bin versucht, setup-dieses basic-Beispiel aus den folgenden doc: http://flask.pocoo.org/docs/0.10/patterns/celery/ Aber bisher habe ich immer die folgende Fehlermeldung: AttributeError: 'Kolben' - Objekt hat kein Attribut 'user_options' Ich bin mit Sellerie 3.1.15. Ich habe einige online-Suche, aber

celery flask python

Django Sellerie Logging Best Practice

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

celery django django-celery logging python

Sellerie auf Prozesse anwenden und gleichzeitig Aufgaben erledigen

4 Antworten

Würde ich gerne Sellerie als eine Warteschlange für meine Aufgaben, so dass meine web-app könnte enqueue-eine Aufgabe, in der eine Antwort zurück und der task verarbeitet werden, inzwischen /someday /... ich Baue eine Art API, also ich

celery gevent monkeypatching multiprocessing python

Running Scrapy Spinnen in einer Sellerie-Aufgabe

2 Antworten

Habe ich eine Django-site, wo ein kratzen geschieht, wenn ein Benutzer es wünscht, und mein code startet einen Scrapy spider standalone Skript in einem neuen Prozess. Natürlich funktioniert das nicht mit einem Anstieg der Nutzer. Etwas wie

celery django python scrapy

Importfehler in Sellerie

3 Antworten

dies ist der code, welchen ich verwende: from __future__ import absolute_import from celery import Celery celery1 = Celery('celery',broker='amqp://',backend='amqp://',include=['tasks']) celery1.conf.update( CELERY_TASK_RESULT_EXPIRES=3600, ) if __name__ == '__main__': celery1.start() wenn ich führen Sie den obigen code, es gibt mir die

celery celery-task pycharm python

Wie kann ich unbestätigte AMQP-Nachrichten von anderen als den eigenen Kanälen wiederherstellen?

3 Antworten

Scheint es, desto länger behalte ich meine rabbitmq-server laufen, desto mehr Schwierigkeiten habe ich mit unbestätigten Nachrichten. Ich würde gerne requeue. In der Tat scheint es eine amqp-Befehl, um dies zu tun, aber es gilt nur für

amqp celery celeryd pika rabbitmq

Was ist die maximale Wertgröße, die Sie in redis speichern können?

3 Antworten

Weiß jemand was der maximale Wert, die Größe, die Sie speichern können in redis? Ich möchte zu verwenden redis als eine message queue mit Sellerie, speichern einige kleine Dokumente, die verarbeitet werden müssen von einem Arbeiter auf

celery redis

Django Sellerie - Keine Verbindung zu amqp: //[email protected]: 5672 //

4 Antworten

Ich versuche zum einrichten Django-Celery. Ich werde durch die Tutorials http://docs.celeryproject.org/en/latest/django/first-steps-with-django.html wenn ich $ python manage.py Sellerie Arbeiter --loglevel=info Bekomme ich [Tasks] /Users/msmith/Documents/dj/venv/lib/python2.7/site-packages/djcelery/loaders.py:133: UserWarning: Using settings.DEBUG leads to a memory leak, never use this setting in production

celery django python