From 81563cdb647b8de014a59fdc7e17fcd5ebf4be6c Mon Sep 17 00:00:00 2001
From: mjkwiatkowski <mati.rewa@gmail.com>
Date: Tue, 23 Jun 2026 13:31:05 +0200
Subject: feat: managed to successfully run experiment I

---
 python_scripts/monitor.py | 24 ------------------------
 1 file changed, 24 deletions(-)
 delete mode 100644 python_scripts/monitor.py

(limited to 'python_scripts/monitor.py')

diff --git a/python_scripts/monitor.py b/python_scripts/monitor.py
deleted file mode 100644
index 23b8c2c4..00000000
--- a/python_scripts/monitor.py
+++ /dev/null
@@ -1,24 +0,0 @@
-import redis
-from redis import Redis
-from redis_streams.consumer import Consumer
-
-STREAM="postgres_topic"
-GROUP="python_consumer"
-
-# It is crucial to enable "decode_response" feature of Redis
-redis_conn = Redis(decode_responses=True)
-consumer = Consumer(
-        redis_conn=redis_conn,
-        stream=STREAM,
-        consumer_group=GROUP,
-        batch_size=10,
-        max_wait_time_ms=30000
-    )
-
-
-while True:
-    messages = consumer.get_items()
-    total_no_of_messages = len(messages)
-    for i, item in enumerate(messages):
-        print(f"Pocessing {i}/{total_no_of_messages} message:{item}")
-        consumer.remove_item_from_consumer_group(item_id=item.msgid)
-- 
cgit v1.2.3