Add output data streams to python functions #1181
Conversation
SvenO3
added
enhancement
| @@ -0,0 +1,16 @@ | |||
| # | |||
| # Licensed to the Apache Software Foundation (ASF) under one or more | |||
There was a problem hiding this comment.
lets move this into a dedicated module called function_zoo
There was a problem hiding this comment.
Should function_zoo be a submodule of the functions module. Or should it be seperated to differentiate between implementation and examples?
There was a problem hiding this comment.
I would see it as separate module on the same level like functions.
Should also be beneficial in terms of imports
|
almost forgot: please rebase the PR before we merge it because we upgraded |
|
Needs to be merged in sync with #1228 |
What's the best way to do this? |
|
Well, one of us has to do some work 😅 |
Purpose
This PR implements the support for output data streams for the python functions. This makes it possible to create a new data stream out of python and to write back live data to StreamPipes via that stream.
It also provides an implementation to use Online Machine Learning with the StreamPipesFunctions using the River library. You can now train an Online ML model on a data stream and sends the prediction back to StreamPipes with very little effort.
Remarks
PR introduces (a) breaking change(s): no
PR introduces (a) deprecation(s): no