aligned.streams.redis.RedisStream

Reads a stream of data

```python stream = RedisStream(...)

records = await stream.read(max_records=10, max_wait=5) print(records[0]) ``` >>> {"passenger_id": 20, "age": 23, ...}

Args:

max_records (int, optional): _description_. Defaults to None. max_wait (float, optional): _description_. Defaults to None.

Returns:

list[dict]: A list of the records returned

Sinkes a record to a stream

```python stream_source = RedisStream(...)

await stream_source.sink(records=[

{"passenger_id": 20, "age": 23, ...}