|
|
@@ -12,6 +12,7 @@ from io import BytesIO
|
|
|
import logging
|
|
|
|
|
|
class MchDataCenter(object):
|
|
|
+ latest_delta = 2
|
|
|
pos_map = {
|
|
|
'commit': 0, 'success': 1, 'fail': 2
|
|
|
}
|
|
|
@@ -41,14 +42,15 @@ class MchDataCenter(object):
|
|
|
else:
|
|
|
hfive = h5py.File(self._file_name, 'w')
|
|
|
|
|
|
+ latest_time = int(stime.time()) - self.latest_delta
|
|
|
self.read_redis(hfive, r, 'nc_user_monitor_commit', 'commit')
|
|
|
self.read_redis(hfive, r, 'nc_user_monitor_success', 'success')
|
|
|
self.read_redis(hfive, r, 'nc_user_monitor_fail', 'fail')
|
|
|
hfive.close()
|
|
|
|
|
|
- self.del_redis(r, 'nc_user_monitor_commit')
|
|
|
- self.del_redis(r, 'nc_user_monitor_success')
|
|
|
- self.del_redis(r, 'nc_user_monitor_fail')
|
|
|
+ self.del_redis(r, 'nc_user_monitor_commit',latest_time)
|
|
|
+ self.del_redis(r, 'nc_user_monitor_success',latest_time)
|
|
|
+ self.del_redis(r, 'nc_user_monitor_fail',latest_time)
|
|
|
except Exception as ex:
|
|
|
print(ex)
|
|
|
finally:
|
|
|
@@ -58,8 +60,7 @@ class MchDataCenter(object):
|
|
|
else:
|
|
|
stime.sleep(1)
|
|
|
|
|
|
- def del_redis(self, redis, name):
|
|
|
- latest_time = int(stime.time()) - 2
|
|
|
+ def del_redis(self, redis, name,latest_time):
|
|
|
for item in redis.hscan_iter(name):
|
|
|
key = str(item[0], encoding="utf-8")
|
|
|
items = re.split(r'-', key)
|
stanley-king