consumer_example.py

consumer.py

import asyncio

from faststream import FastStream, Logger
from faststream.redis import RedisBroker, StreamSub

broker = RedisBroker("redis://localhost:6379")

app = FastStream(broker, logger=None)

chan = "chan"

word_publisher = broker.publisher(chan)


@broker.subscriber(chan)
async def lower(word: str, logger: Logger) -> None:
    lower = word.lower()
    logger.info(f"LOWER:{lower}")

async def send(word) -> None:
    await word_publisher.publish(word)


@app.after_startup
async def run():
    words = ['APPle', 'banaNA']
    await asyncio.gather(*[send(w) for w in words])

faststream run consumer_example:app
2024-01-22 14:42:20,173 INFO     - chan |                 - `Lower` waiting for messages
2024-01-22 14:42:20,193 INFO     - chan | 756d96de-cc63-4 - Received
2024-01-22 14:42:20,194 INFO     - chan | 756d96de-cc63-4 - LOWER:banana
2024-01-22 14:42:20,194 INFO     - chan | 756d96de-cc63-4 - Processed
2024-01-22 14:42:20,194 INFO     - chan | ca21a892-9dbc-4 - Received
2024-01-22 14:42:20,194 INFO     - chan | ca21a892-9dbc-4 - LOWER:apple
2024-01-22 14:42:20,194 INFO     - chan | ca21a892-9dbc-4 - Processed