Test whether redis works

1 files changed, 13 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)
+