tspy.data_structures.io.PushStreamTimeSeriesReader module¶
-
class
tspy.data_structures.io.PushStreamTimeSeriesReader.PushStreamTimeSeriesReader¶ Bases:
objectinterface to represent reading stream-time-series data at motion from a data-source where data is being pushed to the reader
Notes
When implementing this reader, you will typically use the
callback()method in your own callback of the streaming platform you are using. Callback accepts a single message.Methods
callback(message)Accepts the next message to process
parse(message)parse a message
-
callback(message)¶ Accepts the next message to process
- Parameters
- messageany
a single message
-
abstract
parse(message)¶ parse a message
- Parameters
- messageAny
a message
- Returns
Observationa single observation or None if parsing has failed
-