wisetop/controller-data-analysis
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

-update selection

Browse Source
This commit is contained in:
peterlu14
2023-03-23 12:58:09 +08:00
parent 4a214100f6
commit fe2e95399d
1 changed files with 24 additions and 17 deletions
Download Patch File Download Diff File Expand all files Collapse all files
new/callback_func.py
+24 -17
View File
@@ -57,25 +57,32 @@ async def async_callback(topic, payload, conn, client):
with ProcessPoolExecutor() as executor:
channelX = meta['channel'][0]
channelY = meta['channel'][1]
for meta_id, result in zip(meta['id'], executor.map(VTmode_run, [[meta_data[meta_id][channelX],meta_data[meta_id][channelY],analysis_pattern['parameter']['percentage']] for meta_id in meta['id']])):
print('result', meta_id, result)
if analysis_pattern['id'] == 0:
for meta_id in meta['id']:
data = [meta_id, meta_data[meta_id][channelX], meta_data[meta_id][channelY]]
# mqtt publish data
await client.publish("data_analysis", data)
elif analysis_pattern['id'] == 1:
for meta_id, result in zip(meta['id'], executor.map(VTmode_run, [[meta_data[meta_id][channelX],meta_data[meta_id][channelY],analysis_pattern['parameter']['percentage']] for meta_id in meta['id']])):
print('result', meta_id, result)
# do analysis function
# result, csv_data = VTmode_run(x_data, y_data, analysis_pattern['parameter']['percentage'])
data = [meta_id, meta_data[meta_id][channelX], meta_data[meta_id][channelY], *result[0]]
# do analysis function
# result, csv_data = VTmode_run(x_data, y_data, analysis_pattern['parameter']['percentage'])
data = [meta_id, meta_data[meta_id][channelX], meta_data[meta_id][channelY], *result[0]]
# mqtt publish data
await client.publish("data_analysis", data)
# mqtt publish data
await client.publish("data_analysis", data)
# # create dict writer
# fieldnames = list(csv_data.keys())
# dict_writer = csv.DictWriter(csvfile, fieldnames=fieldnames)
# # create dict writer
# fieldnames = list(csv_data.keys())
# dict_writer = csv.DictWriter(csvfile, fieldnames=fieldnames)
# # write data header
# if not write_header_done:
# dict_writer.writeheader()
# write_header_done = True
# # write data header
# if not write_header_done:
# dict_writer.writeheader()
# write_header_done = True
# # write data
# dict_writer.writerow(csv_data)
# # write data
# dict_writer.writerow(csv_data)
print("執行時間：%f 秒" % (time.time() - start_time))