import requests
import pandas as pd
def getDtu(dtuid,addr):
sqlData = '{ "sql":"select * from dtu where dtuid=\'%s\' and addr=\'%s\' order by DTUTIME desc", "project":"yongli" , "offset":0, "limit":100}' %(dtuid, addr)
response = requests.post(url = 'https://kylin1.wdp:7070/kylin/api/query',
data = sqlData,
auth = ('admin', 'admin'),
headers = {"Content-Type":"application/json"})
dfCols = pd.DataFrame(response.json()["columnMetas"])
df = pd.DataFrame(response.json()["results"], columns=dfCols["label"].values)
values = pd.DataFrame({ 'dtutime': df["DTUTIME"].map(pd.Timestamp),
addr: df["DTUVALUE"]})
return values
getDtu('8627427973', '1800')import requests
import panda