| Basics |
Basic Graph |
Basic sum of constant integers |
| Ticking Graphs |
Cumulative sum of streaming integers |
| Visualizing a Graph |
Bid-ask spread of a trade with graph visualization |
| Complete Example (Trading) |
Volume weighted average price (VWAP) and profit and loss (PnL) |
| Complete Example (Retail) |
Maintain a shopping cart with time-based discounts for customers |
| Intermediate |
Feedback Connections |
Add a feedback edge between nodes in a graph |
| Statistics Nodes |
Use the CSP statistics library on simulated trading data |
| Statistics Nodes with Numpy |
Rolling window statistics on a set of three symbols using NumPy arrays |
Expression Nodes with exprtk |
Calculate mathematical expressions with streaming data |
| Using Adapters |
Kafka Adapter Example |
Stream data from a Kafka bus using KafkaAdapterManager and MessageMapper
|
| Parquet Adapter Example |
Read from and write CSP data to Parquet files
|
| Websocket Client |
Send and receive messages over a websocket connection
|
| Websocket Output |
Send data over a websocket connection and view HTML output
|
| Writing Adapters |
Generic Push Adapter |
Push real-time data into a CSP graph
|
| Pull Input Adapter |
Replay historical data using a pull adapter
|
| Pull Input Adapter with Adapter
Manager |
Provide data to multiple input adapters from a single source
|
| Push Input Adapter |
Write your own push adapter for real-time data
|
| Push Input Adapter with Adapter
Manager |
Use an adapter manager with real-time data sources
|
| Output Adapter |
Create a custom writer for CSP output data
|
| Complete Input/Output Adapter with
Adapter Manager |
Manage input and output adapters with a single adapter manager
|
| Push-Pull Input Adapter for Earthquake Data |
Create a push-pull adapter which transitions from replay to live execution
|
| Writing C++ Nodes and Adapters |
C++ Node |
Extend CSP with a pig latin C++ node
|
C++ Node with csp.Struct |
Write a C++ node with a csp.Struct input
|
| Advanced |
Dynamic Graphs |
Update the shape of a graph at runtime
|
| Pandas Extension |
Use CSP within a pandas DataFrame
|
| End-to-end examples |
MTA Subway Data |
Access real-time New York City transit data
|
| Seismic Data with obspy |
Analyze seismic waveforms and compare with batch processing methods
|
| Wikipedia Updates and Edits |
Monitor live updates to all Wikimedia sites
|
| World Earthquake Dashboard |
Display recent earthquakes on a live-updating world map
|
| Just for fun! |
NAND Computer |
Understand csp.node & csp.graph by connecting NAND logic gates
|
| Developer Tools |
Profiling csp code |
Profile a CSP Graph, view static attributes and runtime performance
|