Używam Celery do kolejkowania zadań z utworzonej przeze mnie aplikacji CGI . Sposób, w jaki to skonfigurowałem, Celery sprawia, że ​​każde zadanie jest uruchamiane jedno lub dwa naraz, ustawiając CELERYD_CONCURRENCY = 1 lub = 2 (aby nie...

Mamy konfigurację Celery (+Celerybeat) z backendem RabbitMQ wykonującym zaplanowane i niezaplanowane zadania. Zauważyłem, że czasami przegapiam/porzucam wystąpienie zaplanowanego zadania. Wszystko nadal działa poprawnie, a zadanie nadal działa w...

Używam Celery w projekcie django, moim brokerem jest RabbitMQ i chcę pobrać długość kolejek. Przejrzałem kod Celery, ale nie znalazłem odpowiedniego narzędzia. Znalazłem ten problem na stackoverflow ( Sprawdź rozmiar kolejki RabbitMQ od klienta ),...

To może być kiepskie pytanie, ale naprawdę jestem zdezorientowany z tymi dwoma. Wiem, że signals są używane do wykonania jakiegoś zadania, gdy coś się wydarzy. Ale co z selerem? W dokumentacji jest napisane: Celery to asynchroniczna...

Obecnie testuję Django Celery Results używając Django DB jako backendu. Śledziłem dokumentację tutaj: http://docs.celeryproject.org/en/latest/django/first-steps-with-django.html#django-celery-results-using-the-django-orm-cache-as-a-result-backend...

Jakie jest właściwe podejście podczas pisania zadań selerowych, które komunikują się z usługą, która ma ograniczenia szybkości i czasami nie odpowiada (nie odpowiada) przez długi czas? Czy muszę ponawiać zadanie? A co jeśli serwisowi brakuje zbyt...

Próbuję nauczyć się korzystać z selera, aby później zintegrować go z moją aplikacją do kolby. Próbuję tylko wykonać podstawowy przykład znaleziony w Celery Docs Utworzyłem plik o nazwie task.py i w tym folderze, w którym znajduje się plik task.py,...

Próbuję uruchomić zadanie selera w widoku Django przy użyciu my_task.delay() . Jednak zadanie nigdy nie jest wykonywane, kod jest blokowany w tej linii, a widok nigdy się nie renderuje. Używam AWS SQS jako brokera z użytkownikiem IAM z pełnym...