[python] Celery의 지연된 작업(delayed task)에 대한 사용 사례는 어떤 것이 있는가?

21 Nov 2023

python

이메일 전송: 사용자가 이메일을 등록하면, 이메일 전송 작업을 지연시켜 백그라운드에서 실행할 수 있습니다. 이렇게 하면 사용자는 즉시 이메일을 받는 것이 아니라, 작업이 완료된 후에 이메일을 받을 수 있습니다.

from celery import Celery

app = Celery('myapp', broker='redis://localhost:6379/0')

@app.task
def send_email(to, subject, body):
    # 이메일 전송 코드 작성
    pass

# 지연된 작업 예약
send_email.apply_async(args=['user@example.com', 'Hello', 'This is the body'])

배치 처리: 대량의 데이터를 처리해야 하는 경우, 작업을 지연시켜서 병렬로 실행할 수 있습니다. 예를 들어, 온라인 상점에서 주문을 처리할 때, 데이터베이스에 저장된 주문을 비동기적으로 처리할 수 있습니다.

from celery import Celery

app = Celery('myapp', broker='redis://localhost:6379/0')

@app.task
def process_order(order_id):
    # 주문 처리 코드 작성
    pass

# 지연된 작업 예약
process_order.apply_async(args=[1234])

크롤링: 큰 규모의 웹 크롤링 작업을 수행할 때, 작업을 지연시켜 백그라운드에서 비동기적으로 실행할 수 있습니다. 이렇게 하면 사용자는 작업이 완료될 때까지 기다릴 필요가 없으며, 다른 작업을 동시에 처리할 수 있습니다.

from celery import Celery

app = Celery('myapp', broker='redis://localhost:6379/0')

@app.task
def scrape_website(url):
    # 웹 크롤링 코드 작성
    pass

# 지연된 작업 예약
scrape_website.apply_async(args=['https://example.com'])

이처럼 Celery의 지연된 작업을 사용하면, 시간이 오래 걸리는 작업을 비동기적으로 실행하고, 병렬 처리를 통해 성능을 향상시킬 수 있습니다.

더 자세한 내용은 Celery 공식 문서에서 확인할 수 있습니다.