Batch points, emit server errors.

wlanslovenija · Jun 22, 2017 · 86c8363 · 86c8363
1 parent 0808692
commit 86c8363
Showing 1 changed file with 6 additions and 3 deletions.
diff --git a/datastream/backends/influxdb.py b/datastream/backends/influxdb.py
@@ -1277,9 +1277,12 @@ def _append_multiple(self, datapoints, raw=False):
 
         if points:
             try:
-                self._influxdb.write_points(points)
-            except influxdb.exceptions.InfluxDBServerError:
-                raise exceptions.StreamAppendFailed
+                self._influxdb.write_points(
+                    points=points,
+                    batch_size=1000,
+                )
+            except influxdb.exceptions.InfluxDBServerError as error:
+                raise exceptions.StreamAppendFailed(error.content)
 
             self._backprocess_streams(stream_ids, grouped_datapoints)