redis.read_stream

Read from Redis stream

Properties

Name	Type	Description	Required
batch_size	integer	Maximum number of records yielded per downstream batch. Default: 1000 Minimum: 1	no
flush_ms	integer, null	If set, flush a partial batch after this many ms of inactivity. null or omitted = wait until batch_size or end-of-stream. Default: 1000 Minimum: 1	no
connection	string	Connection name	yes
stream_name (Source stream name)	string	Source stream name	yes
snapshot (Snapshot current entries and quit)	boolean	Snapshot current entries and quit Default: false	no

Example

batch_size: 1000
flush_ms: 1000
snapshot: false