d_mcknight/Varken
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

fixes #129

Browse source
This commit is contained in:
Nicholas St. Germain 2019-04-29 10:25:06 -05:00
parent 03e67b8759
commit e44ddefb43
1 changed files with 6 additions and 2 deletions
Download patch file Download diff file Expand all files Collapse all files

8
varken/dbmanager.py
View file

@ -28,8 +28,12 @@ class DBManager(object):
self.logger.info("Creating varken database")
self.influx.create_database('varken')
self.logger.info("Creating varken retention policy (30d/1h)")
self.influx.create_retention_policy('varken 30d/1h', '30d', '1', 'varken', False, '1h')
retention_policies = [policy['name'] for policy in self.influx.get_list_retention_policies(database='varken')]
# Fix name bug by adding retention policy retroactively
if 'varken 30d-1h' not in retention_policies:
self.logger.info("Creating varken retention policy (30d-1h)")
self.influx.create_retention_policy('varken 30d-1h', '30d', '1', 'varken', False, '1h')
def write_points(self, data):
d = data