Refactor telemetry so it can be passed data from the db

I need to be able to pass a dataframe to raps directly. Refactor telemetry to split out the logic so it can do either parquet, snapshot, or direct parquet