Skip to content

Latest commit

 

History

History
80 lines (59 loc) · 2.73 KB

README.md

File metadata and controls

80 lines (59 loc) · 2.73 KB
Raw

Python/Docker/RabbitMQ

This project demonstrates a simple message producer and consumer using RabbitMQ and Docker.

Project Structure

  • producer/: Contains the producer code and Dockerfile.
  • consumer/: Contains the consumer code and Dockerfile.
  • docker-compose.yml: Defines the services for Docker Compose.
  • README.md: This file.

Requirements

  • Docker and Docker Compose installed on machine.

Setup Instructions

  1. Clone the repository:

    git clone <repository_url>
cd <repository_name>

  2. Build and run the services using Docker Compose:

    docker compose up --build

  3. Access RabbitMQ management UI:

    • Open browser and go to http://localhost:15672
    • Login with guest as the username and guest as the password.

  4. Observe the logs: See Logs & Testing section below.

    • Producer logs will show messages being sent.
    • Consumer logs will show messages being received.

Logs & Testing

  1. RabbitMQ Management Interface:

    • Open browser and navigate to http://localhost:15672.
    • Login using the default credentials (guest / guest).
    • Go to the "Queues" tab to see the task_queue.
    • Check the queue to ensure messages are being published and consumed.

  2. Verify Producer Logs:

    • Ensure the producer is logging messages every 5 seconds. You should see log entries like: 
      producer_1  | Sending message: {'message_id': 'some-uuid', 'created_on': 'some-timestamp'}

  3. Verify Consumer Logs:

    • Ensure the consumer is logging received messages. You should see log entries like: 
      consumer_1  | Received message: b"{'message_id': 'some-uuid', 'created_on': 'some-timestamp'}"

Sample Terminal Output

When running docker compose up --build, the terminal output should look something like this:

Starting project-root_rabbitmq_1 ... done
Starting project-root_producer_1 ... done
Starting project-root_consumer_1 ... done
rabbitmq_1   | 2024-07-07 12:34:00.000 [info] <0.0.0> RabbitMQ running
producer_1   | 2024-07-07 12:34:05.123 INFO Sending message: {'message_id': 'e7e2c715-0b0e-453e-9df9-b89b0d8a3147', 'created_on': '2024-07-07T12:34:05.123456'}
consumer_1   | 2024-07-07 12:34:06.789 INFO Received message: b"{'message_id': 'e7e2c715-0b0e-453e-9df9-b89b0d8a3147', 'created_on': '2024-07-07T12:34:05.123456'}"

Notes

  • The producer sends a message every 5 seconds. This interval can be adjusted in producer/producer.py.
  • Both producer and consumer services are set up to communicate with the RabbitMQ service defined in docker-compose.yml.

Cleanup

To stop the services and remove containers, networks, and volumes created by Docker Compose, run:

docker compose down