Added missing database in params.

gallir · gallir · commit 3a08029cf3da · 2015-08-15T22:08:54.000+02:00
Receive an unique point and add it to a list in data["points"] (although it's an unnecesary overhead)
diff --git a/influxdb/client.py b/influxdb/client.py
@@ -242,7 +242,7 @@ def request(self, url, method='GET', params=None, data=None,
         else:
             raise InfluxDBClientError(response.content, response.status_code)
 
-    def write(self, data, params=None, expected_response_code=204):
+    def write(self, point, params={}, expected_response_code=204):
         """Write data to InfluxDB.
 
         :param data: the data to be written
@@ -256,6 +256,11 @@ def write(self, data, params=None, expected_response_code=204):
         :rtype: bool
         """
 
+        data = {"points": [point] }
+
+        if not 'db' in params:
+            params['db'] = self._database
+
         headers = self._headers
         headers['Content-type'] = 'application/octet-stream'
 
