From the course: AI-Powered Time Series Forecasting with Python
Unlock the full course today
Join today to access over 24,700 courses taught by industry experts.
Online prediction - Python Tutorial
From the course: AI-Powered Time Series Forecasting with Python
Online prediction
Now that we know how to produce data to a real time stream and calculate our real time feature store, the last missing piece is to make predictions. So let's see how that works. First off, make sure your docker container is running from a fresh state. Go into the real-time folder and launch your docker container. Be sure that here on the left side there is no state folder. And then go to the data producer script and run it to produce some data. Once this is running, go to your feature pipeline and also start your feature pipeline so it's listening to the produced data. Now with that, let's close our terminal for now and go to the inference notebook. What we will do here is to define a Kafka consumer to subscribe to messages in the feature store. This one isn't using Quix Streams anymore, just Confluent Kafka. Let's take a closer look. The function fetch_all_feature_records is, as you might guess, fetching all feature records from our online feature store. The way this works is that we…
Contents
-
-
-
-
-
(Locked)
What are real-time forecasting systems?4m 14s
-
(Locked)
Requirements of real-time forecasting systems5m 2s
-
(Locked)
Streaming datasets4m 22s
-
(Locked)
Online features4m 21s
-
(Locked)
Online prediction3m 23s
-
(Locked)
End-to-end example2m 30s
-
(Locked)
Real-time forecasting and latency considerations1m 26s
-
(Locked)
Advantages and disadvantages of real-time forecasting4m 44s
-
(Locked)
Challenge: Feature Z1m 34s
-
(Locked)
Solution: Feature Z1m 29s
-
(Locked)
-
-