Django Academy · Lekcja

Pisanie i wywoływanie @shared_task

Asynchroniczne uruchamianie funkcji za pomocą delay()

Lekcja 3 z 413 kroki

Pisanie i wywoływanie @shared_task to bezpłatna lekcja Django Academy na CoddyKit. To lekcja 3 z 4. Możesz przeczytać całą lekcję poniżej za darmo — a potem ćwiczyć ją interaktywnie w przeglądarce z wbudowanym edytorem kodu i tutorem AI dostępnym 24/7. To część ścieżki edukacyjnej Django Academy, a Twój postęp synchronizuje się między webem a aplikacją CoddyKit. Kurs Django Academy zawiera 4 lekcji w sumie.

Zadania to po prostu funkcje

Zadanie Celery to zwykła funkcja Pythona z dekoratorem umieszczonym nad nią. Dekorator informuje Celery, jak dodać funkcję do kolejki i uruchomić ją później.

Dlaczego shared_task

Użyj @shared_task zamiast @app.task, aby zadania nie zależały od konkretnej aplikacji Celery. To standardowy wybór w aplikacjach Django.

Napisz pierwsze zadanie

Umieść zadania w pliku tasks.py wewnątrz aplikacji. Ozdób zwykłą funkcję dekoratorem, a Celery znajdzie ją dzięki automatycznemu wykrywaniu.

from celery import shared_task

@shared_task
def add(x, y):
    return x + y

Wywołaj je za pomocą delay

Aby uruchomić zadanie w tle, wywołaj .delay() zamiast bezpośrednio wywoływać funkcję. Zadanie trafi do kolejki, a wywołanie natychmiast zwróci wynik.

add.delay(2, 3)  # queued, runs on a worker

delay a wywołanie bezpośrednie

Wywołanie add(2, 3) wykonuje się od razu w procesie internetowym. Wywołanie add.delay(2, 3) wysyła zadanie do kolejki. Ta sama funkcja, ale zupełnie inny czas wykonania.

Przekazuj proste argumenty

Argumenty są serializowane do JSON i wysyłane do brokera, dlatego przekazuj proste wartości, takie jak identyfikatory i napisy, a nie całe obiekty modeli.

send_email.delay(user.id)   # good
send_email.delay(user)      # avoid: not serializable

Uchwyt AsyncResult

delay() zwraca obiekt AsyncResult. Można zapisać jego identyfikator, a później sprawdzić status lub pobrać zwracaną wartość z backendu wyników.

result = add.delay(2, 3)
print(result.id)

Większa kontrola dzięki apply_async

Potrzebują Państwo odliczania czasu lub konkretnej kolejki? Należy użyć apply_async() — pełniejszej wersji delay z dodatkowymi opcjami.

add.apply_async((2, 3), countdown=10)  # run after 10s

Ponawianie po błędzie

Należy powiązać zadanie i wywołać self.retry(), aby uruchomić je ponownie po błędzie. To doskonałe rozwiązanie w przypadku niestabilnych połączeń sieciowych, które mogą zadziałać przy kolejnej próbie.

@shared_task(bind=True, max_retries=3)
def fetch(self):
    try:
        call_api()
    except Exception as e:
        raise self.retry(exc=e)

Wygrywają zadania idempotentne

Ponieważ zadania mogą być ponawiane, należy zadbać o ich idempotentność: dwukrotne uruchomienie powinno być bezpieczne i nie może spowodować podwójnego obciążenia ani wysłania wiadomości. 🔁

Obserwowanie dziennika workera

Po wywołaniu delay należy obserwować terminal workera. Zobaczą Państwo odebrane zadanie i jego wynik, co jest najszybszym sposobem debugowania. 👀

Szybkie sprawdzenie

Jak uruchomić zadanie Celery w tle?

Odpowiedz w interaktywnej lekcji

Podsumowanie: pisanie zadań

Należy udekorować funkcję za pomocą @shared_task, wywołać ją przez .delay(), aby umieścić ją w kolejce, przekazywać proste identyfikatory i projektować zadania tak, aby można je było bezpiecznie ponawiać. 🎯

Bezpłatny start

Ucz się Python dzięki korepetycjom AI — za darmo

Pisz i uruchamiaj kod w przeglądarce, otrzymuj natychmiastową pomoc od korepetytora AI dostępnego 24/7 i kontynuuj naukę w sieci lub w aplikacji.

Kursy: 30
Lekcje: 120

Zacznij naukę bezpłatnie Wyświetl pełny kurs

Często zadawane pytania

Czy lekcja „Pisanie i wywoływanie @shared_task” jest bezpłatna?

Tak — pełny tekst „Pisanie i wywoływanie @shared_task” jest dostępny za darmo tutaj w sieci. Aby ćwiczyć ją interaktywnie (wbudowany edytor kodu i tutor AI dostępny 24/7) i odblokować resztę kursu Django Academy, przejdź na CoddyKit PRO. Kurs Django Academy zawiera 4 lekcji w sumie.

Co nauczysz się w „Pisanie i wywoływanie @shared_task”?

Asynchroniczne uruchamianie funkcji za pomocą delay() Ćwiczysz Django Academy z praktycznym kodem, który uruchamiasz bezpośrednio w przeglądarce, a tutor AI dostępny 24/7 odpowiada na Twoje pytania podczas pracy nad lekcją.

Czy potrzebuję doświadczenia, aby zacząć Django Academy?

Nie wymagamy żadnego doświadczenia. Django Academy w CoddyKit jest strukturyzowany dla początkujących i zaawansowanych użytkowników, więc możesz zacząć tutaj lub od początku i uczyć się w swoim tempie. To lekcja 3 z 4.

Ile czasu zajmuje lekcja „Pisanie i wywoływanie @shared_task”?

Większość lekcji CoddyKit trwa około 5–10 minut. Każda lekcja to mały, interaktywny krok, dzięki czemu robisz systematyczne postępy i zawsze wracasz dokładnie do tego samego miejsca — na webie i w aplikacji.

Czy mogę pisać i uruchamiać kod w tej lekcji Django Academy?

Tak. Każda lekcja Django Academy zawiera wbudowany edytor kodu, więc piszesz i uruchamiasz prawdziwy kod bezpośrednio w przeglądarce i od razu otrzymujesz sprzężenie zwrotne od AI — bez konfiguracji na komputerze.

Wszystkie lekcje w tym kursie

← Powrót do Django Academy