tspy.data_structures.io.PullStreamTimeSeriesReader module¶
-
class
tspy.data_structures.io.PullStreamTimeSeriesReader.PullStreamTimeSeriesReader¶ Bases:
objectinterface to represent reading stream-time-series data at motion from a data-source where data is being pulled to the reader
Methods
parse(message)parse a message
poll()poll for the latest list of messages from your source
-
abstract
parse(message)¶ parse a message
- Parameters
- messageAny
a message
- Returns
Observationa single observation or None if parsing has failed
-
abstract
poll()¶ poll for the latest list of messages from your source
- Returns
- list
a list of messages
-
abstract