|
|
@@ -16,7 +16,7 @@ redis_helper = RedisHelper()
|
|
|
def main():
|
|
|
log_.info("开始执行:" + datetime.now().strftime("%Y-%m-%d %H:%M:%S"))
|
|
|
#1 读取当前时间及上一时间
|
|
|
- now_date = datetime.today() - timedelta(hours=1)
|
|
|
+ now_date = datetime.today()# - timedelta(hours=1)
|
|
|
hour = datetime.strftime(now_date, '%H').lstrip('0')
|
|
|
date = datetime.strftime(now_date, '%Y%m%d')
|
|
|
if hour == "":
|
|
|
@@ -45,9 +45,14 @@ def main():
|
|
|
for _, code in REGION_CODE.items():
|
|
|
read_key = "recall:item:score:region:h:{}:data66:rule66:{}:{}".format(code, date, hour)
|
|
|
keys.append(read_key)
|
|
|
+ values = redis_helper.get_data_zset_with_index(read_key, 0, -1, True, True)
|
|
|
+ print(str(read_key))
|
|
|
+ print(str(values))
|
|
|
write_key = "recall:item:score:region:h:{}:data66:rule66:{}:{}".format(code, date_next, hour_next)
|
|
|
- value = redis_helper.get_data_zset_with_index(read_key, 0, -1, True, True)
|
|
|
- print(str(value))
|
|
|
+ redis_helper.add_data_with_zset(write_key, set(values))
|
|
|
+ print(str(write_key))
|
|
|
+ break
|
|
|
+
|
|
|
|
|
|
# records_process_for_list(result, process_and_store, max_size=50, num_workers=8)
|
|
|
log_.info("完成执行:" + datetime.now().strftime("%Y-%m-%d %H:%M:%S"))
|
zhangbo