add forcePush argument to insert_all function

databox · Oct 7, 2018 · cb659b4 · cb659b4
1 parent bf73d37
commit cb659b4
Showing 1 changed file with 8 additions and 3 deletions.
diff --git a/databox/__init__.py b/databox/__init__.py
@@ -105,10 +105,15 @@ def push(self, key, value, date=None, attributes=None, unit=None):
 
         return self.last_push_content['id']
 
-    def insert_all(self, rows):
-        self.last_push_content = self._push_json({
+    def insert_all(self, rows, forcePush=None):
+        payload = {
             'data': [self.process_kpi(**row) for row in rows]
-        })
+        }
+
+        if isinstance(forcePush, bool) and forcePush:
+            payload['meta'] = {'ensure_unique': True}
+        self.last_push_content = self._push_json(payload)
+
         return self.last_push_content['id']
 
     def last_push(self, number=1):