Implementation of Producer-Consumer using Docker containers with Django App, Celery Worker & Beat and RabbitMQ.
Make a copy of .env-sample
cp .env-sample .envSetup database configuration. Update values for:
DB_NAME=<db_name>In file .env, created before when setup database configuration; update values for:
# RABBITMQ
BROKER_USER=<broker_user>
BROKER_PASSWORD=<broker_user_password>
BROKER_HOST=<broker_server_ip_or_hostname|localhost>
BROKER_PORT=<broker_server_port|5672>
# CELERY
CELERY_TASK_DEFAULT_QUEUE=<default_tasks_queue_name|my_stack_dq>
CELERY_TASK_DEFAULT_EXCHANGE=<default_tasks_exchange_name|my_stack_ex>
CELERY_TASK_DEFAULT_ROUTING_KEY=<default_tasks_routing_key|my_stack_rk>From root directory execute:
docker-compose -f .container/docker-compose up -d
Visit url http://localhost:15672/
username: rabbitmq_admin
password: RabbitMqAdminPassWord
Login in RabbitMQ Manager Tool
Click in Admin menu option
Click in Add a user
- Set as Username: celery_user
- Set as Passowrd: celery_password
- Set as Tags: management
- Click button Add User
Login in RabbitMQ Manager Tool
Edit the created user: celery_user
In Permissions section, set as Virtual Host the value: /
Click the button Set permission
Visit url http://localhost:8008/