diff --git a/Zmq/filterProcess.py b/Zmq/filterProcess.py index 58d8209..02175ed 100644 --- a/Zmq/filterProcess.py +++ b/Zmq/filterProcess.py @@ -175,7 +175,7 @@ class SlidingFilter(threading.Thread): continue filtered_data = self._filter_window_data(window_data) - algo_log(f"滤波后{filtered_data.shape}数据", level='debug') + # algo_log(f"滤波后{filtered_data.shape}数据", level='debug') if self.filter_result_callback is not None: self.filter_result_callback(filtered_data[:64, :]) diff --git a/Zmq/zmqServer.py b/Zmq/zmqServer.py index af5a2c6..940ccee 100644 --- a/Zmq/zmqServer.py +++ b/Zmq/zmqServer.py @@ -176,7 +176,7 @@ class zmqServer(threading.Thread): # 转置为上位机需要的[50, 通道数]格式 filtered_data = filtered_data.T.astype(np.float64) send_buf = filtered_data.tobytes() - algo_log(f"发送滤波数据,长度: {len(send_buf)}字节, filtered_data.shape: {filtered_data.shape}", level="DEBUG") + algo_log(f"发送滤波数据,长度: {len(send_buf)}字节, filtered_data.shape: {filtered_data.shape}", level="DEBUG", record_once=True) self.data_send_queue.put(send_buf) def _process_data_send_queue(self): @@ -193,7 +193,7 @@ class zmqServer(threading.Thread): b"", send_buf ]) - algo_log(f"发送滤波数据成功,长度: {len(send_buf)}字节", level="DEBUG") + algo_log(f"发送滤波数据成功,长度: {len(send_buf)}字节", level="DEBUG", record_once=True) except Exception as e: algo_log(f"发送滤波数据失败: {e}", level="ERROR") @@ -322,7 +322,7 @@ class zmqServer(threading.Thread): def detect_event(self, samples): self.pack_contain_event = False # 第65通道为事件通道 - events = np.array(samples[-2])[0].tolist() + events = samples[-2].tolist() for idx, event in enumerate(events): if int(event) in self.events: new_key = "".join(