-
Skill level
Beginner, no prior knowledge requirements
-
Time to complete
Approx. 25 min
Introduction: Here is a basic example of using Bytewax to turn an incoming stream of event logs from a hypothetical search engine into metrics over search sessions. In this example, we're going to focus on the dataflow itself and aggregating state, and gloss over details of building this processing into a larger system.
Kafka/Redpanda
Postgres
Python modules
[What people can expect to gain from reading the tutorial]
Your takeaway from this tutorial will be a streaming application that lets you aggregate data coming from a Kafka topic using Bytewax.
- Resources
- Step 1
- Step 2
- Step 3
- Summary
Github link
Jupyter Notebook link
Data sample link
To start off, we are going to diverge into some concepts around markets, exchanges and orders.
Order book
Bid & Ask
Level 2 Data
That’s it, you are awesome and we are going to rephrase our takeaway paragraph
If you have any trouble with the process or have ideas about how to improve this document, come talk to us in the #troubleshooting Slack channel!
- Relevant explainer video
- Relevant case study
- Relevant blog post
- Another awesome tutorial
See our full gallery of tutorials →