aligned.streams.interface.SinakableStream

class documentation

class SinakableStream: (source)

Known subclasses: aligned.streams.redis.RedisStream

View In Hierarchy

Undocumented

Async Method sink Sinkes a record to a stream
async def sink(self, records: list[dict]): (source) ΒΆ
overridden in aligned.streams.redis.RedisStream

Sinkes a record to a stream

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

await stream_source.sink(records=[
{"passenger_id": 20, "age": 23, ...}

])

Args:
record (dict): The record to sink