if raw_smart_data:
for device, raw_data in raw_smart_data.items():
data = self.extract_smart_features(raw_data)
- self.put_device_metrics(ioctx, device, data)
+ if device and data:
+ self.put_device_metrics(ioctx, device, data)
ioctx.close()
return 0, "", ""
continue
did_device[device] = 1
data = self.extract_smart_features(raw_data)
- self.put_device_metrics(ioctx, device, data)
+ if device and data:
+ self.put_device_metrics(ioctx, device, data)
ioctx.close()
return 0, "", ""
if raw_smart_data:
for device, raw_data in raw_smart_data.items():
data = self.extract_smart_features(raw_data)
- self.put_device_metrics(ioctx, device, data)
+ if device and data:
+ self.put_device_metrics(ioctx, device, data)
ioctx.close()
return 0, "", ""
daemon_type, daemon_id, outb))
def put_device_metrics(self, ioctx, devid, data):
+ assert devid
old_key = datetime.utcnow() - timedelta(
seconds=int(self.retention_period))
prune = old_key.strftime(TIME_FORMAT)