From a925035acdb8218201d26ef063dcb1c59c7a8372 Mon Sep 17 00:00:00 2001
From: Karen Zeng <karen.zeng@outlook.com>
Date: Mon, 15 May 2023 14:56:53 -0400
Subject: [PATCH] Saved the df to a HDF5 file

---
 fp2_11.py | 5 +++++
 1 file changed, 5 insertions(+)

diff --git a/fp2_11.py b/fp2_11.py
index 283dbff..1b1ae62 100644
--- a/fp2_11.py
+++ b/fp2_11.py
@@ -189,6 +189,11 @@ while True:
         print(f"no messages, trying again at {time.asctime()}")
         break
 
+df.to_hdf('product1.h5', key='df',mode='w')
+
+# Open the HDF5 file in a separate window
+os.startfile('product1.h5')
+
 # Start receiving messages (async version)
 #flow_control = pubsub_v1.types.FlowControl(max_messages = 1)
 #streaming_pull_future = subscriber.subscribe(subscription_path,