Pytania otagowane jako celery

Celery to rozproszona struktura kolejki zadań dla języka Python, używana do wykonywania asynchronicznego i równoległego.

2
Dlaczego potrzebujemy brokerów wiadomości takich jak RabbitMQ w bazie danych takiej jak PostgreSQL?
Jestem nowym brokerem wiadomości, takim jak RabbitMQ, którego możemy używać do tworzenia zadań / kolejek wiadomości dla systemu planowania, takiego jak Celery . Oto pytanie: Mogę utworzyć tabelę w PostgreSQL, która może być dołączona do nowych zadań i wykorzystana przez program konsumencki, taki jak Celery. Dlaczego, u licha, miałbym chcieć …
30
Seler Otrzymano niezarejestrowane zadanie typu (przykład uruchomienia)
Próbuję uruchomić przykład z dokumentacji Seleru. Biegnę: celeryd --loglevel=INFO /usr/local/lib/python2.7/dist-packages/celery/loaders/default.py:64: NotConfigured: No 'celeryconfig' module found! Please make sure it exists and is available to Python. "is available to Python." % (configname, ))) [2012-03-19 04:26:34,899: WARNING/MainProcess] -------------- celery@ubuntu v2.5.1 ---- **** ----- --- * *** * -- [Configuration] -- * - …
98 python  celery 
5
Anulować już wykonywane zadanie za pomocą Selera?
Czytałem dokument i szukałem, ale nie mogę znaleźć prostej odpowiedzi: Czy możesz anulować już wykonywane zadanie? (ponieważ zadanie zostało rozpoczęte, zajmuje trochę czasu, aw połowie musi zostać anulowane) Znalazłem to z dokumentu w Celery FAQ >>> result = add.apply_async(args=[2, 2], countdown=120) >>> result.revoke() Ale nie jestem pewien, czy spowoduje to …
13
Jak sprawdzić status zadania w Selerze?
Jak sprawdzić, czy zadanie działa w selerze (konkretnie używam selera-django)? Przeczytałem dokumentację i wyszukałem w Google, ale nie widzę połączenia takiego jak: my_example_task.state() == RUNNING Moim przypadkiem jest to, że mam zewnętrzną usługę (java) do transkodowania. Kiedy wysyłam dokument do transkodowania, chcę sprawdzić, czy zadanie, które uruchamia tę usługę, jest …
1
Rozproszone kolejki zadań (np. Celery) a skrypty crontab
Mam problem ze zrozumieniem celu „kolejek zadań rozproszonych”. Na przykład biblioteka selera w języku Python . Wiem, że w selerze, frameworku Pythona, możesz ustawić okna czasowe dla funkcji do wykonania. Jednak można to również łatwo zrobić w linuksowej tabeli crontab skierowanej do skryptu Pythona. O ile wiem, i pokazałem to …
92 python  django  celery 
6
Testy jednostkowe z django-seler?
Próbuję wymyślić metodologię testowania dla naszego projektu django-seler . Przeczytałem notatki w dokumentacji , ale nie dały mi one dobrego pojęcia, co właściwie mam robić. Nie martwię się testowaniem zadań w rzeczywistych demonach, tylko funkcjonalność mojego kodu. Głównie się zastanawiam: Jak możemy ominąć task.delay()podczas testu (próbowałem ustawić, CELERY_ALWAYS_EAGER = Trueale …
1
Django uruchamia zadania (prawdopodobnie) w dalekiej przyszłości
Załóżmy, że mam model Event. Chcę wysłać powiadomienie (e-mail, push, cokolwiek) do wszystkich zaproszonych użytkowników po zakończeniu wydarzenia. Coś w stylu: class Event(models.Model): start = models.DateTimeField(...) end = models.DateTimeField(...) invited = models.ManyToManyField(model=User) def onEventElapsed(self): for user in self.invited: my_notification_backend.sendMessage(target=user, message="Event has elapsed") Teraz oczywiście najważniejszą częścią jest wywoływanie onEventElapsedza każdym …
Korzystając z naszej strony potwierdzasz, że przeczytałeś(-aś) i rozumiesz nasze zasady używania plików cookie i zasady ochrony prywatności.
Licensed under cc by-sa 3.0 with attribution required.