[개발] celery-python 내장 함수 설명

Celery는 비동기 및 분산 작업 처리를 위한 Python 라이브러리입니다. 이 라이브러리에는 많은 함수와 메서드가 있지만, 주요 함수와 메서드 중 일부를 다음과 같이 나열해보겠습니다:

1. Task Decorators:
@shared_task: 다양한 Celery 인스턴스에서 사용할 수 있는 재사용 가능한 작업을 정의합니다.
@task: 현재 Celery 인스턴스에만 국한된 작업을 정의합니다.

2. Task Methods:
apply_async(args, kwargs, ...): 작업을 비동기적으로 호출합니다.
delay(*args, **kwargs): apply_async의 단축 메서드로, 작업을 비동기적으로 호출합니다.

 

3. Celery Application Methods:
Celery(broker=...): 새로운 Celery 애플리케이션 인스턴스를 생성합니다.
conf.update(...): Celery 애플리케이션의 설정을 업데이트합니다.

 

4.Result Methods (작업 결과를 다루기 위한 메서드들):
result.ready(): 작업이 완료되었는지 확인합니다.
result.get(timeout=...): 작업의 결과를 가져옵니다. timeout은 선택적입니다.
result.forget(): 작업의 결과를 잊습니다.
result.revoke(): 아직 실행되지 않은 작업을 취소합니다.

 

5. Group, Chain, Chord:
group(): 여러 작업을 그룹화하여 병렬로 실행합니다.
chain(): 여러 작업을 연결하여 순차적으로 실행합니다.
chord(): group과 유사하지만, 모든 작업이 완료된 후 콜백 작업을 실행합니다.

 

6. Utility Functions:
signature(): 작업의 서명을 생성하거나 복사합니다. 이는 작업을 호출할 때 사용되는 인자 및 옵션을 포함합니다.
uuid(): 새로운 작업 ID를 생성합니다.
이외에도 Celery는 많은 고급 기능과 메서드를 제공합니다. 위에서 언급한 것은 그저 일부에 불과하며, Celery의 공식 문서에서 더 많은 정보와 세부 사항을 찾을 수 있습니다.