Join the webinar: Build an industrial data pipeline using AI and MCP servers
More details
Quix logo.
Quix Homepage
Product
Quix Cloud
Quix Streams
Solutions
Industry: Energy
Industry: Manufacturing
Customer stories
Project templates
App templates
Integrations
Integrations
Pricing
Pricing
Blog
Blog
Docs
Docs
Github icon
View our Github repo
Slack Icon
Join our Slack community
Explore the platform
Book a demoExplore the platform
Project gallery
See it running in QuixClone this project
Interested in this use case?
If you'd like us to focus on building this template next, register your interest and let us know. You can also head over to the Quix Community Slack if you've got any questions.
Register interest
  • Github
    Project repo
  • Docs tutorial
  • Project frontend
  • Explore in Quix Cloud
Built on Quix with:
Hopsworks logo
Redpanda logo
Streamlit logo
Project template
Use case
Code snippet

Real-time feature computation

A real-time feature pipeline that computes essential features (open-high-low-close prices) that you can pass to an ML-powered trading system for training and inference. This template was contributed by Pau Labarta Bajo.

Use cases:
Feature Engineering
Created by:
Paulescu avatar
Paulescu
Paulescu
A diagram of a real-time feature pipeline

Main project components

Trade producer

A source connector that reads Bitcoin trades from the Kraken Websocket API and writes them in a Kafka topic.

Trade to OHLC

A transformation that reads trading data from a Kafka topic, computes Open-High-Low-Close candles (OHLC) using Stateful Window Operators, and saves them in another Kafka topic.

OHLC to feature store

A sink connector that saves the computed OHLC data to Hopsworks—an external feature store.

Streamlit Dashboard: last 20-minutes

A dashboard that visualizes the last 20 minutes of the real-time OHLC data based on trading activity in Kraken (computed on 10-second windows)

Technologies used

  • Hopsworks
  • Quix Streams
  • Streamlit

Using this template

This project could be easily adapted for use cases such as:

  • More advanced trading analysis
  • Other window-based pipelines such as temperature analysis
Interested in this use case?
If you'd like us to focus on building this template next, register your interest and let us know. You can also head over to the Quix Community Slack if you've got any questions.
Register interest
  • Github
    Project repo
  • Docs tutorial
  • Project frontend
  • Explore in Quix Cloud
Built on Quix with:
Hopsworks logo
Redpanda logo
Streamlit logo
Quix logo.
Quix Homepage
Github
Slack
Slack
Slack
LinkedIn
Twitter
YouTube
Youtube
Product
Quix CloudQuix StreamsIntegrationsPricingExplore the platformBook a demo
Developers
DocsQuix Streams repoRelease notesService status
Serverless portal login
Solutions
Project templatesApp templatesCustomer storiesEnergy industryManufacturing industry
Community
Community hubEventsContributingJoin us on Slack
Resources
Resources hubBlogQuix AcademyWebinars & videosCloud security principles
Company
About usCareersDiversity & inclusionEnvironmental statement
© 2025 Quix Analytics
TermsPrivacyLicense Terms
ISO27001 certified