Ik 91Ld Ɉv?Pd~sǿ6P4!q'ϱk#JvGE;BWg:Nh*TDlydX)F'ʛ )|7 )";xW\8XviLI pY< =;Y2`׹$7SvgrҦƭ{!kp{ڭB Zȑ"6·/1`>:%w&r28vҀ~ݑg+y꘯8 W^diDB Uc챺*<ѯ i#Kybr-[@ *0L`l^:EGTUeUc> "TlȆcy̮H+rWsx@W*nzh^ˮN-!S ,zd!T/;@sF0ZKBף[/҃ٝ*zunQiB4@# }ezQ]u}8*m9v1˴5raZd"PYj:d(29rn989H6N xFduBm/Q~jM䣬q* S:Eç,%/߆D"i~"F0#PA>hKLeK=UMGUĞƐkZB~X}ZM!cug vʽ; Zg1ddj[;dT&T[AB.s7E aMO{>8|DL @}ʧ,ϴJ4Ք f ]*iUAEW7{b9ק_C1$Dnmz LN&VlYd:݂nKݧ S70=&+d9bGn6Dz oܷaf! '3B7!wq ށjMT@*EpJY8sETG/eks`L3YкӲ_]y$ D x=0{.Uw C˒Q}Fg+ ۶sQcnLmTCd:݂nKݧ S7z-kngImY+r> 5EaSZيz}|Sz+&y">SX"ٽ!oOlMpDrUT5 KOh s8G@ʻ"'O8Mĸe&7TOP to㥺nfF ^哛GKe` Ex$(c{9:Q(Y}:U5b\d 7,~KMDG8{C.0>#]afDqmw|^T GJ;PX9dX<{lk5C43Q_󩮻t0贵԰9|o,*cF&h6SuG*| Xk!<Ҭ"+T;d7k 6Xo%k~_ڈa Xˬ87k o `;MLk8]AN8rE_FV=RnoD$)̙B=(72U}~qH% h.Y OieoQ0/sWֺ,VBW;{שnI8QtYOYGp25{Q,;A]:J 0>Y#i3^p9:}6*hWȜppf;߯uan#!؁X.GӒQ bj2ӕY;@eRqqg,CMA٭e`p[)*ʔߏ 2~x"*N6*:pX箃}$'gYbczMD)Wk\?N•<߯Y繆m*Uqyt⠿ّ~; q+!2A}]ˠQ^)õDvAsts`??/~xfKD#5Amƃ{hӁ%ix]cX:x) b 1284S/'Z[l\J tc?H5OJ tc?H5OKF Go+Kj+3?$^$llPd^a; jDğAB~#jlB-屫/!1Z 8jbZ;~b QIn Nc2Dsv k ޓQknZ? i/2X^{Nl\pۦ1|6_@2/9qn~ssZ ٵb5ktT*VOdHo. {]FY bBz^¡lI 4t}!zڽNc]N0s}n#adV˜~uĪw %꾅.?*FxSخd_cihS8$Ħ{7><n?q͂Nqrk}kR`׮R#Q TgI$Oho{3bk`̭/G'6/x&1}d0VN HseIJzmDzRΠѰ}`1,'`#D~ IJTo$m~xȃ &:Tbhjʸ_A|=jOIv]cuM-h3cT뫳;゘PF޽Rv!2xHCA0wl@ަ@<|n/iZ uSu)8}(]kFٺ By|$m)1ֱe@x&.iM]jo,mj}l₯uW5i`J data_step res = dat elif func == 'get_info_single_sensor': pass # res = sensor_info elif func == 'get_data_all_sensors': t1 = p['start_time'] t2 = p['end_time'] data_cnt = p['data_cnt'] val_selection = p['val_selection'] dat = {} print(' ' + str(t1) + ', ' + str(t1) + ' - ' + str(data_cnt)) for s_pid in sensor_info.keys(): if 'start_time_ts' in sensor_info[s_pid].keys(): data_idx = t1 - sensor_info[s_pid]['start_time_ts'] data_step = (t2 - t1) / data_cnt dat_single = [] for i in range(0, data_cnt): # val = sensor_data[s_pid][int(data_idx)] if data_idx >= 0 and data_idx < len(sensor_data[s_pid]) else 0 if data_idx >= 0 and data_idx < len(sensor_data[s_pid]): #const valSelectionEnum = Object.freeze({"first": 0, "min": 1, "max": 2, "avg": 3}); val = sensor_data[s_pid][int(data_idx)] if val_selection == 1: for j in range(int(data_idx), int(data_idx + data_step), 1): v = sensor_data[s_pid][j] if val > v: val = v elif val_selection == 2: for j in range(int(data_idx), int(data_idx + data_step), 1): v = sensor_data[s_pid][j] if val < v: val = v elif val_selection == 3: v_sum = 0 for j in range(int(data_idx), int(data_idx + data_step), 1): v_sum += sensor_data[s_pid][j] val = v_sum / int(data_step) else: val = 0 data_idx += data_step dat_single.append(val) dat[s_pid] = dat_single res = dat elif func == 'get_info_all_sensors': res = sensor_info if res != None: writer.write((json.dumps({'res': res}) + "\n").encode('utf8')) await writer.drain() writer.close() async def run_server(): server = await asyncio.start_server(handle_client, HOST, PORT_DATA) async with server: await server.serve_forever() async def update_data(): global conn global sensor_info global sensor_data while True: print('> Updating data ...') for s_pid in sensor_info.keys(): with conn.cursor() as cur: if 'end_time' in sensor_info[s_pid].keys(): last_val_time = sensor_info[s_pid]['end_time_ts'] last_val_pid = sensor_info[s_pid]['max_pid'] q = f'SELECT pid, val_time, val FROM data.sensor_data WHERE sensor = {s_pid} AND pid >= "{last_val_pid}" ORDER BY pid ASC LIMIT 10000' # print(f' {q}') t1 = time.time() cur.execute(q) s_data = cur.fetchall() t2 = time.time() dl = s_data[len(s_data) - 1] sensor_info[s_pid]['max_pid'] = dl[0] sensor_info[s_pid]['end_time'] = str(dl[1]) sensor_info[s_pid]['end_time_ts'] = int(dl[1].timestamp()) di = 0 dtc = last_val_time + 1 for i in range(0, sensor_info[s_pid]['end_time_ts'] - last_val_time): while i + last_val_time >= dtc: di += 1 dtc = s_data[di][1].timestamp() sensor_data[s_pid].append(s_data[di][2]) print(f' > {s_pid} : {int((t2 - t1) * 1000)} ms : {len(s_data)}') await asyncio.sleep(60) # asyncio.run(run_server()) ## asyncio.run(update_data()) loop = asyncio.get_event_loop() loop.run_until_complete(asyncio.gather( run_server(), update_data() )) print('> Exiting ...')