Commit da8f5bce authored by 王志伟's avatar 王志伟
parents 678ea434 510eb6f9
...@@ -7,7 +7,8 @@ import datetime ...@@ -7,7 +7,8 @@ import datetime
my_sender='gaoyazhe@igengmei.com' my_sender='gaoyazhe@igengmei.com'
my_pass = 'VCrKTui99a7ALhiK' my_pass = 'VCrKTui99a7ALhiK'
my_user='gaoyazhe@igengmei.com' my_user1='gaoyazhe@igengmei.com'
my_user2='zhangyanzhao@igengmei.com'
def mail(): def mail():
ret=True ret=True
try: try:
...@@ -15,11 +16,11 @@ def mail(): ...@@ -15,11 +16,11 @@ def mail():
stat_data = f.read() stat_data = f.read()
msg=MIMEText(stat_data,'plain','utf-8') msg=MIMEText(stat_data,'plain','utf-8')
msg['From']=formataddr(["高雅喆",my_sender]) msg['From']=formataddr(["高雅喆",my_sender])
msg['To']=formataddr(["高雅喆",my_user]) msg['To']=my_user1 + ',' + my_user2
msg['Subject']= str(datetime.date.today())+"-esmm多目标模型训练指标统计" msg['Subject']= str(datetime.date.today())+"-esmm多目标模型训练指标统计"
server=smtplib.SMTP_SSL("smtp.exmail.qq.com", 465) server=smtplib.SMTP_SSL("smtp.exmail.qq.com", 465)
server.login(my_sender, my_pass) server.login(my_sender, my_pass)
server.sendmail(my_sender,[my_user,],msg.as_string()) server.sendmail(my_sender,[my_user1,my_user2],msg.as_string())
server.quit() server.quit()
except Exception: except Exception:
ret=False ret=False
......
...@@ -22,18 +22,25 @@ def normal(): ...@@ -22,18 +22,25 @@ def normal():
db = pymysql.connect(host='10.66.157.22', port=4000, user='root', passwd='3SYz54LS9#^9sBvC', db='jerry_test') db = pymysql.connect(host='10.66.157.22', port=4000, user='root', passwd='3SYz54LS9#^9sBvC', db='jerry_test')
sql = "select * from device_read_time" sql = "select * from device_read_time"
df = con_sql(db, sql) df = con_sql(db, sql)
df = df.rename(columns={0:"device_id",1:"0",2:"1",3:"10",4:"1024",5:"1080",6:"11", df = df.rename(columns={0:"device_id",1:"kongbai",2:"eye",3:"simi",4:"zitizhifang",5:"banyongjiu",6:"teeth",
7:"12",8:"13",9:"2",10:"2054",11:"2214",12:"3",13:"4",14:"5",16:"6933", 7:"kouchun",8:"ear",9:"nose",10:"banyongjiuzhuang",11:"qita",12:"lunkuo",
17:"7",18:"9",19:"922",20:"929",21:"971",22:"992"}) 13:"shoushen",14:"skin",16:"shenghuo",
device_id = df[["device_id"]] 17:"breast",18:"hair",19:"kangshuai",20:"shili",21:"chanhou",22:"zhushe"})
df = df.drop("device_id",axis=1) # device_id = df[["device_id"]]
minMax = MinMaxScaler() # df = df.drop("device_id",axis=1)
result = pd.DataFrame(minMax.fit_transform(df),columns=["0","1","10","1024","1080","11", # minMax = MinMaxScaler()
"12","13","2","2054","2214","3","4","5","6933", # result = pd.DataFrame(minMax.fit_transform(df),columns=["0","1","10","1024","1080","11",
"7","9","922","929","971","992"]) # "12","13","2","2054","2214","3","4","5","6933",
result = device_id.join(result) # "7","9","922","929","971","992"])
# result = device_id.join(result)
l = list(df.columns)
l.remove("device_id")
df["sum"] = df.sum(axis=1)
for i in l:
df[i] = df[i]/df["sum"]
df = df.drop("sum",axis=1)
yconnect = create_engine('mysql+pymysql://root:3SYz54LS9#^9sBvC@10.66.157.22:4000/jerry_test?charset=utf8') yconnect = create_engine('mysql+pymysql://root:3SYz54LS9#^9sBvC@10.66.157.22:4000/jerry_test?charset=utf8')
pd.io.sql.to_sql(result, "device_read_time_normal", yconnect, schema='jerry_test', if_exists='fail', index=False) pd.io.sql.to_sql(df, "device_read_time_normal", yconnect, schema='jerry_test', if_exists='fail', index=False)
if __name__ == "__main__": if __name__ == "__main__":
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment