|
@@ -121,12 +121,12 @@ class SpeedDataCenter(object):
|
|
|
|
|
|
if len(result) != 0:
|
|
|
r.set(f"nc_channels_speed", json.dumps(result))
|
|
|
- r.publish('refill',json.dumps({'type':'channels_speed','value':0}))
|
|
|
- print('push msg=', result)
|
|
|
+ r.publish('refill', json.dumps({'type': 'channels_speed', 'value': 0}))
|
|
|
+ print(datetime.now(), 'push msg=', result)
|
|
|
except Exception as ex:
|
|
|
print(ex)
|
|
|
finally:
|
|
|
- stime.sleep(0.05)
|
|
|
+ stime.sleep(0.1)
|
|
|
|
|
|
def _parse_path(self,path):
|
|
|
items = re.split(r'/', path)
|