Reactive Dataflow Graphs
Project description
Reactive-Dataflow
Reactive Processing Graphs for Python.
Getting Started
Installation
pip install reactivedataflow
The key dependencies for this project include rx
and networkx
. These are outlined in the pyproject.toml
dependencies section.
Usage
import reactivex as rx
from reactivedataflow import (
GraphAssembler,
GraphModel,
VerbNodeModel,
InputNodeModel,
InputModel,
verb,
InputPort,
ConfigPort
)
#
# Define a processing verb
#
@verb(
name="print",
ports=[
InputPort(name="values", required=True, parameter="val"),
ConfigPort(name="prefix", required=False, parameter="prefix"),
]
)
def print_verb(val, prefix=""):
return f"{prefix}{val}"
#
# Define a simple graph
#
assembler = GraphAssembler()
assembler.load(
GraphModel(
inputs=[
# This is an input stream of values we'll define on build
InputNodeModel(id="input_values")
],
nodes=[
# Here we define the processing nodes
VerbNodeModel(
id="verb1",
verb="print",
config={"prefix": "emitted: "},
input={
"values": InputModel(node="input_values")
}
),
],
),
)
#
# Build the graph and bind input streams
#
graph = assembler.build(
inputs={
"input_values": rx.of([1, 2, 3])
}
)
#
# Watch graph outputs
#
graph.output("verb1").subscribe(print)
# Output:
# emitted: 1
# emitted: 2
# emitted: 3
Developing
This project uses poetry
for dependency management. You should have a recent Python version (e.g. 3.10+) and Poetry 1.8+ installed on your system.
# Install dependencies
poetry install
# Run tests
poetry run poe test
# Run static checks
poetry run poe check
Project details
Release history Release notifications | RSS feed
Download files
Download the file for your platform. If you're not sure which to choose, learn more about installing packages.
Source Distribution
reactivedataflow-0.1.13.tar.gz
(19.7 kB
view hashes)
Built Distribution
Close
Hashes for reactivedataflow-0.1.13-py3-none-any.whl
Algorithm | Hash digest | |
---|---|---|
SHA256 | ac6c8f704ac30b958e94a5f51b361f6af334ae6d4bf035409eecdd47de6403d5 |
|
MD5 | 10dfe7ee7dd0469867f07ed9a97060cf |
|
BLAKE2b-256 | e776a66d6dac8f0695c9149eb82d3c3306c4451892680486302668f2414794f4 |