2 files changed, 28 insertions, 0 deletions
diff --git a/Code/test_redis_publish.py b/Code/test_redis_publish.py
new file mode 100644
index 0000000..b33ceed
--- /dev/null
+++ b/Code/test_redis_publish.py
@@ -0,0 +1,13 @@
+import os, redis, json, time
+from configure import REDIS_CHANNEL
+
+def publish():
+    redis_host = os.getenv('REDIS_HOST', '127.0.0.1')
+    redis_password = os.getenv('REDIS_PASSWORD', '123456')
+    r = redis.Redis(host=redis_host, port=6379, password=redis_password, db=0)
+    r.publish(REDIS_CHANNEL, json.dumps({'filename':'a.txt', 'data':'123'}))
+
+while True:
+    publish()
+    time.sleep(3)
+    
diff --git a/Code/test_redis_subscribe.py b/Code/test_redis_subscribe.py
new file mode 100644
index 0000000..f38249d
--- /dev/null
+++ b/Code/test_redis_subscribe.py
@@ -0,0 +1,15 @@
+from configure import REDIS_CHANNEL
+import redis # install redis on Ubuntu using this command: sudo apt install python3-redis
+import json
+import os
+
+redis_password = os.getenv('REDIS_PASSWORD', '123456')
+redis_host = os.getenv('REDIS_HOST', '127.0.0.1')
+r = redis.Redis(host=redis_host, port=6379, password=redis_password, db=0)
+pubsub = r.pubsub(ignore_subscribe_messages=True)
+pubsub.subscribe(REDIS_CHANNEL)
+
+for message in pubsub.listen():
+    quant_data = json.loads(message['data'])
+    filename = quant_data['filename']
+    print('[test_redis_subscribe.py] %s - %s.' % (filename, quant_data))