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,