Session 5
2025-04-23
PAU KAI
I need a joke for my class.
Tell me one, please?
PAU KAI
Tell them you just farted
5 goals 🎯
Goal 1 > Build technical indicators service
News Trades
API API
Trades
News ingestor
ingestor
Dashboard
Candles
Sentiment
LLM extractor
Technical
Indicators
Feature Store Model
errors
Market sentiment Technical indicators
features features
Predictions
ML features Predictions
API
Predictions
Model registry Price
predictor
Model trainer Model file +
metadata
Goal 2 > Dockerize the service
News Trades
API API
Trades
News ingestor
ingestor
Dashboard
Candles
Sentiment
LLM extractor
Technical
Indicators
Feature Store Model
errors
Market sentiment Technical indicators
features features
Predictions
ML features Predictions
API
Predictions
Model registry Price
predictor
Model trainer Model file +
metadata
Goal 3 > Deploy to Kubernetes
News Trades
API API
Trades
News ingestor
ingestor
Candles
Sentiment
LLM extractor
Technical
Indicators
Feature Store Model
errors
Market sentiment Technical indicators
features features
Predictions
ML features Predictions
API
Predictions
Model registry Price
predictor
Model trainer Model file +
metadata
Goal 4 > Install RisingWave in our cluster
News Trades
API API
Trades
News ingestor
ingestor
Dashboard
Candles
Sentiment
LLM extractor
Technical
Indicators
Feature Store Model
errors
Market sentiment Technical indicators
features features
Predictions
ML features Predictions
API
Predictions
Model registry Price
predictor
Model trainer Model file +
metadata
Goal 5 > Push kafka messages into RisingWave
News Trades
API API
Trades
News ingestor
ingestor
Dashboard
Candles
Sentiment
LLM extractor
Technical
Indicators
Feature Store Model
errors
Market sentiment Technical indicators
features features
Predictions
ML features Predictions
API
Predictions
Model registry Price
predictor
Model trainer Model file +
metadata
What are technical indicators
3 months
Technical indicators we will compute
- Moving averages
- Simple
- Exponential
- Momentum indicators
- RSI
- MACD
- Volume indicators
- OBV
Complete list is here
How to compute technical
indicators in real time?
Candles topic Read candle from
Kafka
Filter
Add candle to state
Compute technical
indicators
Technical
Push message to indicators topic
Kafka
BTC
Candles topic Read candle from
Kafka
Filter
Add candle to state
Compute technical
indicators
Technical
Push message to indicators topic
Kafka
BTC
Candles topic Read candle from
Kafka
Filter
Add candle to state
Compute technical
indicators
Technical
Push message to indicators topic
Kafka
BTC
Candles topic Read candle from
Kafka
Filter
Add candle to state
Compute technical
indicators
Technical
Push message to indicators topic
Kafka
BTC
State
Candles topic Read candle from
BTC
Kafka
Filter
Add candle to state
Compute technical
indicators
Technical
Push message to indicators topic
Kafka
BTC BTC
State
Candles topic Read candle from
BTC BTC
Kafka
Filter
Add candle to state
Compute technical
indicators
Technical
Push message to indicators topic
Kafka
BTC BTC BTC
State
Candles topic Read candle from
BTC BTC BTC
Kafka
Filter
Add candle to state
Compute technical
indicators
Technical
Push message to indicators topic
Kafka
BTC BTC BTC
State
Candles topic Read candle from
BTC BTC BTC
Kafka
Filter
Add candle to state
Compute technical
indicators
Technical
Push message to indicators topic
Kafka
BTC BTC BTC
State
Candles topic Read candle from
BTC BTC BTC
Kafka
Filter
Add candle to state
Compute technical
indicators
Technical
Push message to indicators topic
Kafka
Tech
indicators
Goal 4 > Visualize data with Grafana
News Trades
API API
Trades
News ingestor
ingestor
Dashboard
Candles
Sentiment
LLM extractor
Technical
Indicators
Feature Store Model
errors
Market sentiment Technical indicators
features features
Predictions
ML features Predictions
API
Predictions
Model registry Price
predictor
Model trainer Model file +
metadata
Your laptop
$ make dev service=trades
Kubernetes cluster
main.py
main.py
main.py
$ make deploy-for-dev service=trades
$ make run service=trades
