Real-time stream processing in Python

Compute real-time OHLC data from raw trades with Bytewax

_{Let's connect 🤗}
Twitter • LinkedIn • Newsletter

Table of contents

1. What is this repo about?
2. How to run this code
3. Wannna build real-world ML products?

What is this repo about?

This repository shows how to

• fetch real-time trade data from the Coinbase Websocket API
• transform trade data into OHLC data in real-time using Bytewax, and
• plot the OHLC data using Bokeh and Streamlit.

The final app is publicly deployed on Streamlit Cloud 👉🏽 click here

How to run this code

1. Create a Python virtual environment with the project dependencies with

   $ make init
   

2. To run the Streamlit app locally simply do

   $ make run
   

Wanna learn to design, develop and deploy a real-world ML system yourself?

Join the Real-World ML Tutorial + Community and get LIFETIME ACCESS to

• 3 hours of video lectures 🎬
• Full source code implementation 👨‍💻
• Discord private community, to connect with 100+ students and me 👨‍👩‍👦