From ed135d79df12a2466b52dae1a82326941211dcc9 Mon Sep 17 00:00:00 2001
From: zmc <zmc_li@foxmail.com>
Date: 星期四, 12 十月 2023 17:00:18 +0800
Subject: [PATCH] 修改了连接远程数据库的方式
---
__pycache__/hello.cpython-38.pyc | 0
src/Crawling.py | 16 +++++++++++-----
src/write_to_minute_table.py | 4 ++--
src/text.py | 2 +-
py_spider.py | 6 ++----
src/__pycache__/Crawling.cpython-38.pyc | 0
Vcode.jpg | 0
src/__pycache__/write_to_MySql.cpython-38.pyc | 0
__pycache__/py_spider.cpython-38.pyc | 0
src/__pycache__/write_to_minute_table.cpython-38.pyc | 0
src/write_to_MySql.py | 4 ++--
11 files changed, 18 insertions(+), 14 deletions(-)
diff --git a/Vcode.jpg b/Vcode.jpg
new file mode 100644
index 0000000..f032937
--- /dev/null
+++ b/Vcode.jpg
Binary files differ
diff --git a/__pycache__/hello.cpython-38.pyc b/__pycache__/hello.cpython-38.pyc
index 249888f..d4074cd 100644
--- a/__pycache__/hello.cpython-38.pyc
+++ b/__pycache__/hello.cpython-38.pyc
Binary files differ
diff --git a/__pycache__/py_spider.cpython-38.pyc b/__pycache__/py_spider.cpython-38.pyc
new file mode 100644
index 0000000..63be6fa
--- /dev/null
+++ b/__pycache__/py_spider.cpython-38.pyc
Binary files differ
diff --git a/hello.py b/py_spider.py
similarity index 95%
rename from hello.py
rename to py_spider.py
index 907f9f9..fed11c5 100644
--- a/hello.py
+++ b/py_spider.py
@@ -109,7 +109,7 @@
# print('\n')
after_address.append(a)
- 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()
df = pd.read_sql('SELECT b.DI_Name,a.MV_Stat_Code,a.MV_Data_Time,a.MV_Isduplication FROM fd_t_minutevalue AS a JOIN ea_t_device_info AS b ON a.MV_Stat_Code = b.DI_Code',con=con_read)
@@ -119,8 +119,6 @@
existing_data = df.values.tolist() #DateFrame鎸夌収琛岃浆鎴恖ist绫诲瀷锛宺es瀛樻斁鐨勬槸璁惧淇℃伅琛ㄤ腑鐨勬暟鎹�
- # print('宸插鐞嗭細',after_address)
- # print('宸插瓨鍦�',existing_data)
# 淇濆瓨閲嶅鍊�
duplicate_data=[]
@@ -157,4 +155,4 @@
return False,max
-app.run(debug=True,port=8089)
\ No newline at end of file
+app.run(debug=False,host='0.0.0.0',port=8089)
\ No newline at end of file
diff --git a/src/Crawling.py b/src/Crawling.py
index 0610702..448d8db 100644
--- a/src/Crawling.py
+++ b/src/Crawling.py
@@ -213,7 +213,7 @@
data = pd.DataFrame(list,columns=['dev_id','exception','exception_type','region','begin_time','end_time'])
print("\n\n")
print(data)
- # engine = create_engine("mysql+mysqlconnector://root:1234@localhost:3306/fume?charset=utf8")
+ # engine = create_engine("mysql+pymysql://root:1234@localhost:3306/fume?charset=utf8")
# con = engine.connect()
# test3 瑕佸啓鍏ョ殑鏁版嵁琛紝杩欐牱鍐欑殑璇濊鎻愬墠鍦ㄦ暟鎹簱寤哄ソ琛�
@@ -380,7 +380,7 @@
data = pd.DataFrame(list,columns=['MV_Stat_Code','MV_Create_Time','MV_Data_Time','MV_Fan_Electricity','MV_Purifier_Electricity','MV_Fume_Concentration','MV_Fume_Concentration2'])
print("\n\n")
print(data)
- #engine = create_engine("mysql+mysqlconnector://root:1234@localhost:3306/fume?charset=utf8")
+ #engine = create_engine("mysql+pymysql://root:1234@localhost:3306/fume?charset=utf8")
#con = engine.connect()
# test3 瑕佸啓鍏ョ殑鏁版嵁琛紝杩欐牱鍐欑殑璇濊鎻愬墠鍦ㄦ暟鎹簱寤哄ソ琛�
@@ -512,7 +512,7 @@
def dev_info_data_if_exisitd(list,con): #list涓虹埇鍙栨煇瀹跺簵閾烘寚瀹氶〉鏁拌浆鎹㈠悗鐨勬暟鎹�
global con_read
#鍒涘缓绗簩涓暟鎹簱杩炴帴
- # engine = create_engine("mysql+mysqlconnector://root:1234@localhost:3306/fume?charset=utf8")
+ # engine = create_engine("mysql+pymysql://root:1234@localhost:3306/fume?charset=utf8")
# con_read = engine.connect()
df = pd.read_sql('SELECT DI_Code,DI_Name,DI_Supplier FROM ea_t_device_info',con=con_read) #浠庤澶囦俊鎭〃涓鍙栬澶囩紪鍙凤紝搴楅摵鍚嶏紝渚涘簲鍟嗗瓧娈电殑鏁版嵁銆傝繑鍥炲�兼槸DateFrame绫诲瀷
@@ -874,7 +874,12 @@
Key_period_night_begin = datetime.strptime('17:00',"%H:%M") #鏅氫笂閲嶇偣鏃舵
Key_period_night_end = datetime.strptime('21:00',"%H:%M")
-engine = create_engine("mysql+mysqlconnector://root:1234@localhost:3306/fume?charset=utf8")
+# e1ngine = create_engine("mysql+pymysql://fume:fume_feiyu2023@localhost:3306/fume?charset=utf8")
+engine = create_engine("mysql+pymysql://fumeRemote:feiyu2023@114.215.109.124:3306/fume?charset=utf8")
+
+
+# e1ngine = create_engine("mysql+pymysql:/fumeRemote:feiyu2023@114.215.109.124:3306/fume?charset=utf8")
+
# 涓撻棬璇诲彇璁惧淇℃伅琛�
con_read = engine.connect()
@@ -903,9 +908,10 @@
# 鍒濆鍖杝ession
session = ses
webshops = shops[:]
+ print(f'鑾峰彇鏁版嵁鐨勬椂闂村尯闂翠负锛歿beginTime}-{endTime}')
print('浼犲叆鐨勫簵閾哄悕绉颁负锛�',shops)
- 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()
# back_cookie() # 浠庢枃浠朵腑璇诲彇cookie
diff --git a/src/__pycache__/Crawling.cpython-38.pyc b/src/__pycache__/Crawling.cpython-38.pyc
index 33a6fd9..1c6a4b9 100644
--- a/src/__pycache__/Crawling.cpython-38.pyc
+++ b/src/__pycache__/Crawling.cpython-38.pyc
Binary files differ
diff --git a/src/__pycache__/write_to_MySql.cpython-38.pyc b/src/__pycache__/write_to_MySql.cpython-38.pyc
index 02f4d79..aa429e6 100644
--- a/src/__pycache__/write_to_MySql.cpython-38.pyc
+++ b/src/__pycache__/write_to_MySql.cpython-38.pyc
Binary files differ
diff --git a/src/__pycache__/write_to_minute_table.cpython-38.pyc b/src/__pycache__/write_to_minute_table.cpython-38.pyc
index 1821c01..5a658b7 100644
--- a/src/__pycache__/write_to_minute_table.cpython-38.pyc
+++ b/src/__pycache__/write_to_minute_table.cpython-38.pyc
Binary files differ
diff --git a/src/text.py b/src/text.py
index 8d59e49..312ffc7 100644
--- a/src/text.py
+++ b/src/text.py
@@ -67,7 +67,7 @@
# a.append(item[11])
# after_address.append(a)
- engine = create_engine("mysql+mysqlconnector://root:1234@localhost:3306/fume?charset=utf8")
+ engine = create_engine("mysql+pymysql://root:1234@localhost:3306/fume?charset=utf8")
# 涓撻棬璇诲彇璁惧淇℃伅琛�
con_read = engine.connect()
diff --git a/src/write_to_MySql.py b/src/write_to_MySql.py
index 445a007..3af97c9 100644
--- a/src/write_to_MySql.py
+++ b/src/write_to_MySql.py
@@ -434,12 +434,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()
diff --git a/src/write_to_minute_table.py b/src/write_to_minute_table.py
index 42a0f9d..3afe27b 100644
--- a/src/write_to_minute_table.py
+++ b/src/write_to_minute_table.py
@@ -51,12 +51,12 @@
fd_t_minbute(has_remove_duplicates,con) #灏嗘寚瀹氶〉鏁版暟鎹啓鍏ユ暟鎹簱鍒嗛挓鏁版嵁琛ㄤ腑
-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