Celery를 사용하여 RabbitMQ로 publish / consume 처리 하기
- REST API(FastAPI)에서 MQ로 publish
- Celery Beat에서 MQ로 publish
- Celery Work에서 consume
- poetry로 설치
poety install
- 로컬에서 사용할
.env
파일 루트 경로에 생성
RABBITMQ_URL=localhost
RABBITMQ_DEFAULT_USER=guest
RABBITMQ_DEFAULT_PASS=guest
REDIS_URL=localhost
$ docker run -d -it --rm --name rabbitmq -p 5672:5672 -p 15672:15672 rabbitmq:3.13-management
$ docker run -d --name redis-stack-server -p 6379:6379 redis/redis-stack-server:latest
$ docker-compose up --build