Skip to main content

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


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.6.tar.gz (16.9 kB view details)

Uploaded Source

Built Distribution

reactivedataflow-0.1.6-py3-none-any.whl (27.4 kB view details)

Uploaded Python 3

File details

Details for the file reactivedataflow-0.1.6.tar.gz.

File metadata

  • Download URL: reactivedataflow-0.1.6.tar.gz
  • Upload date:
  • Size: 16.9 kB
  • Tags: Source
  • Uploaded using Trusted Publishing? Yes
  • Uploaded via: twine/5.1.0 CPython/3.12.4

File hashes

Hashes for reactivedataflow-0.1.6.tar.gz
Algorithm Hash digest
SHA256 1d2eba0424807b89a213c1652705dfe864beaee8032c1e913c27153180743d17
MD5 925569b10048df2119ee13c33f73a148
BLAKE2b-256 c9cd1787202e87b416ac7f8dac22b7fc46f3e7e041bef866cb8ccdc134aaf225

See more details on using hashes here.

File details

Details for the file reactivedataflow-0.1.6-py3-none-any.whl.

File metadata

File hashes

Hashes for reactivedataflow-0.1.6-py3-none-any.whl
Algorithm Hash digest
SHA256 1dbfafd127f63e9c4678a6561973756d13ad35b51aeb52a59408076ebcc7c986
MD5 7d439e992308d5e1f699d05878ac2a81
BLAKE2b-256 320b3515cfd21002484aaf38e53d1747e2257d935e46fb4083afa3bbe52b407d

See more details on using hashes here.

Supported by

AWS AWS Cloud computing and Security Sponsor Datadog Datadog Monitoring Fastly Fastly CDN Google Google Download Analytics Microsoft Microsoft PSF Sponsor Pingdom Pingdom Monitoring Sentry Sentry Error logging StatusPage StatusPage Status page