add 3 lab files

Author: RivanDev

emit_log.py

@@ -0,0 +1,35 @@
+import asyncio
+import sys
+
+from aio_pika import DeliveryMode, ExchangeType, Message, connect
+
+
+async def main() -> None:
+    # Perform connection
+    connection = await connect("amqp://guest:guest@localhost/")
+
+    async with connection:
+        channel = await connection.channel()
+
+        logs_exchange = await channel.declare_exchange(
+            "logs",
+            ExchangeType.FANOUT,
+        )
+
+        message_body = (
+            b" ".join(arg.encode() for arg in sys.argv[1:]) or b"Hello World!"
+        )
+
+        message = Message(
+            message_body,
+            delivery_mode=DeliveryMode.PERSISTENT,
+        )
+
+        # Sending the message
+        await logs_exchange.publish(message, routing_key="info")
+
+        print(f" [x] Sent {message!r}")
+
+
+if __name__ == "__main__":
+    asyncio.run(main())

logs_from_rabbit.log

@@ -0,0 +1,3 @@
+ [*] Waiting for logs. To exit press CTRL+C
+[x] b'Hello World!'
+[x] b'Hello World!'

receive_logs.py

@@ -0,0 +1,40 @@
+import asyncio
+
+from aio_pika import ExchangeType, connect
+from aio_pika.abc import AbstractIncomingMessage
+
+
+async def on_message(message: AbstractIncomingMessage) -> None:
+    async with message.process():
+        print(f"[x] {message.body!r}")
+
+
+async def main() -> None:
+    # Perform connection
+    connection = await connect("amqp://guest:guest@localhost/")
+
+    async with connection:
+        # Creating a channel
+        channel = await connection.channel()
+        await channel.set_qos(prefetch_count=1)
+
+        logs_exchange = await channel.declare_exchange(
+            "logs",
+            ExchangeType.FANOUT,
+        )
+
+        # Declaring queue
+        queue = await channel.declare_queue(exclusive=True)
+
+        # Binding the queue to the exchange
+        await queue.bind(logs_exchange)
+
+        # Start listening the queue
+        await queue.consume(on_message)
+
+        print(" [*] Waiting for logs. To exit press CTRL+C")
+        await asyncio.Future()
+
+
+if __name__ == "__main__":
+    asyncio.run(main())