1.修改了创建连接数据库引擎时的方言类型 2.修改了爬取数据的逻辑以及相关的异常分析代码

zmc

2023-12-22 d99d235123d43825f35cdc4c8cb49339d9651056

 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) #结果为datetime.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