We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent dae6a8a commit 7fae65fCopy full SHA for 7fae65f
influxdb/client.py
@@ -390,21 +390,25 @@ def _write_points(self,
390
'points': points
391
}
392
393
+ if tags:
394
+ data['tags'] = tags
395
+
396
+ params = {
397
+ 'db': database or self._database
398
+ }
399
400
if time_precision:
- data['precision'] = time_precision
401
+ params['precision'] = time_precision
402
403
if retention_policy:
- data['retentionPolicy'] = retention_policy
-
- if tags:
- data['tags'] = tags
404
+ params['rp'] = retention_policy
405
406
if self.use_udp:
407
self.send_packet(data)
408
else:
409
self.write(
410
data=data,
- params={'db': database or self._database},
411
+ params=params,
412
expected_response_code=204
413
)
414
0 commit comments