i connecting influxdb through python , read database. use client.query(query) data database. after data gets erased influxdb. have idea why lose data in influxdb database? code given below
import time import datetime influxdb import influxdbclient import numpy np start_time = time.time() host='localhost' port=8086 user = '' password = '' dbname = 'db' client = influxdbclient(host, port, user, password, dbname) query4 = 'select * rawdata order time asc limit 1 ;' result4 = client.query(query4) initialdate = result4.raw['series'][0]['values'][0][0][0:10] finaldate=datetime.datetime.strptime(initialdate, "%y-%m- %d")+datetime.timedelta(days=7) query = 'select count(*) rawdata' result = client.query(query) length=result.raw['series'][0]['values'][0][1] count=0 list = set() finaldata = {} while(count*1000000<length): query2 = 'select * rawdata limit 1000000 '+'offset '+ str(count*1000000) result2 = client.query(query2) count=count+1 if ("series" not in result2.raw.keys()): continue temp = result2.raw['series'][0]['values'] print(len(temp)) data = [temp[i] in range(len(temp)) if (temp[i][4] != '0' , temp[i][0]<=str(finaldate))] in range(len(data)): list.add(data[i][3] + ' ' + data[i][4]) in range(len(data)): if (data[i][3] + ' ' + data[i][4]) in finaldata.keys(): if data[i][1] in finaldata[data[i][3] + ' ' + data[i][4]].keys(): finaldata[data[i][3] + ' ' + data[i][4]][data[i] [1]].append((data[i][0], data[i][2])) else: finaldata[data[i][3] + ' ' + data[i][4]].update({data[i][1]: [(data[i][0], data[i][2])]}) else: finaldata[data[i][3] + ' ' + data[i][4]] = {data[i][1]: [(data[i][0], data[i][2])]} np.save('my_file2.npy', finaldata)
Comments
Post a Comment