Home

csp ("Composable Stream Processing") is a functional-like reactive language that makes time-series stream processing simple to do.  The main reactive engine is a C++ based engine which has been exposed to python ( other languages may optionally be extended in future versions ). csp applications define a connected graph of components using a declarative language (which is essentially python).  Once a graph is constructed it can be run using the C++ engine. Graphs are composed of some number of "input" adapters, a set of connected calculation "nodes" and at the end sent off to "output" adapters. Inputs as well as the engine can be seamlessly run in simulation mode using historical input adapters or in realtime mode using realtime input adapters.

Contents

• 0. Introduction
• 1. Generic Nodes (csp.baselib)
• 2. Statistics Nodes (csp.stats)
• 3. Adapters
• 4. Dynamic Graphs
• 5. Profiler

Roadmap

• Redis Pub/Sub Adapter with Redis-plus-plus
• uWebsockets adapter
• Slack Adapter with python-slack-sdk
• csp-gateway: Application development framework, built with FastAPI and Perspective
• Interactive graph viewer, both standalone and viewable in Jupyter
• Sympy integration via lambdify