class documentation
class SinakableStream: (source)
Known subclasses: aligned.streams.redis.RedisStream
Undocumented
| Async Method | sink |
Sinkes a record to a stream |
overridden in
aligned.streams.redis.RedisStreamSinkes 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