|
@@ -14,7 +14,7 @@ import time as time
|
|
|
|
|
|
|
|
|
class DataCenter(object):
|
|
|
- latest_delta = 2
|
|
|
+ latest_delta = 10
|
|
|
pos_map = {
|
|
|
'commit-succ': 0, 'commit-fail': 1, 'notify-succ': 2, 'notify-fail': 3, 'user_succ': 4
|
|
|
}
|
|
@@ -54,7 +54,7 @@ class DataCenter(object):
|
|
|
except Exception as ex:
|
|
|
print(ex)
|
|
|
finally:
|
|
|
- stime.sleep(0.1)
|
|
|
+ stime.sleep(1)
|
|
|
|
|
|
def del_redis(self, redis, name,latest_time):
|
|
|
for item in redis.hscan_iter(name):
|