Ik 91Ld Ɉv?- y4 .75s IIk8(jtXpΠ;eb\MЂ_[#T)ަE}'i٠'ɲ[˄`J2NAVclDQ<E. Č;x-|arݒI*Xg|cZ/c焺Obq>8񤑌6T%v$퇟)^/ U1" f:\B^F.X.$#~ ڙT@| +׽v D)MI+$!by#p&rd(T+;^ R8=kӨJјsc뫗 >[|V}O4޾Dt}8fM I`OZ4>ΤkH q e^W4.Xt=:G5z䬝l{" Aj@1 )W>w/̡-#Usxʸ3*#Qv¨FCesf;("4{`D}@(k(#96|[z>#p&rd(T+;^ R8=kӨJјsc뫗 >[|V}O4?"wӊ@hs@v=K<6)mB\ !u}[xB<ȱ'j*:]cL. 1xMG*ߞ10nP7zG#z9;eAUIK >L'OTw5(Hjis0 [ >d2o![>ms2 8 u4LPՇ(DiG|];'|`n^iq#ZXQ'9\X; S#Xt^~ىmB lF <Яߺy &1JNoDHGlG)LDE_@aDȱ[QEю/E " +J=m1$Tq3zFHx]'1@6Vt=B(#/94Z|W[K`Er !销 $yrs\,8n7&10a;WFǮeQ1SX?Y-y;)%qf_6w^%G6RbQ/]7hAo +y Çol"W{UWaQ X}6$Qɬ,"[W{UWaQ +?뇰hz?R]/?+G.<0bHVe6YW{UWaQ 7«=c7C Q>UJ-խuMȯmX`, 2cTj]cwr_'&C?MRE]j7˙r7Za7J^gj Y )h Щk@8_K5GڌDDC MTuLIaXhNBu&I&}"`N?8:vҧ) +Fefn,,7^%%ry3롁BFJ%=W=^݃:Y|F{ix]cX:x) b 1284S/'Z[l\J tc?H5OJ tc?H5OKF Go+Kj+3?$^$ ' + func + ' ' + parm) res = None if func == 'get_memory_usage': data_cnt = 0 mem_size = sys.getsizeof(sensor_data) for s in sensor_data: data_cnt += len(sensor_data[s]) mem_size += sys.getsizeof(sensor_data[s]) res = {'data_cnt': data_cnt, 'mem_usage': mem_size} elif func == 'get_data_single_sensor': t1 = p['start_time'] t2 = p['end_time'] data_cnt = p['data_cnt'] print(' ' + str(t1) + ', ' + str(t1) + ' - ' + str(data_cnt)) dat = [] # data_idx = 0 # data_step = len(sensor_data) / data_cnt data_idx = t1 - sensor_info['start_time'] data_step = (t2 - t1) / data_cnt for i in range(0, data_cnt): dat.append(sensor_data[int(data_idx)]) data_idx += 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'] dat = {} print(' ' + str(t1) + ', ' + str(t1) + ' - ' + str(data_cnt)) for s_pid in sensor_info.keys(): if 'start_time' in sensor_info[s_pid].keys(): data_idx = t1 - sensor_info[s_pid]['start_time'] 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 dat_single.append(val) data_idx += data_step 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() asyncio.run(run_server())