Pytania oznaczone «celery»

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 mogę usunąć wszystkie oczekujące zadania, nie znając ich task_iddla każdego

Jak mogę pobrać listę zadań w kolejce, które nie zostały jeszcze

Dokumentacja Celery wspomina o testowaniu Celery w Django, ale nie wyjaśnia, jak przetestować zadanie Celery, jeśli nie używasz Django. Jak Ty to

Zamknięte . To pytanie musi być bardziej skoncentrowane . Obecnie nie przyjmuje odpowiedzi. Chcesz poprawić to pytanie? Zaktualizuj pytanie, aby skupiało się tylko na jednym problemie, edytując ten post . Zamknięte 3 lata temu . Popraw to pytanie...

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

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

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

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

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

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 =