Merge pull request #327 from filippog/statsd_pipeline

statsd: use pystatsd pipeline to send batches
python-diamond · Nov 27, 2015 · e005666 · e005666
2 parents 2755eda + 48b5cc5
commit e005666
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/src/diamond/handler/stats_d.py b/src/diamond/handler/stats_d.py
@@ -135,6 +135,8 @@ def _send(self):
                     statsd.Counter(prefix, self.connection).increment(
                         name, value)
 
+        if hasattr(statsd, 'StatsClient'):
+            self.connection.send()
         self.metrics = []
 
     def flush(self):
@@ -152,7 +154,7 @@ def _connect(self):
             self.connection = statsd.StatsClient(
                 host=self.host,
                 port=self.port
-            )
+            ).pipeline()
         else:
             # Create socket
             self.connection = statsd.Connection(