|
@@ -48,8 +48,11 @@ def main():
|
|
|
values = redis_helper.get_data_zset_with_index(read_key, 0, -1, True, True)
|
|
|
print(str(read_key))
|
|
|
print(str(values))
|
|
|
+ new_kvs = {}
|
|
|
+ for k, v in values:
|
|
|
+ new_kvs[k] = v
|
|
|
write_key = "recall:item:score:region:h:{}:data66:rule66:{}:{}".format(code, date_next, hour_next)
|
|
|
- redis_helper.add_data_with_zset(write_key, set(values))
|
|
|
+ redis_helper.add_data_with_zset(write_key, new_kvs)
|
|
|
print(str(write_key))
|
|
|
break
|
|
|
|