From 5e6561c5a69d4809a477ef9a0b46b4f1d6eaecdd Mon Sep 17 00:00:00 2001
From: MuJ <muji3203380067@outlook.com>
Date: Mon, 26 Feb 2024 22:06:50 +0800
Subject: [PATCH] =?UTF-8?q?=E5=AE=8C=E6=88=90=E7=AC=AC=E4=B8=80=E6=AC=A1?=
 =?UTF-8?q?=E6=B5=8B=E8=AF=95?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 __pycache__/listen.cpython-310.pyc | Bin 2508 -> 2926 bytes
 post.py                            |  65 +++++++++++++++++++++++++----
 test.txt                           |   2 +-
 3 files changed, 57 insertions(+), 10 deletions(-)

diff --git a/__pycache__/listen.cpython-310.pyc b/__pycache__/listen.cpython-310.pyc
index 416cdc823f4a021ecf602c304572ef7a3952e17f..3d58e6f089417eb73c09e9a7bfbae189560b518f 100644
GIT binary patch
delta 563
zcmX9)L2J}N6rMMkPA1ve*jlIx3PY>K&{D0s2zwHx3L?E!kS;<AnOVAa-EAi+EwZJD
zcveb4Jb2hW_aOd{UIb734+Qb%K|$-AY=-yE<D2h&?;~fkKj)%;y&e+$PXB&23-y!e
zDttOwijOtd{#(*wW=e}4YM&WekQO(5=#K~x!(R#e7%{Mq4AVgYt<Z!z+@aY$ylXh|
z(9}>ZN2CDMdy^iO6i5$($|1XfY~A^3*r+O&-(8mV^vmZDKKmFdRX!1S%R|v9PsLLC
zO+1}z;(Nvsq%UFq+}^=9h4P1g`S=00IT@f+LEq0D!2pIZB15XF_D1xGz95=0!bsr(
z8PE-~O0p{ln9iL|EXT!DZ{FcrrJiqhGS%MirFo~{Q`RI}=_F57+xB0pM0NXV(p4+@
zVXoSpt_fXKjQCQirZxG#?KM@F+vUkjHC+wn+h(G7E5=~Q5Lypoug9KU!F$Y{cI;cT
z+f7n~>}_Q2ssmQ;@!7@53AUWsmRr1rFPTJ;{zVAS8J+&esJ&m_3NEQXuuz%Dk-gvy
tt~sC%+)qQ%W-t$|JO~;$uOlIdfXEXKQ4^Ab0FFn%G)OE;`EM!Mum5Z)f<gcQ

delta 236
zcmaDSc1D;lpO=@50SKZz52a>sPvnzfteB{+8IsD9!j{ccWR=R)%n-$z%DRAUAp;{r
zDr**dkqMCGC^Agt1d4JkWN2mtiZeslDeTQm5LLyBKoM?`o)pGlFxKSQcxEm;(*&-`
zxg5rm7Xk54PR+?ooF3MeK<kUyfCLXa52MomA|oL47Ds%1ZenI$e0&v0NosM4UP(oX
zCQlJRP^w54L@<E}qsi~MlqQRE8!E^Exf~1}jC{--CLG*sj2w(?K*+<$$H?}VhlS-Q
E02Y5VDF6Tf

diff --git a/post.py b/post.py
index 842443e..30f6061 100644
--- a/post.py
+++ b/post.py
@@ -1,21 +1,68 @@
 import socket
 import random
 import time
+import pandas as pd
+import numpy as np
+
+def data_clean(data, is_column=False):
+    """_summary_
+
+    Args:
+        data (_type_): csv数据
+        is_column (bool, optional): 清除含有NaN数据的列. Defaults to False.即清除含有NaN数据的行
+
+    Returns:
+        _type_: 清洗过的数据
+    """
+    if not is_column:
+        data = data.dropna(axis=0)
+        return data
+    else:
+        data = data.dropna(axis=1)
+        return data
+      
+def data_load(data_path, is_column=False):
+    """
+    数据加载
+    data_path: 数据路径
+    is_column: 是否是列数据
+    return:X,Y
+    """
+    # 读取csv文件
+    df = pd.read_csv(data_path)
+
+    # 进行数据清洗
+    data_clean(df, is_column)
+    df = df[df['output'] == 1]
+
+    # 去除第一列
+    df = df.drop(df.columns[0], axis=1)
+
+    # 初始化X,Y
+    X= []
+
+    # 遍历DataFrame的每一行
+    for index, row in df.iterrows():
+        # 获取前127个数据项
+        X.append(row.iloc[0:129])
+
+    return np.array(X)
+
+# 输入需要发送的数据
+data = data_load('data\PowerQualityDistributionDataset1.csv')
 
 # 创建一个socket：
 s = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
 # 建立连接:
 s.connect(('localhost', 9996))
 while True:
-    try:
-        # 输入需要发送的数据
-        data = str(random.randint(1, 10))
-        time.sleep(0.1)
-        if data.lower() == 'exit':
+    for i in data:
+      for j in i:
+        try:
+            time.sleep(0.5)
+            # 发送数据:
+            s.send((str(j)).encode())
+        except KeyboardInterrupt:
             break
-        # 发送数据:
-        s.send(data.encode())
-    except KeyboardInterrupt:
-        break
 # 关闭连接
 s.close()
\ No newline at end of file
diff --git a/test.txt b/test.txt
index 4287ca8..e2d5185 100644
--- a/test.txt
+++ b/test.txt
@@ -1 +1 @@
-#
\ No newline at end of file
+#3293.482471
\ No newline at end of file