Improve error handling

jertel · May 21, 2020 · a123296 · a123296
1 parent b9f7478
commit a123296
Showing 1 changed file with 15 additions and 14 deletions.
diff --git a/src/vuegraf.py b/src/vuegraf.py
@@ -124,24 +124,25 @@ def lookupChannelName(account, chan):
                 usage = account['vue'].get_usage_over_time(chan, start, account['end'])
                 index = 0
                 for watts in usage:
-                    dataPoint = {
-                        "measurement": "energy_usage",
-                        "tags": {
-                            "account_name": account['name'],
-                            "device_name": chanName,
-                        },
-                        "fields": {
-                            "usage": watts,
-                        },
-                        "time": start + datetime.timedelta(seconds=index)
-                    }
-                    index = index + 1
-                    usageDataPoints.append(dataPoint)
+                    if watts is not None:
+                        dataPoint = {
+                            "measurement": "energy_usage",
+                            "tags": {
+                                "account_name": account['name'],
+                                "device_name": chanName,
+                            },
+                            "fields": {
+                                "usage": watts,
+                            },
+                            "time": start + datetime.timedelta(seconds=index)
+                        }
+                        index = index + 1
+                        usageDataPoints.append(dataPoint)
 
             info('Submitted datapoints to database; account="{}"; points={}'.format(account['name'], len(usageDataPoints)))
             influx.write_points(usageDataPoints)
         except:
-            error('Failed to record new usage data', sys.exc_info()) 
+            error('Failed to record new usage data: {}'.format(sys.exc_info())) 
 
     pauseEvent.wait(INTERVAL_SECS)