celery-task

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([

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

5Ciepło

1Odpowiedz

otrzymał niezarejestrowane zadanie typu:

Próbuję uruchomić zadania znajdujące się w pamięci. zarejestrowany, zadania na pracownika [2012-09-13 11:10:18,928: WARNING/PoolWorker-1] [u'B.run', u'M1.run', u'M11.run', u'M22.run', u'M23.run', u'M2

9Ciepło

1Odpowiedz

Gdzie ustawiasz task_id zadania selerowego?

Mam problemy ze znalezieniem jakiegokolwiek przykład ustawienie task_id z własną task_id coś wzdłuż tych linii ... def testview1(request): for i in xrange(0,1000): result = add.delay(i, 4,t

22Ciepło

2Odpowiedz

Jak sprawić, aby zadanie selera nie powiodło się w ramach zadania?

Pod pewnymi warunkami chcę sprawić, aby zadanie selerowe nie powiodło się w ramach tego zadania. Próbowałem następujące: from celery.task import task from celery import states @task() def run_simu

15Ciepło

1Odpowiedz

W selera, jaki byłby cel, aby wielu pracowników przetwarzało tę samą kolejkę?

W dokumentacji celeryd-Multi, znajdziemy tu np # Advanced example starting 10 workers in the background: # * Three of the workers processes the images and video queue # * Two of the workers processe

6Ciepło

2Odpowiedz

Przechowywanie identyfikatora zadania dla każdego zadania selera w bazie danych

Używam selera z MySQL. Chcę zapisać identyfikator zadania jako zwykłą liczbę całkowitą w bazie danych lub w zmiennej selekcji task. Jak mogę to zrobić?