summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorHui Lan <lanhui@zjnu.edu.cn>2025-08-06 16:51:44 +0800
committerHui Lan <lanhui@zjnu.edu.cn>2025-08-06 16:51:44 +0800
commitf57f6e3c256db8e160fdf40cbba51180803d3124 (patch)
treeb4db301126bee6528a38412c7c6b95b243a3ca4a
parent67d57d8e1aaff7cc57cd030bdb3349337e7e9092 (diff)
[download_and_map.py] Anything wrong in redis public? Why I cannot see the published data on my subscriber side (Raspberry Pi 5)HEADmaster
-rw-r--r--Code/download_and_map.py13
1 files changed, 8 insertions, 5 deletions
diff --git a/Code/download_and_map.py b/Code/download_and_map.py
index 5ad19cf..6372248 100644
--- a/Code/download_and_map.py
+++ b/Code/download_and_map.py
@@ -392,11 +392,14 @@ def publish(mapped_data_directory):
redis_password = os.getenv('REDIS_PASSWORD', '123456')
r = redis.Redis(host=redis_host, port=6379, password=redis_password, db=0)
for fname in glob.glob('%s/*_quant.txt' % (mapped_data_directory.rstrip('/'))):
- file_basename = os.path.basename(fname)
- with open(fname, 'r') as f:
- data = f.read()
- r.publish(REDIS_CHANNEL, json.dumps({'filename':file_basename, 'data':data}))
- time.sleep(1)
+ try:
+ file_basename = os.path.basename(fname)
+ with open(fname, 'r') as f:
+ data = f.read()
+ r.publish(REDIS_CHANNEL, json.dumps({'filename':file_basename, 'data':data}))
+ time.sleep(1)
+ except Exception as e:
+ r.publish(REDIS_CHANNEL, json.dumps({'filename':'REDIS_ERROR.txt', 'data':str(e)}))
## main