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

only add if no db for now until tau historical built

Browse source
This commit is contained in:
Nicholas St. Germain 2019-04-29 10:52:45 -05:00
parent 29e4e57e20
commit 1db99a46ed
1 changed files with 6 additions and 7 deletions
Download patch file Download diff file Expand all files Collapse all files

13
varken/dbmanager.py
View file

@ -28,13 +28,12 @@ class DBManager(object):
self.logger.info("Creating varken database")
self.influx.create_database('varken')
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(name='varken 30d-1h', duration='30d', replication='1',
database='varken', default=True, shard_duration='1h')
retention_policies = [policy['name'] for policy in
self.influx.get_list_retention_policies(database='varken')]
if 'varken 30d-1h' not in retention_policies:
self.logger.info("Creating varken retention policy (30d-1h)")
self.influx.create_retention_policy(name='varken 30d-1h', duration='30d', replication='1',
database='varken', default=True, shard_duration='1h')
def write_points(self, data):
d = data