liuwei_x_x/abot
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

debug 入库

Browse Source
This commit is contained in:
liuwei
2025-02-05 13:35:14 +08:00
parent 451f885f2d
commit 4c13b552d8
1 changed files with 1 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
message_report/write_db.py
View File

@@ -25,7 +25,7 @@ def write_to_db():
# 遍历Redis中所有与昨天日期相关的key，并写入数据库 # 遍历Redis中所有与昨天日期相关的key，并写入数据库
for key in r.keys(f"*:*:{yesterday}:count"): for key in r.keys(f"*:*:{yesterday}:count"):
print('user key：{key}') print('user key：'+ key)
parts = key.decode('utf-8').split(':') parts = key.decode('utf-8').split(':')
group_id, wx_id, _date = parts[0], parts[1], parts[2] # _date应该是yesterday，但这里为了完整性还是保留 group_id, wx_id, _date = parts[0], parts[1], parts[2] # _date应该是yesterday，但这里为了完整性还是保留
count = int(r.hget(key, 'count')) if isinstance(r.hget(key, 'count'), bytes) else 0 # 处理可能的None或空值情况 count = int(r.hget(key, 'count')) if isinstance(r.hget(key, 'count'), bytes) else 0 # 处理可能的None或空值情况