Skip to content
Python Data Streams
Python Makefile Shell
Branch: master
Clone or download
Fetching latest commit…
Cannot retrieve the latest commit at this time.
Permalink
Type Name Latest commit message Commit time
Failed to load latest commit information.
docs
examples
scripts
tests
tributary
.bettercodehub.yml
.gitattributes
.gitignore
.travis.yml
CODE_OF_CONDUCT.md first commit Sep 8, 2018
LICENSE
MANIFEST.in
Makefile fixes #44 Aug 6, 2019
README.md update readme Jun 11, 2019
requirements.txt
requirements_py2.txt
setup.cfg
setup.py
setup.py.in

README.md

Python Data Streams

Build Status GitHub issues codecov BCH compliance PyPI PyPI Docs

Stream Types

Tributary offers several kinds of streams:

Reactive

These are synchronous, reactive data streams, built using python generators. They are designed to mimic complex event processors in terms of event ordering.

Asynchronous

These are synchronous, reactive data streams, built using asynchronous python generators. They are a variant of the reactive streams, but should offer performance improvements over the non-asynchronous variants.

Functional

These are functional streams, built by currying python functions (callbacks).

Lazy

These are lazily-evaluated python streams, where outputs are propogated only as inputs change.

Event Loop

TODO These function as tornado based event-loop based streams similar to streamz.

Examples

Math

(Work in progress)

Operations

  • unary operators/comparators
  • binary operators/comparators

Rolling

  • count
  • sum

Sources and Sinks

(Work in progress)

Sources

  • file
  • kafka
  • websocket
  • http
  • socket io

Sinks

  • file
  • kafka
  • http
  • TODO websocket
  • TODO socket io
You can’t perform that action at this time.