From d1de51f5b8cdc8ef5551c1c1e09b8fcd6941dc33 Mon Sep 17 00:00:00 2001 From: Bar Nehemia Date: Thu, 2 Jun 2022 16:52:40 +0300 Subject: [PATCH] influx: Add retention policy. You can now add metrics to a specific retention policy and not only to the default one - that called "autogen". --- pyformance/reporters/influx.py | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/pyformance/reporters/influx.py b/pyformance/reporters/influx.py index 2b74170..2f37a87 100644 --- a/pyformance/reporters/influx.py +++ b/pyformance/reporters/influx.py @@ -42,6 +42,7 @@ def __init__( protocol=DEFAULT_INFLUX_PROTOCOL, autocreate_database=False, clock=None, + retention_policy="autogen", ): super(InfluxReporter, self).__init__(registry, reporting_interval, clock) self.prefix = prefix @@ -53,6 +54,7 @@ def __init__( self.server = server self.autocreate_database = autocreate_database self._did_create_database = False + self.retention_policy = retention_policy def _create_database(self): url = "%s://%s:%s/query" % (self.protocol, self.server, self.port) @@ -94,7 +96,7 @@ def report_now(self, registry=None, timestamp=None): line = "%s %s %s" % (table, values, timestamp) post_data.append(line) post_data = "\n".join(post_data) - path = "/write?db=%s&precision=s" % self.database + path = "/write?db=%s&precision=s&rp=%s" % (self.database, self.retention_policy) url = "%s://%s:%s%s" % (self.protocol, self.server, self.port, path) request = Request(url, post_data.encode("utf-8")) if self.username: