@shared_task 작성과 호출

Celery 작업은 위에 데코레이터가 붙은 일반 Python 함수입니다. 데코레이터는 Celery에 해당 함수를 나중에 대기열에 넣고 실행하는 방법을 알려 줍니다.

@app.task 대신 @shared_task를 사용하면 작업이 특정 Celery 앱에 종속되지 않습니다. Django 앱 내부에서 표준적으로 사용하는 방식입니다.

앱 내부의 tasks.py에 작업을 작성하세요. 일반 함수를 데코레이터로 꾸미면 Celery가 자동 검색을 통해 이를 찾아냅니다.

작업을 백그라운드에서 실행하려면 함수를 직접 호출하는 대신 delay()를 호출하세요. 작업을 대기열에 넣고 즉시 반환합니다.

add(2, 3)을 호출하면 웹 프로세스에서 지금 바로 실행됩니다. add.delay(2, 3)을 호출하면 대기열로 전송됩니다. 같은 함수지만 실행 시점은 크게 다릅니다.

인수는 JSON으로 직렬화되어 브로커로 전송되므로, 전체 모델 객체가 아니라 ID나 문자열처럼 간단한 값을 전달하세요.

delay()는 AsyncResult를 반환합니다. 해당 ID를 저장해 두었다가 나중에 상태를 확인하거나 결과 백엔드에서 반환 값을 가져올 수 있습니다.

카운트다운이나 특정 대기열이 필요하신가요? 추가 옵션을 제공하는 delay의 확장 버전인 apply_async()를 사용하십시오.

작업을 바인딩하고 self.retry()를 호출하면 오류가 발생한 후 작업을 다시 실행할 수 있습니다. 다음에는 성공할 수도 있는 불안정한 네트워크 호출에 특히 유용합니다.

작업은 재시도될 수 있으므로 멱등성을 갖도록 설계하십시오. 두 번 실행해도 안전하여 요금이 두 번 청구되거나 메시지가 두 번 전송되지 않아야 합니다. 🔁

delay를 호출할 때 작업자 터미널을 확인하십시오. 작업이 수신된 내용과 그 결과를 볼 수 있으며, 이는 문제를 디버깅하는 가장 빠른 방법입니다. 👀

함수에 @shared_task를 적용하고 .delay()로 호출해 대기열에 넣으십시오. 간단한 ID를 전달하고 안전하게 재시도할 수 있도록 작업을 설계하십시오. 🎯