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: