Skip to content

mrme77/streaming-03-bonus-salomone_p

Repository files navigation

Project Title: streaming-03-bonus-salomone_p

Introduction:

This project involves the creation of a producer that reads data from an Airport CSV file and sends messages to a new queue at intervals of 1-3 seconds. Simultaneously, a consumer is implemented to read these messages from the queue and write them to a new file as they are received.

In a fictional scenario, a company named 'Alpha' represents a consumer that acquires airport data by reading the messages produced by the aforementioned process. These messages contain relevant information from the Airport CSV file, and 'Alpha' can process this data for their specific needs.

-The producer_salomone.py program overall demonstrates how to establish a connection with RabbitMQ, send messages to a queue,handle interrupts gracefully or peacefully whichever definition sounds best, and manage RabbitMQ connections effectively.

-The consumer_salomone.py program overall demonstrates how to establish a RabbitMQ connection, set up a consumer to process messages from a queue, handle interrupts gracefully or peacefully whichever definition sounds best, and effectively manage RabbitMQ connections and message processing.

Author: Pasquale Salomone, 28 August 2023

Prerequisites

  1. Git
  2. Python 3.7+ (3.11+ preferred)
  3. VS Code Editor
  4. VS Code Extension: Python (by Microsoft)

The following modules are required:

Module Version
csv 1.0
random 3.11.4
signal 3.11.4
sys 3.11.4
time 3.11.4
pika 1.3.2

Multiple Terminals

Mac Example

Additional Resources

  1. For more information about Git in VS Code, see Using Git source control in VS Code.
  2. For more information about editing Markdown in VS Code, see Markdown and Visual Studio Code.

Acknowledgments

I would like to acknoledge both Stackoverflow and ChatGPT as an instrumental aid in the development of this project.

About

No description, website, or topics provided.

Resources

Stars

Watchers

Forks

Releases

No releases published

Packages

No packages published

Languages