From d03320352e3b34f2601aa8af9fd800a27c1adada Mon Sep 17 00:00:00 2001
From: zmc <zmc_li@foxmail.com>
Date: 星期五, 22 十二月 2023 15:42:57 +0800
Subject: [PATCH] 1.修改了创建连接数据库引擎时的方言类型 2.修改了爬取数据的逻辑以及相关的异常分析代码
---
src/write_to_MySql.py | 15 +++++++++------
1 files changed, 9 insertions(+), 6 deletions(-)
diff --git a/src/write_to_MySql.py b/src/write_to_MySql.py
index 445a007..20161e9 100644
--- a/src/write_to_MySql.py
+++ b/src/write_to_MySql.py
@@ -7,7 +7,6 @@
from datetime import datetime, timedelta
import sys
-# sys.path.append('D:\\z\workplace\\VsCode\\pyvenv\\venv')
sys.path.append('../../')
import src.core_modules.remove_duplicates_methods as rdm
@@ -107,7 +106,7 @@
temp=[]
temp.append(item[2]) #璁惧缂栧彿
temp.append('璁惧鏁呴殰') #璁惧缂栧彿
- temp.append('1') #璁惧鏁呴殰
+ temp.append('1') #渚涚數寮傚父
temp.append('寰愭眹鍖�')
temp.append(item[11]) #鏁呴殰寮�濮嬫椂闂�
startTimeSub= datetime.strptime(startTime,"%Y-%m-%d %H:%M") - timedelta(minutes = 10) #缁撴灉涓篸atetime.datetime绫诲瀷 锛岄渶瑕佸啀杞负瀛楃涓茬被鍨�
@@ -178,6 +177,7 @@
for i in power_supply_abnormal :
print(i)
+
#灏嗕緵鐢靛紓甯哥殑淇℃伅鍐欏叆鏁版嵁搴撳紓甯歌〃涓�
abnormal_write_to_SQL(power_supply_abnormal,con) #灏嗚澶囨晠闅滀俊鎭啓鍏ュ紓甯歌〃
print('渚涚數寮傚父鐨勪俊鎭啓鍏ュ紓甯歌〃瀹屾垚!')
@@ -314,9 +314,12 @@
def refind_ea(list): #涓�鏉¤褰曪紝涔熷氨鏄竴涓垪琛�
temp=[]
temp.append(generate_short_uuid())
+ # 璁惧缂栧彿
temp.append(list[2])
+ # 搴楅摵鍚嶅瓧
temp.append(list[1])
- temp.append(list[0])
+ # 渚涘簲鍟�
+ temp.append(list[3])
temp.append(1)
print(temp)
return temp
@@ -388,7 +391,7 @@
temp.append(list[7]) #鍑�鍖栧櫒鐢垫祦 7
temp.append(list[4]) #杩涙补鐑熸祿搴﹀��
temp.append(list[5]) #鎺掓补鐑熸祿搴﹀��
- temp.append(list[14]) #閲嶅鐨勬鏁�
+ temp.append(list[13]) #閲嶅鐨勬鏁�
print(temp)
return temp
@@ -434,12 +437,12 @@
Key_period_night_end = datetime.strptime('21:00',"%H:%M")
-engine = create_engine("mysql+mysqlconnector://root:1234@localhost:3306/fume?charset=utf8")
+engine = create_engine("mysql+pymysql://fumeRemote:feiyu2023@114.215.109.124:3306/fume?charset=utf8")
# 涓撻棬璇诲彇璁惧淇℃伅琛�
con_read = engine.connect()
def write(data):
- engine = create_engine("mysql+mysqlconnector://root:1234@localhost:3306/fume?charset=utf8")
+ engine = create_engine("mysql+pymysql://fumeRemote:feiyu2023@114.215.109.124:3306/fume?charset=utf8")
con = engine.connect()
write_all(data,con)
con.close()
--
Gitblit v1.9.3