Tag: celery

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

Baue ich einen Kolben app mit Sellerie, mit rabbitmq als Sellerie-backend. meine conf für Sellerie ist CELERY_BROKER_URL='amqp://localhost:5672', CELERY_RESULT_BACKEND='amqp://', CELERY_QUEUE_HA_POLICY='all', CELERY_TASK_RESULT_EXPIRES=None Dann, deklarieren eine Warteschlange produziert eine ganze Reihe von Fehler connection = pika.BlockingConnection(pika.ConnectionParameters('localhost')) channel = connection.channel() channel.queue_declare(queue=new_task_id)

In Sellerie, gibt es eine einfache Möglichkeit zum erstellen einer (Reihe von) Aufgabe(N), dass ich verwenden könnte, um automatisch neu starten, ein Arbeiter? Ziel ist, meinen Bereitstellung automatisch neu starten, werden alle untergeordneten Sellerie Arbeiter jedes mal,

Bekomme ich folgende Fehler beim ausführen dieses Befehls /etc/init.d/celerybeat start: chown: changing ownership of `/srv/project/logs': Operation not permitted chown: changing ownership of `/var/run': Operation not permitted chown: changing ownership of `/var/run': Operation not permitted chmod: changing permissions

Ich eine Gruppe erstellen möchten, aus einer Liste zurückgegeben, die von einem Sellerie Aufgabe, so dass für jedes Element im task-Ergebnis-set, ein task wird zu der Gruppe Hinzugefügt. Hier ein einfaches code-Beispiel, um zu erklären, die use-case.

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

# 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

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

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

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

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

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

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":

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

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):

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)

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

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

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,

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

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',

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

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

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:123456@localhost/test',

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