[python] Django와 메시지 큐(Message queue) 연동 방법은 어떻게 되는가?

22 Nov 2023

python

Django는 메시지 큐(Message Queue)와의 연동을 쉽게 구현할 수 있습니다. 메시지 큐를 사용하면 비동기적으로 작업을 처리하고, 작업이 완료될 때까지 요청을 차단하지 않고 다른 작업을 처리할 수 있습니다. 이를 통해 시스템의 확장성과 성능을 향상시킬 수 있습니다.

RabbitMQ를 사용한 Django와의 연동

RabbitMQ는 Django와의 메시지 큐 연동을 위한 인기 있는 오픈 소스 솔루션입니다. 아래는 RabbitMQ를 사용한 Django 연동 방법입니다.

RabbitMQ 설치 및 설정

RabbitMQ를 공식 웹사이트에서 다운로드하고 설치합니다. 설치 후 RabbitMQ 서버를 실행해야 합니다.
Django에 Celery 설치

Celery는 Django와 RabbitMQ를 연동하여 비동기 작업을 수행할 수 있도록 해주는 라이브러리입니다. 다음 명령을 사용하여 Celery를 설치합니다.
```
pip install celery
```

Django 설정 파일에서 Celery 설정 추가

Django 설정 파일(settings.py)에 다음과 같이 Celery 설정을 추가합니다.

# settings.py

CELERY_BROKER_URL = 'amqp://localhost'
CELERY_RESULT_BACKEND = 'rpc://'

# Celery worker가 Django 설정을 자동으로 사용하도록 설정합니다.
CELERY_APP = 'your_project_name'
CELERY_IMPORTS = (
    'your_app_name.tasks',
)

Django 애플리케이션에서 비동기 작업 정의

비동기로 실행되어야 하는 작업을 정의하는 파일을 생성합니다. 일반적으로 tasks.py라는 이름으로 저장합니다. 다음은 간단한 예제입니다.
```
# tasks.py

from celery import shared_task

@shared_task
def send_email(recipient, message):
    # 이 메서드에서 이메일을 보내는 작업을 처리합니다.
    pass
```
비동기 작업 실행

Django 애플리케이션의 어느 곳에서든 비동기 작업을 실행할 수 있습니다. 다음은 예제입니다.
```
from your_app_name.tasks import send_email

send_email.delay('recipient@example.com', 'Hello, World!')
```
delay() 메서드를 호출하여 비동기 작업을 큐에 추가하고, Celery worker가 순차적으로 작업을 실행합니다.

이와 같이, Django와 RabbitMQ를 연동하여 메시지 큐를 사용하는 방법을 알아보았습니다. RabbitMQ는 다른 메시지 큐 프로버더들과도 호환되며, 원하는 경우 다른 메시지 큐를 사용할 수도 있습니다.

더 자세한 내용은 Celery 공식 문서를 참조해주세요.