Redis Strings¶

Store events as key-value pairs in Redis.

Docker Image¶

docker pull ghcr.io/psteinroe/postgres-stream:redis-strings-latest

Configuration¶

sink:
  type: redis-strings
  url: redis://localhost:6379

With Key Prefix¶

sink:
  type: redis-strings
  url: redis://localhost:6379
  key_prefix: events

Options¶

Key Resolution¶

Keys are determined in this order:

1. key in event metadata
2. Event ID with optional prefix

Without a key in metadata: - No prefix: key = event ID - With prefix: key = {prefix}:{event_id}

Dynamic Routing¶

Set custom keys per-event using metadata:

-- Use user_id as the key
metadata_extensions = '[
  {"json_path": "key", "expression": "''user:'' || new.user_id::text"}
]'

The sink reads the key from event metadata.

Example¶

Complete configuration:

stream:
  id: 1
  pg_connection:
    host: localhost
    port: 5432
    name: mydb
    username: postgres
    password: postgres
    tls:
      enabled: false
  batch:
    max_size: 1000
    max_fill_secs: 5

sink:
  type: redis-strings
  url: redis://localhost:6379
  key_prefix: postgres

Values are stored as JSON-serialized payloads using Redis SET command.