cloudvision.Connector package

Subpackages

Module contents

cloudvision.Connector.process_notifs(stream, paths={}, keys={}, nominalKeys=None)[source]

process_notifs consume the batch coming from stream and return them as a hierarchy of dataset, path, and keys. Allowing for faster access of a given time serie.

cloudvision.Connector.sort_dict(resDict)[source]

sort_dict orders every timeseries in a hierarchy of dataset by its timestamps.