import jsonimport datetimeimport requests, osfrom influxdb import InfluxDBClientDataBasename = "test"conn_db = InfluxDBClient('10.26.5.35', '8086', 'lixx', '12xx456', DataBasename)#conn_db.create_database('testdb') #创立数据库print(conn_db.get_list_database()) #显示所有数据库名称#conn_db.drop_database('testdb') #删除数据库#print("##test delet after:", conn_db.get_list_database())json_body = [ { "measurement": "ipad_electricitytable", "tags": { "ip": "10.31.140.24", "device_id": "sn:222ss222test", "device_type": "ipad" }, "fields": {"electricity": 79} }]conn_db.write_points(json_body) #写入数据,同时创立表result = conn_db.query('select * from ipad_electricitytable;') ##selectprint("Result: {0}".format(result))#conn_db.query('drop measurement students') #删除表result = conn_db.query("show measurements") #显示数据库中的表print("Result: {0}".format(result))#5、更新#tags和timestamp雷同时数据会笼罩操作,相当于influxDB的更新操作#6、删除#应用influxql语句实现,delete语法,示例如下"#conn_db.query('delete from ipad_electricitytable;') #删除数据