celery

6Ciepło

1Odpowiedz

Trwa pobieranie GroupResult z taskset_id w Seler?

Jestem od zestawu zadań selera stosując grupę seler, jak opisano w official documentation ja również przechowywanie grupę (taskset) identyfikator w dB, w celu POLL seler stanu taskset. job = group([

python celery celery-task 2012-12-03

---

8Ciepło

1Odpowiedz

Seler AsyncResult uzyskać nazwę hosta

Mam skonfigurować seler, który wykorzystuje dwa różne serwery do przetwarzania zadań. Próbuję znaleźć najlepszy sposób dopasowania serwera, na którym zostało wykonane zadanie. Przeglądałem dokumenty i

celery django-celery 2012-12-04

---

7Ciepło

2Odpowiedz

Przeczytaj konfigurację selera z pliku właściwości Pythona

Mam aplikację, która musi zainicjować Seler i inne rzeczy (np. Bazę danych). Chciałbym mieć plik .ini, który zawierałby konfigurację aplikacji. To powinno zostać przekazane do aplikacji w czasie wykon

python celery 2012-12-06

---

5Ciepło

1Odpowiedz

podklasowanie selera Zadanie

Piszę dużo zadań, które są bardzo podobne, i chcą wiedzieć, jak poprawić podklasę Task, aby zmniejszyć bojler. Ponieważ zadanie jest tworzone tylko raz, nie mogę umieścić rzeczy w __init__, tak jak po

python django celery django-celery 2012-12-13

---

12Ciepło

2Odpowiedz

SQS z konfiguracją naciowego

Próbowałem konfiguracji Amazon SQS dla Seler i mam poniżej konfigurację: BROKER_BACKEND = "SQS" BROKER_TRANSPORT_OPTIONS = { 'region': 'us-east-1', } AWS_ACCESS_KEY_ID = # access id AWS_SECRE

python django celery 2012-12-13

---

5Ciepło

3Odpowiedz

Ograniczanie liczby rozproszonych

Mam wiele serwerów/pracowników przechodzących przez kolejkę zadań wykonujących żądania interfejsu API. (Django z Memcached i Seler dla kolejki) Żądania interfejsu API są ograniczone do 10 żądań na sek

queue message-queue celery throttling rate-limiting 2012-12-17

---

5Ciepło

1Odpowiedz

selera - grupę w obrębie łańcucha

że chcą użyć grupy (lub fragmentów) wewnątrz sieci, takich jak: chain(getRange.s(3), GROUP() , xsum.s()) przypadku GROUP() jest grupą double() zadań, to znaczy group(double(0),double(1),double(2)).

python celery celery-task 2012-12-18

---

5Ciepło

1Odpowiedz

Seler próbuje zamknąć pracownika przez podniesienie SystemExit w sygnale task_postrun, ale zawsze się zawiesza, a proces główny nigdy nie kończy się.

Próbuję wyłączyć główny proces selera przez rodis SystemExit() w sygnale task_postrun. Sygnał zostaje wystrzelony w porządku, a wyjątek zostaje podniesiony, ale robotnik nigdy nie kończy się całkowici

python signals celery systemexit 2012-11-06

---

16Ciepło

1Odpowiedz

Jak powiązać zadanie z selerem, które zwraca listę do grupy?

Chcę utworzyć grupę z listy zwróconej przez zadanie Celery, aby dla każdego elementu w zestawie wyników zadania jedno zadanie zostało dodane do grupy. Oto prosty przykład kodu wyjaśniający przypadek u

python celery 2012-11-07

---

10Ciepło

1Odpowiedz

django-celery: Dynamiczne tworzenie i rejestrowanie zadania

Chciałbym dodać opóźnienie arbitralnych zadań przy użyciu django-celery. Obecnie Stworzyłem klasę podobny do tego poniżej (to tylko przykład, rzeczywiste klasy mają więcej niż to): from celery.task im

django celery 2013-01-02

---