bytewax-valkey 0.1.0

Valkey connectors for Bytewax

Bytewax Lever

Valkey connectors for Bytewax.

This connector offers 1 source and 1 sink:

• StreamSource - reads Valkey streams using xread
• PubSubSource - writes Valkey pubsub using subscribe

Installation

This package is available via PyPi as bytewax-valkey and can be installed via your package manager of choice.

Usage

Pub/Sub Source

import os

from bytewax_valkey.inputs.pubsub_source import PubSubSource
from bytewax.connectors.stdio import StdOutSink

import bytewax.operators as op
from bytewax.dataflow import Dataflow

VALKEY_URL = os.environ["VALKEY_URL"]

flow = Dataflow("valkey_example")
flow_input = op.input("input", flow, PubSubSource.from_url(VALKEY_URL, "example"))
op.output("output", flow_input, StdOutSink())

Stream Source

import os

from bytewax_valkey.inputs.stream_source import StreamSource
from bytewax.connectors.stdio import StdOutSink

import bytewax.operators as op
from bytewax.dataflow import Dataflow

VALKEY_URL = os.environ["VALKEY_URL"]

flow = Dataflow("valkey_example")
flow_input = op.input("input", flow, StreamSource.from_url(VALKEY_URL, "example"))
op.output("output", flow_input, StdOutSink())

License

Licensed under the MIT License.