1
+
2
+ from __future__ import print_function
1
3
import argparse
2
4
3
5
from influxdb import InfluxDBClient
@@ -38,7 +40,8 @@ def main(host='localhost', port=8086, nb_day=15):
38
40
},
39
41
}
40
42
series .append (pointValues )
41
- print series
43
+
44
+ print (series )
42
45
43
46
client = InfluxDBClient (host , port , USER , PASSWORD , DBNAME )
44
47
@@ -51,20 +54,20 @@ def main(host='localhost', port=8086, nb_day=15):
51
54
client .create_database (DBNAME )
52
55
53
56
print ("Create a retention policy" )
54
- retention_policy = 'awesome_policy '
57
+ retention_policy = 'server_data '
55
58
client .create_retention_policy (retention_policy , '3d' , 3 , default = True )
56
59
57
60
print ("Write points #: {0}" .format (total_records ))
58
61
client .write_points (series , retention_policy = retention_policy )
59
62
60
63
time .sleep (2 )
61
64
62
- query = "SELECT MEAN(value) FROM %s WHERE time > now() - 10d GROUP BY time(500m)" % (metric )
63
- result = client .query (query , database = DBNAME , raw = False )
64
- print (result )
65
+ query = "SELECT MEAN(value) FROM {} WHERE time > now() - 10d GROUP BY time(500m)" . format (metric )
66
+ result = client .query (query , database = DBNAME )
67
+ print (result )
65
68
print ("Result: {0}" .format (result ))
66
69
67
- print ("Drop database: " + DBNAME )
70
+ print ("Drop database: {}" . format ( DBNAME ) )
68
71
client .drop_database (DBNAME )
69
72
70
73
0 commit comments