Hello world for Python (rstream) stream client (#404)

Author: DanielePalaia

python-stream/README.md

@@ -0,0 +1,25 @@
+# Python code for RabbitMQ tutorials
+
+
+Here you can find Python code examples from [RabbitMQ tutorials](https://www.rabbitmq.com/getstarted.html).
+
+
+## Requirements
+
+These examples use the [`qweeze/rstream`](https://github.com/qweeze/rstream) client library.
+
+Get it first with the necessary dependencies:
+
+     pip3 install -r requirements.txt
+
+## Code
+
+Code examples are executed via `python3`:
+
+[Tutorial one: "Hello World!"](https://www.rabbitmq.com/tutorials/tutorial-one-python-stream):
+
+    python3 send.py
+    python3 receive.py
+
+
+To learn more, see [`rqweeze/rstream`](https://github.com/qweeze/rstream).

python-stream/receive.py

@@ -0,0 +1,44 @@
+import asyncio
+import signal
+
+from rstream import (
+    AMQPMessage,
+    Consumer,
+    MessageContext,
+    ConsumerOffsetSpecification,
+    OffsetType,
+)
+
+STREAM_NAME = "hello-python-stream"
+# 5GB
+STREAM_RETENTION = 5000000000
+
+
+async def receive():
+    consumer = Consumer(host="localhost", username="guest", password="guest")
+    await consumer.create_stream(
+        STREAM_NAME, exists_ok=True, arguments={"MaxLengthBytes": STREAM_RETENTION}
+    )
+
+    loop = asyncio.get_event_loop()
+    loop.add_signal_handler(
+        signal.SIGINT, lambda: asyncio.create_task(consumer.close())
+    )
+
+    async def on_message(msg: AMQPMessage, message_context: MessageContext):
+        stream = message_context.consumer.get_stream(message_context.subscriber_name)
+        print("Got message: {} from stream {}".format(msg, stream))
+
+    print("Press control +C to close")
+    await consumer.start()
+    await consumer.subscribe(
+        stream=STREAM_NAME,
+        callback=on_message,
+        offset_specification=ConsumerOffsetSpecification(OffsetType.FIRST, None),
+    )
+    await consumer.run()
+    # give time to the consumer task to close the consumer
+    await asyncio.sleep(1)
+
+
+asyncio.run(receive())

python-stream/requirements.txt

@@ -0,0 +1,3 @@
+rstream
+uamqp
+mmh3

python-stream/send.py

@@ -0,0 +1,27 @@
+import asyncio
+
+from rstream import Producer
+
+STREAM_NAME = "hello-python-stream"
+# 5GB
+STREAM_RETENTION = 5000000000
+
+
+async def send():
+    async with Producer(
+        host="localhost",
+        username="guest",
+        password="guest",
+    ) as producer:
+        await producer.create_stream(
+            STREAM_NAME, exists_ok=True, arguments={"MaxLengthBytes": STREAM_RETENTION}
+        )
+
+        await producer.send(stream=STREAM_NAME, message=b"Hello, World!")
+
+        print(" [x] Hello, World! message sent")
+
+        input(" [x] Press Enter to close the producer  ...")
+
+
+asyncio.run(send())