PredixClient/util.py at master · HAK-CODE/PredixClient · GitHub

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
import json
import inspect


def get_subtraction(data_dict1, data_dict2):
    return [[x1[0], x1[1] - x2[1]] for (x1, x2) in zip(data_dict1, data_dict2)]


def get_perc_conversion(data_values1, data_values2, data_values3):
    return [[x1[0], (x1[1] - x2[1]) / x3[1]] for (x1, x2, x3) \
            in zip(data_values1, data_values2, data_values3)]


def parse_data_reon(data, tag=None):
    format = {"response": {'tag': None, 'results': []}}
    if inspect.stack()[1][3] == 'get_aggregated_day':
        for i in data:
            format['response']['tag'] = i['tags'][0]['name']
            format['response']['results']. \
                append(i['tags'][0]['results'][0]['values'][0]
                       if len(i['tags'][0]['results'][0]['values']) != 0 else [])
        return json.dumps(format)
    elif inspect.stack()[1][3] == 'get_aggregated_month' or \
            inspect.stack()[1][3] == 'get_aggregated_week' or \
            inspect.stack()[1][3] == 'get_aggregated':
        format['response']['tag'] = tag
        format['response']['results'] = data
        return json.dumps(format)
    elif inspect.stack()[1][3] == 'get_aggregated_year':
        copyData = list(data)
        copyData.reverse()
        format['response']['tag'] = tag
        format['response']['results'] = copyData
        return json.dumps(format)

def parse_data(data,tag):
    res=[]
    json_object={}
    tem={}
    for key,i in enumerate(data):
        res.append(i)
    json_object.update({"results": res})
    tem.update({"response":json_object})
    tem['response']['tag']=tag
    return (tem)

def get_values(data):
    return data["tags"][0].get('results')[0].get('values')

def parse_data_latest(data):
    json_object={}
    tem={}
    json_object.update({'tag' : data["tags"][0].get('name')})
    json_object.update({'results': get_values(data)})
    tem.update({"response":json_object})
    return (tem)


def parse_data_zeroslen(data):
    return {
        'tag': data["tags"][0].get('name'),
        'results': len(data["tags"][0]["results"][0]["values"])
    }