This project contains an example of how to implement a consumer and a publisher of the messages on RabbitMQ queues. It also persists the received data into a Postgres schema. Basically the publisher will create a person for each new message and send it to the queue. Then the consumer will catch the next message on the queue, parse it to JSON and finally persist the received person into the database.
- Have RabbitMQ running on your computer.
- Have a database on PostgreSQL called integration. For the sake of the example, it also must be running on localhost with user and password: postgres Don't worry about the table. The consumer application will handle it.
- Clone this repository.
- Start the app.py file in the folder called consumer:
python app.py - Start the app.py file in the folder called publisher, passing as the argument how many messages you want to send:
python app.py 300
Ps.: You can start how many publishers/consumers you want.