Skip to content

Instantly share code, notes, and snippets.

@tomas-quix

tomas-quix/6b-perform-aggregation-over-a-window-of-time-series-data-with-built-in-buffers.py

Created March 2, 2023 09:58
Show Gist options
  • Star 0 You must be signed in to star a gist
  • Fork 0 You must be signed in to fork a gist
  • Save tomas-quix/dc463c5d1a5461d4477ef91d9b7e18fb to your computer and use it in GitHub Desktop.
Save tomas-quix/dc463c5d1a5461d4477ef91d9b7e18fb to your computer and use it in GitHub Desktop.
Download ZIP
OSS Announcement
Raw
6b-perform-aggregation-over-a-window-of-time-series-data-with-built-in-buffers.py
def on_read_dataframe(stream: StreamConsumer, df: pd.DataFrame):
df["total"] = df["price"] * df["items_count"]
topic_producer.get_or_create_stream(stream.stream_id).timeseries_data.write(df)
buffer.on_received_dataframe = on_read_dataframe_handler
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment