Skip to main content
Join the official 2019 Python Developers SurveyStart the survey!

Data stream model

Project description

Data stream model helps developers to build "chains" of connected
computing nodes and run them.
A computing node has input/ouput sockets, and the "dsm runner"
is responsible to carry "data streams" through the "chains"
and feed "data streams" to computing nodes.

Usage:

Please read the main function in Composite.py for an example.

Notes:

1. Developers are responsible to
* build computing nodes (with i/o sockets)
2 Developers or Users are responsible to
* specify connections of computing nodes

Hints for developers:

1. Read tests in source codes to understand how to use dsm.
Start with Composite.py and Runner.py is a good idea

Limitations:
1. No loops are allowed.
2. Currently only a trivial implementation of "runner" exists. So data streams
are limited in one physical machine.

Project details


Download files

Download the file for your platform. If you're not sure which to choose, learn more about installing packages.

Files for danse.ins.dsm, version 0.1.2
Filename, size File type Python version Upload date Hashes
Filename, size danse.ins.dsm-0.1.2.tar.gz (4.0 kB) File type Source Python version None Upload date Hashes View hashes

Supported by

Elastic Elastic Search Pingdom Pingdom Monitoring Google Google BigQuery Sentry Sentry Error logging AWS AWS Cloud computing DataDog DataDog Monitoring Fastly Fastly CDN SignalFx SignalFx Supporter DigiCert DigiCert EV certificate StatusPage StatusPage Status page