Skip to main content

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.

Source Distribution

danse.ins.dsm-0.1.2.tar.gz (4.0 kB view details)

Uploaded Source

File details

Details for the file danse.ins.dsm-0.1.2.tar.gz.

File metadata

File hashes

Hashes for danse.ins.dsm-0.1.2.tar.gz
Algorithm Hash digest
SHA256 3ac483bda458b77d45bf24bdeb118c011ff0149e60782c6d97aafd421e1c236b
MD5 52365d8f0d1374a7bb0091bf4b718a67
BLAKE2b-256 fb9407d30e0aabc9608acffe68230530ddadea34b2fc993489b175ed15bd1d36

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