`bytewax_redis.sinks`#

Sinks for Redis.

Classes#

class RedisStreamSink(stream_name: str, host: str, port: int, db: int)#

Bases:

Redis stream sink.

This sink takes a stream of dictionaries containing key-value pairs that will be sent to a redis stream defined by the stream_name argument.

Initialization

Initialize the Redis stream sink.

Parameters:

build( step_id: str, worker_index: int, worker_count: int, ) → bytewax_redis.sinks._RedisStreamSinkPartition#

Build a stateless sink partition for each worker.

This method creates a _RedisStreamSinkPartition for each worker in the dataflow. Each worker will independently write messages to the Redis stream.

Parameters:

Returns:

A _RedisStreamSinkPartition object for writing data to the Redis stream.

class RedisKVSink(host: str = 'localhost', port: int = 6379, db: int = 0)#

Bases:

Redis key-value sink.

This sink take a stream of (key, value) 2-tuples, and writes every key to the specified Redis instance.

Initialization

Initialize the Redis key-value dynamic sink.

Parameters:

build( step_id: str, worker_index: int, worker_count: int, ) → bytewax_redis.sinks._RedisKVSinkPartition#

Build a stateless sink partition for each worker.

This creates a _RedisKVSinkPartition for each worker in the dataflow. Each worker will independently write key-value pairs to Redis.

Parameters:

Returns:

A _RedisKVSinkPartition object for writing key-value pairs to Redis.