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. csp.Struct
• 6. Profiler

Contributing

Contributions are welcome on this project. We distribute under the terms of the Apache 2.0 license.

For bug reports or small feature requests, please open an issue on our issues page.

For questions or to discuss larger changes or features, please use our discussions page.

For contributions, please see our developer documentation. We have help wanted and good first issue tags on our issues page, so these are a great place to start.

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