From 758027eb55cca334f28cc7dddda0279043401e81 Mon Sep 17 00:00:00 2001 From: Fisher Date: Tue, 13 Jul 2021 09:29:14 +0800 Subject: [PATCH] =?UTF-8?q?=E5=B0=86=20data=5Fcleansing.py=20=E9=9B=86?= =?UTF-8?q?=E6=88=90=E8=BF=9B=20Spider=20=E4=B8=AD?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- src/backend/Data_Cleansing/createTestDB.sql | 252 ----- src/backend/Data_Cleansing/data_cleansing.py | 1055 ------------------ 2 files changed, 1307 deletions(-) delete mode 100644 src/backend/Data_Cleansing/createTestDB.sql delete mode 100644 src/backend/Data_Cleansing/data_cleansing.py diff --git a/src/backend/Data_Cleansing/createTestDB.sql b/src/backend/Data_Cleansing/createTestDB.sql deleted file mode 100644 index 0208b50..0000000 --- a/src/backend/Data_Cleansing/createTestDB.sql +++ /dev/null @@ -1,252 +0,0 @@ -CREATE DATABASE IF NOT EXISTS test; -USE test; - -DROP TABLE IF EXISTS `cpu`; -CREATE TABLE `cpu` ( - `id` int(11) DEFAULT 0, - `name` varchar(255) DEFAULT NULL, - `comment_num` INT DEFAULT 100, - `praise_rate` INT DEFAULT 90, - `shop_name` varchar(255) DEFAULT NULL, - `price` INT DEFAULT 0, - `link` varchar(255) NOT NULL, - `brand` varchar(255) DEFAULT NULL, - `tags` varchar(255) DEFAULT NULL, - `clock_speed` varchar(255) DEFAULT NULL, - `core_num` varchar(255) DEFAULT NULL, - `TDP` INT DEFAULT 0, - `socket` varchar(255) DEFAULT NULL, - `have_core_graphics_card` varchar(255) DEFAULT NULL, - `have_cpu_fan` varchar(255) DEFAULT NULL, - `generation` INT DEFAULT 0, - `introduction` JSON, - `Ptable_params` JSON, - `title_name` varchar(255) DEFAULT NULL, - PRIMARY KEY (`link`) -) ENGINE=InnoDB AUTO_INCREMENT=38 DEFAULT CHARSET=utf8mb4, COLLATE=utf8mb4_general_ci; -truncate cpu; - -DROP TABLE IF EXISTS `motherboard`; -CREATE TABLE `motherboard` ( - `id` int(11) DEFAULT 0, - `name` varchar(255) DEFAULT NULL, - `comment_num` INT DEFAULT 100, - `praise_rate` INT DEFAULT 90, - `shop_name` varchar(255) DEFAULT NULL, - `price` INT DEFAULT 0, - `link` varchar(255) NOT NULL, - `brand` varchar(255) DEFAULT NULL, - `tags` varchar(255) DEFAULT NULL, - `form_factor` varchar(255) DEFAULT NULL, - `platform` varchar(255) DEFAULT NULL, - `cpu_socket` varchar(255) DEFAULT NULL, - `m2_num` INT DEFAULT 0, - `slot_num` INT DEFAULT 0, - `ddr_gen` varchar(255) DEFAULT NULL, - `max_memory` INT DEFAULT 0, - `introduction` JSON, - `Ptable_params` JSON, - `title_name` varchar(255) DEFAULT NULL, - PRIMARY KEY (`link`) -) ENGINE=InnoDB AUTO_INCREMENT=38 DEFAULT CHARSET=utf8mb4, COLLATE=utf8mb4_general_ci; -truncate motherboard; - -DROP TABLE IF EXISTS `graphics_card`; -CREATE TABLE `graphics_card` ( - `id` int(11) DEFAULT 0, - `name` varchar(255) DEFAULT NULL, - `comment_num` INT DEFAULT 100, - `praise_rate` INT DEFAULT 90, - `shop_name` varchar(255) DEFAULT NULL, - `price` INT DEFAULT 0, - `link` varchar(255) NOT NULL, - `brand` varchar(255) DEFAULT NULL, - `tags` varchar(255) DEFAULT NULL, - `card_length` float DEFAULT 0, - `rgb` varchar(255) DEFAULT NULL, - `card_type` varchar(255) DEFAULT NULL, - `generation` INT DEFAULT 0, - `introduction` JSON, - `Ptable_params` JSON, - `title_name` varchar(255) DEFAULT NULL, - PRIMARY KEY (`link`) -) ENGINE=InnoDB AUTO_INCREMENT=38 DEFAULT CHARSET=utf8mb4, COLLATE=utf8mb4_general_ci; -truncate graphics_card; - -DROP TABLE IF EXISTS `memory`; -CREATE TABLE `memory` ( - `id` int(11) DEFAULT 0, - `name` varchar(255) DEFAULT NULL, - `comment_num` INT DEFAULT 100, - `praise_rate` INT DEFAULT 90, - `shop_name` varchar(255) DEFAULT NULL, - `price` INT DEFAULT 0, - `link` varchar(255) NOT NULL, - `brand` varchar(255) DEFAULT NULL, - `frequency` varchar(255) DEFAULT NULL, - `total_capacity` INT DEFAULT 0, - `memory_num` varchar(255) DEFAULT NULL, - `appearance` varchar(255) DEFAULT NULL, - `ddr_gen` varchar(255) DEFAULT NULL, - `introduction` JSON, - `Ptable_params` JSON, - `title_name` varchar(255) DEFAULT NULL, - PRIMARY KEY (`link`) -) ENGINE=InnoDB AUTO_INCREMENT=38 DEFAULT CHARSET=utf8mb4, COLLATE=utf8mb4_general_ci; -truncate memory; - -DROP TABLE IF EXISTS `cpu_radiator`; -CREATE TABLE `cpu_radiator` ( - `id` int(11) DEFAULT 0, - `name` varchar(255) DEFAULT NULL, - `comment_num` INT DEFAULT 100, - `praise_rate` INT DEFAULT 90, - `shop_name` varchar(255) DEFAULT NULL, - `price` INT DEFAULT 0, - `link` varchar(255) NOT NULL, - `brand` varchar(255) DEFAULT NULL, - `height` INT DEFAULT 0, - `socket` varchar(255) DEFAULT NULL, - `radiator_size` INT DEFAULT 0, - `rgb` varchar(255) DEFAULT NULL, - `introduction` JSON, - `Ptable_params` JSON, - `title_name` varchar(255) DEFAULT NULL, - PRIMARY KEY (`link`) -) ENGINE=InnoDB AUTO_INCREMENT=38 DEFAULT CHARSET=utf8mb4, COLLATE=utf8mb4_general_ci; -truncate cpu_radiator; - -DROP TABLE IF EXISTS `ssd`; -CREATE TABLE `ssd` ( - `id` int(11) DEFAULT 0, - `name` varchar(255) DEFAULT NULL, - `comment_num` INT DEFAULT 100, - `praise_rate` INT DEFAULT 90, - `shop_name` varchar(255) DEFAULT NULL, - `price` INT DEFAULT 0, - `link` varchar(255) NOT NULL, - `brand` varchar(255) DEFAULT NULL, - `interface` varchar(255) DEFAULT NULL, - `total_capacity` FLOAT DEFAULT 0, - `introduction` JSON, - `Ptable_params` JSON, - `title_name` varchar(255) DEFAULT NULL, - PRIMARY KEY (`link`) -) ENGINE=InnoDB AUTO_INCREMENT=38 DEFAULT CHARSET=utf8mb4, COLLATE=utf8mb4_general_ci; -truncate ssd; - -DROP TABLE IF EXISTS `hdd`; -CREATE TABLE `hdd` ( - `id` int(11) DEFAULT 0, - `name` varchar(255) DEFAULT NULL, - `comment_num` INT DEFAULT 100, - `praise_rate` INT DEFAULT 90, - `shop_name` varchar(255) DEFAULT NULL, - `price` INT DEFAULT 0, - `link` varchar(255) NOT NULL, - `brand` varchar(255) DEFAULT NULL, - `size` varchar(255) DEFAULT NULL, - `rotating_speed` varchar(255) DEFAULT NULL, - `total_capacity` FLOAT DEFAULT 0, - `introduction` JSON, - `Ptable_params` JSON, - `title_name` varchar(255) DEFAULT NULL, - PRIMARY KEY (`link`) -) ENGINE=InnoDB AUTO_INCREMENT=38 DEFAULT CHARSET=utf8mb4, COLLATE=utf8mb4_general_ci; -truncate hdd; - -DROP TABLE IF EXISTS `power_supply`; -CREATE TABLE `power_supply` ( - `id` int(11) DEFAULT 0, - `name` varchar(255) DEFAULT NULL, - `comment_num` INT DEFAULT 100, - `praise_rate` INT DEFAULT 90, - `shop_name` varchar(255) DEFAULT NULL, - `price` INT DEFAULT 0, - `link` varchar(255) NOT NULL, - `brand` varchar(255) DEFAULT NULL, - `tags` varchar(255) DEFAULT NULL, - `power` INT DEFAULT 0, - `size` varchar(255) DEFAULT NULL, - `modularization` varchar(255) DEFAULT NULL, - `transfer_efficiency` varchar(255) DEFAULT NULL, - `introduction` JSON, - `Ptable_params` JSON, - `title_name` varchar(255) DEFAULT NULL, - PRIMARY KEY (`link`) -) ENGINE=InnoDB AUTO_INCREMENT=38 DEFAULT CHARSET=utf8mb4, COLLATE=utf8mb4_general_ci; -truncate power_supply; - -DROP TABLE IF EXISTS `computer_case`; -CREATE TABLE `computer_case` ( - `id` int(11) DEFAULT 0, - `name` varchar(255) DEFAULT NULL, - `comment_num` INT DEFAULT 100, - `praise_rate` INT DEFAULT 90, - `shop_name` varchar(255) DEFAULT NULL, - `price` INT DEFAULT 0, - `link` varchar(255) NOT NULL, - `brand` varchar(255) DEFAULT NULL, - `max_form_factor` varchar(255) DEFAULT NULL, - `max_card_len` INT DEFAULT 0, - `max_radiator_height` INT DEFAULT 0, - `supported_radiator` varchar(255) DEFAULT NULL, - `has_transparent_side_panel` INT DEFAULT 0, - `introduction` JSON, - `Ptable_params` JSON, - `title_name` varchar(255) DEFAULT NULL, - PRIMARY KEY (`link`) -) ENGINE=InnoDB AUTO_INCREMENT=38 DEFAULT CHARSET=utf8mb4, COLLATE=utf8mb4_general_ci; -truncate computer_case; - -DROP TABLE IF EXISTS `board_u_suit`; -CREATE TABLE `board_u_suit` ( - `id` int(11) DEFAULT 0, - `name` varchar(255) DEFAULT NULL, - `board` varchar(255) DEFAULT NULL, - `cpu` varchar(255) DEFAULT NULL, - `shop_name` varchar(255) DEFAULT NULL, - `price` INT DEFAULT 0, - `link` varchar(255) NOT NULL, - `introduction` JSON, - `Ptable_params` JSON, - `title_name` varchar(255) DEFAULT NULL, - PRIMARY KEY (`link`) -) ENGINE=InnoDB AUTO_INCREMENT=38 DEFAULT CHARSET=utf8mb4, COLLATE=utf8mb4_general_ci; -truncate board_u_suit; - -DROP TABLE IF EXISTS `trendings`; -CREATE TABLE `trendings` ( - `id` varchar(255) NOT NULL, - `frequency` int(11) DEFAULT 0, - `cpu` varchar(255) NOT NULL, - `cpu_price` int(11) DEFAULT 0, - `cpu_link` varchar(255) NOT NULL, - `motherboard` varchar(255) NOT NULL, - `motherboard_price` int(11) DEFAULT 0, - `motherboard_link` varchar(255) NOT NULL, - `GPU` varchar(255) NOT NULL, - `GPU_price` int(11) DEFAULT 0, - `GPU_link` varchar(255) NOT NULL, - `memory` varchar(255) NOT NULL, - `memory_price` int(11) DEFAULT 0, - `memory_link` varchar(255) NOT NULL, - `CPURadiator` varchar(255) NOT NULL, - `CPURadiator_price` int(11) DEFAULT 0, - `CPURadiator_link` varchar(255) NOT NULL, - `ssd` varchar(255) NOT NULL, - `ssd_price` int(11) DEFAULT 0, - `ssd_link` varchar(255) NOT NULL, - `hdd` varchar(255) NOT NULL, - `hdd_price` int(11) DEFAULT 0, - `hdd_link` varchar(255) NOT NULL, - `powerSupply` varchar(255) NOT NULL, - `powerSupply_price` int(11) DEFAULT 0, - `powerSupply_link` varchar(255) NOT NULL, - `case` varchar(255) NOT NULL, - `case_price` int(11) DEFAULT 0, - `case_link` varchar(255) NOT NULL, - `totalPrice` int(11) DEFAULT 0, - PRIMARY KEY (`id`) -) ENGINE=InnoDB AUTO_INCREMENT=38 DEFAULT CHARSET=utf8mb4, COLLATE=utf8mb4_general_ci; -truncate trendings; \ No newline at end of file diff --git a/src/backend/Data_Cleansing/data_cleansing.py b/src/backend/Data_Cleansing/data_cleansing.py deleted file mode 100644 index b7ac932..0000000 --- a/src/backend/Data_Cleansing/data_cleansing.py +++ /dev/null @@ -1,1055 +0,0 @@ -''' -Description: -Author: Fishermanykx -LastEditors: Fishermanykx -LastEditTime: 2021-05-28 11:13:27 -''' -import re -import pymysql - -MYSQL_HOSTS = "127.0.0.1" -MYSQL_USER = "root" -MYSQL_PASSWORD = "08239015" -MYSQL_PORT = 3306 -MYSQL_DB = "test" -# MYSQL_DB = "computer_accessories" - - -class DataCleaning: - def __init__(self, accessory_type): - self.accessory_type = accessory_type - - def washComments(self, comment_num, praise_rate): - # 清洗好评率 - praise_rate = int(praise_rate[:-1]) - # 清洗评论数 - pat = r'\d*(\.)?\d*' - base = 1 - try: - if '万' in comment_num: - base *= 10**4 - res = re.match(pat, comment_num) - comment_num = eval(res.group()) * base - except: - comment_num = 100 - return int(comment_num), praise_rate - - def handleSingleCPURecrod(self, record): - record['price'] = int(record['price']) - introd = eval(record['introduction']) - p_table = eval(record['Ptable_params']) - - # TDP - record['TDP'] = int(p_table['规格']['功率'][:-1]) - # 处理接口 - socket = introd["接口"] - if "1151" in socket: - socket = "INTEL LGA1151" - elif "其他" in socket: - socket = "INTEL LGA1151" - record["socket"] = socket - # 清洗评论和好评率 - record['comment_num'], record['praise_rate'] = self.washComments( - record['comment_num'], record['praise_rate']) - # 清洗 brand - record['brand'] = self.washBrand(record['brand']) - - return record - - def cleanCPU(self): - ''' - description: 清洗 CPU 数据 - ''' - connection = pymysql.connect( - host=MYSQL_HOSTS, - port=MYSQL_PORT, - user=MYSQL_USER, - passwd=MYSQL_PASSWORD, - db=MYSQL_DB, - charset="utf8") - # 获取游标 - cursor = connection.cursor(cursor=pymysql.cursors.DictCursor) - - cursor.execute("drop table " + self.accessory_type) - cursor.execute( - "create table test."+self.accessory_type+" as select * from computer_accessories."+self.accessory_type) - - instruct = "alter table " + self.accessory_type + " modify price int default NULL" - row = cursor.execute(instruct) # 返回被影响的行数 - cursor.execute("select * from " + self.accessory_type) - data = cursor.fetchall() # 以字典列表的形式读出表中所有数据 - - # 增加列 - add_col = "alter table cpu add column TDP int NOT NULL default 0 AFTER core_num " - cursor.execute(add_col) - add_col = "alter table cpu add column socket VARCHAR(255) default NULL AFTER TDP" - cursor.execute(add_col) - - # 数据清洗 - data_len = len(data) - # print(data_len) - for i in range(data_len): - # 逐条数据处理 - data[i] = self.handleSingleCPURecrod(data[i]) - - # 清空表 - cursor.execute("truncate table " + self.accessory_type) - # 将评论数和好评率修改为 int 类型 - instruct = "alter table "+self.accessory_type+" modify comment_num int default 0" - row = cursor.execute(instruct) # 返回被影响的行数 - instruct = "alter table "+self.accessory_type+" modify praise_rate int default 0" - row = cursor.execute(instruct) # 返回被影响的行数 - # 重新写入 - sql_insert = "INSERT INTO cpu (id, name, comment_num, praise_rate, shop_name, price, link,"\ - "brand, tags, clock_speed, core_num, TDP, socket, have_core_graphics_card, have_cpu_fan, introduction, "\ - "Ptable_params) VALUES (%(id)s, %(name)s, %(comment_num)s, %(praise_rate)s, %(shop_name)s, %(price)s, "\ - "%(link)s, %(brand)s, %(tags)s, %(clock_speed)s, %(core_num)s, %(TDP)s, %(socket)s, "\ - "%(have_core_graphics_card)s, %(have_cpu_fan)s, %(introduction)s, %(Ptable_params)s)" - cursor.executemany(sql_insert, data) - - connection.commit() - - def washBrand(self, brand): - if "Intel" in brand: - return "INTEL" - elif 'AMD' in brand: - return "AMD" - - index = brand.find('（') - if brand == 'Thermaltake（Tt）': - return "TT" - - if index != -1: - brand = brand[:index] - else: - # Special cases - if brand == 'Crucial': - brand = '英睿达' - elif brand == 'HP': - brand = '惠普' - elif brand == 'uFound': - brand = '方正' - elif brand == 'pioneer': - brand = '先锋' - elif brand == 'HIKVISION': - brand = '海康威视' - elif brand == 'dahua': - brand = '大华' - elif brand == 'SEASONIC': - brand = '海韵' - elif brand == 'SUPER FLOWER': - brand = '振华' - elif brand == 'INWIN': - brand = '迎广' - elif brand == 'NZXT': - brand = '恩杰' - elif brand == 'be quiet': - brand = '德商必酷' - elif brand == 'XPG': - brand = '威刚' - elif brand == 'LIANLI': - brand = '联立' - elif brand == 'BitFenix': - brand = '火鸟' - elif brand == 'Fractal Design': - brand = '分形工艺' - elif brand == 'METALLICGEAR': - brand = '普力魔' - elif brand == 'Thermalright': - brand = '利民' - elif brand == 'noctua': - brand = '猫头鹰' - elif brand == 'PHANTEKS': - brand = '追风者' - - # 注意：没被处理的有：EVGA, zero zone(这TM还是家国内公司。。。), ID_COOLING - - return brand - - def handleSingleMotherboardRecord(self, record): - record['price'] = int(record['price']) - introd = eval(record['introduction']) - p_table = eval(record['Ptable_params']) - # form_factor 去中文 - s = record['form_factor'] - record['form_factor'] = s[:s.find('（')] - # platform - record['platform'] = self.washBrand(record['platform'][:-2]) - # 加入 CPU 接口列 - try: - ss = introd['适用CPU接口'] - index = ss.find('（') - if (index != -1): - ss = ss[:index] - ss = ss.split("，")[0] - if ss == 'INTEL1151': - ss = 'INTEL LGA1151' - record['cpu_socket'] = ss - except: - print(introd) - exit(1) - # 加入 m2 接口数 列 - record['m2_num'] = int(introd.get('M.2接口数量', 0)) - # 清洗品牌 - record['brand'] = self.washBrand(record['brand']) - # 清洗评论和好评率 - record['comment_num'], record['praise_rate'] = self.washComments( - record['comment_num'], record['praise_rate']) - - return record - - def cleanMotherboard(self): - connection = pymysql.connect( - host=MYSQL_HOSTS, - port=MYSQL_PORT, - user=MYSQL_USER, - passwd=MYSQL_PASSWORD, - db=MYSQL_DB, - charset="utf8") - # 获取游标 - cursor = connection.cursor(cursor=pymysql.cursors.DictCursor) - - cursor.execute("drop table " + self.accessory_type) - cursor.execute( - "create table test."+self.accessory_type+" as select * from computer_accessories."+self.accessory_type) - - instruct = "alter table " + self.accessory_type + " modify price int default NULL" - row = cursor.execute(instruct) # 返回被影响的行数 - cursor.execute("select * from " + self.accessory_type) - data = cursor.fetchall() # 以字典列表的形式读出表中所有数据 - - # 插入 CPU 接口列和 m.2 接口数 - add_col = "alter table " + self.accessory_type + \ - " add column cpu_socket VARCHAR(255) default NULL AFTER platform " - cursor.execute(add_col) - add_col = "alter table " + self.accessory_type + \ - " add column m2_num int NOT NULL default 0 AFTER cpu_socket" - cursor.execute(add_col) - - # 数据清洗 - data_len = len(data) - # print(data_len) - new_data = [] - for i in range(data_len): - # 逐条数据处理 - # 判定是否为板-U套装 - record = data[i] - if record['comment_num'] == '100': # 抓到板-U套装了 - continue - if '板U套装' in record['name']: - continue - # 清洗数据 - new_data.append(self.handleSingleMotherboardRecord(record)) - - # 清空表 - cursor.execute("truncate table " + self.accessory_type) - # 将评论数和好评率修改为 int 类型 - instruct = "alter table motherboard modify comment_num int default 0" - row = cursor.execute(instruct) # 返回被影响的行数 - instruct = "alter table motherboard modify praise_rate int default 0" - row = cursor.execute(instruct) # 返回被影响的行数 - # 重新写入 - sql_insert = "INSERT INTO motherboard (id, name, comment_num, praise_rate, shop_name, price, link,"\ - "brand, tags, form_factor, platform, cpu_socket, m2_num, introduction, Ptable_params) VALUES (%(id)s, %(name)s,"\ - " %(comment_num)s, %(praise_rate)s, %(shop_name)s, %(price)s, %(link)s, %(brand)s, %(tags)s, %(form_factor)s, "\ - "%(platform)s, %(cpu_socket)s, %(m2_num)s, %(introduction)s, %(Ptable_params)s)" - cursor.executemany(sql_insert, new_data) - - connection.commit() - - def handleSingleGraphicsCard(self, record): - record['price'] = int(record['price']) - introd = eval(record['introduction']) - p_table = eval(record['Ptable_params']) - - # 显卡类别 - amd = introd.get('AMD芯片', "其他") - nv = introd.get('NVIDIA芯片', "其他") - if nv == '其他': - record['card_type'] = 'AMD' - else: - record['card_type'] = 'NVIDIA' - # 修正卡长 - record['card_length'] = eval(record['card_length']) - # 修正 RGB 列 - rgb = record['rgb'] - if rgb == '单色': - record['rgb'] = '支持RGB' - # 清洗评论和好评率 - record['comment_num'], record['praise_rate'] = self.washComments( - record['comment_num'], record['praise_rate']) - # 清洗 brand - record['brand'] = self.washBrand(record['brand']) - - # if record['brand'] == '磐镭': - # record['card_length'] /= 10 - - return record - - def cleanGraphicsCard(self): - connection = pymysql.connect( - host=MYSQL_HOSTS, - port=MYSQL_PORT, - user=MYSQL_USER, - passwd=MYSQL_PASSWORD, - db=MYSQL_DB, - charset="utf8") - # 获取游标 - cursor = connection.cursor(cursor=pymysql.cursors.DictCursor) - - cursor.execute("drop table " + self.accessory_type) - cursor.execute( - "create table test."+self.accessory_type+" as select * from computer_accessories."+self.accessory_type) - - instruct = "alter table " + self.accessory_type + " modify price int default NULL" - row = cursor.execute(instruct) # 返回被影响的行数 - cursor.execute("select * from " + self.accessory_type) - data = cursor.fetchall() # 以字典列表的形式读出表中所有数据 - - # 插入 显卡类别列 (AMD/NVIDIA) - add_col = "alter table " + self.accessory_type + \ - " add column card_type VARCHAR(255) default NULL AFTER rgb " - cursor.execute(add_col) - - # 数据清洗 - data_len = len(data) - # print(data_len) - for i in range(data_len): - # 逐条数据处理 - record = data[i] - # 清洗数据 - data[i] = self.handleSingleGraphicsCard(record) - - # 清空表 - cursor.execute("truncate table " + self.accessory_type) - # 将评论数和好评率修改为 int 类型 - instruct = "alter table "+self.accessory_type+" modify comment_num int default 0" - row = cursor.execute(instruct) # 返回被影响的行数 - instruct = "alter table "+self.accessory_type+" modify praise_rate int default 0" - row = cursor.execute(instruct) # 返回被影响的行数 - instruct = "alter table "+self.accessory_type + \ - " modify card_length float default 0.0" - row = cursor.execute(instruct) # 返回被影响的行数 - # 重新写入 - sql_insert = "INSERT INTO graphics_card (id, name, comment_num, praise_rate, shop_name, price, link,"\ - "brand, tags, card_length, rgb, card_type, introduction, Ptable_params) VALUES (%(id)s, %(name)s, %(comment_num)s,"\ - "%(praise_rate)s, %(shop_name)s, %(price)s, %(link)s, %(brand)s, %(tags)s, %(card_length)s, "\ - "%(rgb)s, %(card_type)s, %(introduction)s, %(Ptable_params)s)" - cursor.executemany(sql_insert, data) - - connection.commit() - - def handleSingleCPURadiator(self, record): - record['price'] = int(record['price']) - introd = eval(record['introduction']) - p_table = eval(record['Ptable_params']) - - # 散热器高度 - try: - h = p_table['规格']['散热器高度'] - h = int(h[:-2]) - except: - h = 0 - record['height'] = h - - # 冷排大小 - cooling_size = introd.get('水冷类型', '0风冷') - cooling_size = cooling_size[:-2] - try: - record['radiator_size'] = int(cooling_size) - except: - record['radiator_size'] = 0 - - # RGB - rgb = introd.get('发光类型', '无') - if '无' in rgb: - rgb = '无' - elif 'RGB' not in rgb: - rgb = 'RGB' - record['rgb'] = rgb - - # 兼容接口 - try: - socket_str = introd.get('兼容接口', "") - socket_str = socket_str.split('，') - res_socket = "" - for item in socket_str: - index = item.find('（') - if index != -1: - item = item[:index] - item = item.strip() - if item == "INTEL1151": - item = 'INTEL LGA1151' - res_socket += item - res_socket += '~' - res_socket = res_socket[:-1] - except: - print(record) - exit(1) - record['socket'] = res_socket - - # 清洗评论和好评率 - record['comment_num'], record['praise_rate'] = self.washComments( - record['comment_num'], record['praise_rate']) - # 清洗 brand - record['brand'] = self.washBrand(record['brand']) - - return record - - def cleanCPURadiator(self): - connection = pymysql.connect( - host=MYSQL_HOSTS, - port=MYSQL_PORT, - user=MYSQL_USER, - passwd=MYSQL_PASSWORD, - db=MYSQL_DB, - charset="utf8") - # 获取游标 - cursor = connection.cursor(cursor=pymysql.cursors.DictCursor) - - cursor.execute("drop table " + self.accessory_type) - cursor.execute( - "create table test."+self.accessory_type+" as select * from computer_accessories."+self.accessory_type) - - instruct = "alter table " + self.accessory_type + " modify price int default NULL" - row = cursor.execute(instruct) # 返回被影响的行数 - cursor.execute("select * from " + self.accessory_type) - data = cursor.fetchall() # 以字典列表的形式读出表中所有数据 - - # 插入 散热器高度 (mm) - add_col = "alter table " + self.accessory_type + \ - " add column height int default NULL AFTER brand " - cursor.execute(add_col) - # 插入 兼容接口 列 - add_col = "alter table " + self.accessory_type + \ - " add column socket VARCHAR(255) default NULL AFTER height " - cursor.execute(add_col) - # 插入 冷排 列 - add_col = "alter table " + self.accessory_type + \ - " add column radiator_size int default NULL AFTER socket " - cursor.execute(add_col) - # 插入 RGB 列 - add_col = "alter table " + self.accessory_type + \ - " add column rgb VARCHAR(255) default NULL AFTER radiator_size " - cursor.execute(add_col) - - # 数据清洗 - data_len = len(data) - # print(data_len) - for i in range(data_len): - # 逐条数据处理 - record = data[i] - # 清洗数据 - data[i] = self.handleSingleCPURadiator(record) - - # 清空表 - cursor.execute("truncate table " + self.accessory_type) - # 将评论数和好评率修改为 int 类型 - instruct = "alter table "+self.accessory_type+" modify comment_num int default 0" - row = cursor.execute(instruct) # 返回被影响的行数 - instruct = "alter table "+self.accessory_type+" modify praise_rate int default 0" - row = cursor.execute(instruct) # 返回被影响的行数 - - # 重新写入 - sql_insert = "INSERT INTO cpu_radiator (id, name, comment_num, praise_rate, shop_name, price, link,"\ - "brand, height, socket, radiator_size, rgb, introduction, Ptable_params) VALUES (%(id)s, %(name)s, %(comment_num)s,"\ - "%(praise_rate)s, %(shop_name)s, %(price)s, %(link)s, %(brand)s, %(height)s, %(socket)s, "\ - "%(radiator_size)s, %(rgb)s, %(introduction)s, %(Ptable_params)s)" - cursor.executemany(sql_insert, data) - - connection.commit() - - def handleSingleCase(self, record): - record['price'] = int(record['price']) - introd = eval(record['introduction']) - p_table = eval(record['Ptable_params']) - - # 最大板型 - boards = introd.get('支持主板', '') - if boards: - boards = boards.split('，')[0] - boards = boards[:boards.find('（')] - record['max_form_factor'] = boards - - # 最大卡长 - max_l = p_table['规格'].get('显卡（连供电头总长度）限长', 0) - if max_l: - max_l = int(max_l[1:-2]) - record['max_card_len'] = max_l - - # 散热器限高 - max_h = p_table['规格'].get('CPU散热器限高', 0) - if max_h: - pat = r'\d*' - max_h = re.match(pat, max_h).group() - record['max_radiator_height'] = int(max_h) - - # 支持的冷排 - sup_rad = introd.get('支持水冷', '0') - res = sup_rad - - if sup_rad != '0': - sup_rad = sup_rad.split('，') - res = "" - for i in range(len(sup_rad)): - sup_rad[i] = sup_rad[i][:-2] - res = res + sup_rad[i] + '~' - res = res[:-1] - if res == '不': - res = '0' - record["supported_radiator"] = res - - # 清洗评论和好评率 - record['comment_num'], record['praise_rate'] = self.washComments( - record['comment_num'], record['praise_rate']) - # 清洗 brand - record['brand'] = self.washBrand(record['brand']) - - return record - - def cleanCase(self): - connection = pymysql.connect( - host=MYSQL_HOSTS, - port=MYSQL_PORT, - user=MYSQL_USER, - passwd=MYSQL_PASSWORD, - db=MYSQL_DB, - charset="utf8") - # 获取游标 - cursor = connection.cursor(cursor=pymysql.cursors.DictCursor) - - cursor.execute("drop table " + self.accessory_type) - cursor.execute( - "create table test."+self.accessory_type+" as select * from computer_accessories."+self.accessory_type) - - instruct = "alter table " + self.accessory_type + " modify price int default NULL" - row = cursor.execute(instruct) # 返回被影响的行数 - cursor.execute("select * from " + self.accessory_type) - data = cursor.fetchall() # 以字典列表的形式读出表中所有数据 - - # 插入 最大板型 - add_col = "alter table " + self.accessory_type + \ - " add column max_form_factor VARCHAR(255) default NULL AFTER brand " - cursor.execute(add_col) - # 插入 最大显卡长度 列 - add_col = "alter table " + self.accessory_type + \ - " add column max_card_len int default NULL AFTER max_form_factor " - cursor.execute(add_col) - # 插入 散热器限高 列 - add_col = "alter table " + self.accessory_type + \ - " add column max_radiator_height int default NULL AFTER max_card_len " - cursor.execute(add_col) - # 插入 散热器规格支持 列 - add_col = "alter table " + self.accessory_type + \ - " add column supported_radiator VARCHAR(255) default NULL AFTER max_radiator_height " - cursor.execute(add_col) - - # 数据清洗 - data_len = len(data) - # print(data_len) - new_data = [] - for i in range(data_len): - # 逐条数据处理 - record = data[i] - p_table = eval(record['Ptable_params']) - max_l = p_table['规格'].get('显卡（连供电头总长度）限长', 0) - max_h = p_table['规格'].get('CPU散热器限高', 0) - name = record['name'] - if '套装' in name: - continue - # 清洗数据 - if max_h and max_l: - new_data.append(self.handleSingleCase(record)) - - # 清空表 - cursor.execute("truncate table " + self.accessory_type) - # 将评论数和好评率修改为 int 类型 - instruct = "alter table "+self.accessory_type+" modify comment_num int default 0" - row = cursor.execute(instruct) # 返回被影响的行数 - instruct = "alter table "+self.accessory_type+" modify praise_rate int default 0" - row = cursor.execute(instruct) # 返回被影响的行数 - - # 重新写入 - sql_insert = "INSERT INTO computer_case (id, name, comment_num, praise_rate, shop_name, price, link,"\ - "brand, max_form_factor, max_card_len, max_radiator_height, supported_radiator, introduction, Ptable_params)"\ - " VALUES (%(id)s, %(name)s, %(comment_num)s, %(praise_rate)s, %(shop_name)s, %(price)s, %(link)s, %(brand)s, "\ - "%(max_form_factor)s, %(max_card_len)s, %(max_radiator_height)s, %(supported_radiator)s, %(introduction)s, %(Ptable_params)s)" - - cursor.executemany(sql_insert, new_data) - - connection.commit() - - def handleSingleHDD(self, record): - record['price'] = int(record['price']) - introd = eval(record['introduction']) - p_table = eval(record['Ptable_params']) - - # 清洗容量 (以TB为单位的0.25的倍数的浮点数) - capacity = record['total_capacity'] - dig = capacity[:-2] - if dig != '12' and dig.isdigit(): - capacity = dig - else: - name = record['name'] - pat = r'\d+T|\d+G|\d*\.\d*T' - res = re.search(pat, name) - if res: - res = res.group() - else: - res = '0T' - if res and res[-1] == 'T': - capacity = round(eval(res[:-1])) - elif res and res[-1] == 'G': - capacity = eval(res[:-1]) // 250 * 0.25 - else: - print("Error in converting capacity") - print(res) - print(record) - exit(1) - record['total_capacity'] = capacity - - # 清洗 尺寸 - try: - size = p_table['特性'].get('产品尺寸（mm）', '0x0x0') - except: - size = '0x0x0' - if '×' in size: - size = size.replace('×', '*') - if 'x' in size: - size = size.replace('x', '*') - if 'X' in size: - size = size.replace('X', '*') - new_size = "" - if len(size) > 9: - lis = size.split('*') - pat = r'\d*\.\d*|\d*' - for item in lis: - res = re.findall(pat, item) - res = list(filter(None, res))[0] - new_size = new_size + (res + '*') - new_size = new_size[:-1] - else: - pat = r'\d*\.\d*|\d*' - res = re.search(pat, size.strip()).group() - new_size = res + ' inches' - record['size'] = new_size - - # 清洗评论和好评率 - record['comment_num'], record['praise_rate'] = self.washComments( - record['comment_num'], record['praise_rate']) - # 清洗 brand - record['brand'] = self.washBrand(record['brand']) - - return record - - def cleanHDD(self): - connection = pymysql.connect( - host=MYSQL_HOSTS, - port=MYSQL_PORT, - user=MYSQL_USER, - passwd=MYSQL_PASSWORD, - db=MYSQL_DB, - charset="utf8") - # 获取游标 - cursor = connection.cursor(cursor=pymysql.cursors.DictCursor) - - cursor.execute("drop table " + self.accessory_type) - cursor.execute( - "create table test."+self.accessory_type+" as select * from computer_accessories."+self.accessory_type) - - instruct = "alter table " + self.accessory_type + " modify price int default NULL" - row = cursor.execute(instruct) # 返回被影响的行数 - cursor.execute("select * from " + self.accessory_type) - data = cursor.fetchall() # 以字典列表的形式读出表中所有数据 - - # 插入 尺寸 列 - add_col = "alter table " + self.accessory_type + \ - " add column size VARCHAR(255) default NULL AFTER brand " - cursor.execute(add_col) - - # 数据清洗 - data_len = len(data) - # print(data_len) - new_data = [] - for i in range(data_len): - # 逐条数据处理 - # 判定是否为 SSD - record = data[i] - name = record['name'] - if ('SSD' in name) or ('固态' in name): - continue - if '笔记本' in name: - continue - # 清洗数据 - new_data.append(self.handleSingleHDD(record)) - - # 清空表 - cursor.execute("truncate table " + self.accessory_type) - # 将评论数和好评率修改为 int 类型 - instruct = "alter table "+self.accessory_type+" modify comment_num int default 0" - row = cursor.execute(instruct) # 返回被影响的行数 - instruct = "alter table "+self.accessory_type+" modify praise_rate int default 0" - row = cursor.execute(instruct) # 返回被影响的行数 - instruct = "alter table "+self.accessory_type + \ - " modify total_capacity float default 0" - row = cursor.execute(instruct) # 返回被影响的行数 - # 重新写入 - sql_insert = "INSERT INTO hdd (id, name, comment_num, praise_rate, shop_name, price, link,"\ - "brand, size,rotating_speed, total_capacity, introduction, Ptable_params) VALUES (%(id)s, %(name)s, %(comment_num)s,"\ - "%(praise_rate)s, %(shop_name)s, %(price)s, %(link)s, %(brand)s, %(size)s, %(rotating_speed)s, "\ - "%(total_capacity)s, %(introduction)s, %(Ptable_params)s)" - for i in range(len(new_data)): - try: - cursor.execute(sql_insert, new_data[i]) - except: - print(new_data[i]) - exit(1) - # sql_insert = "INSERT INTO hdd (id, name, comment_num, praise_rate, shop_name, price, link,"\ - # "brand, size,rotating_speed, total_capacity, introduction, Ptable_params) VALUES (%(id)s, %(name)s, %(comment_num)s,"\ - # "%(praise_rate)s, %(shop_name)s, %(price)s, %(link)s, %(brand)s, %(size)s, %(rotating_speed)s, "\ - # "%(total_capacity)s, %(introduction)s, %(Ptable_params)s)" - # cursor.executemany(sql_insert, new_data) - - connection.commit() - - def handleSingleSSD(self, record): - record['price'] = int(record['price']) - introd = eval(record['introduction']) - p_table = eval(record['Ptable_params']) - - # 清洗接口 - s = record['interface'] - index = s.find('接口') - record['interface'] = s[:index] - - # 清洗容量 (以TB为单位的0.25的倍数的浮点数) - capacity = record['total_capacity'] - if capacity == '960GB-1TB': - capacity = 1.0 - elif capacity == '(480-512)GB': - capacity = 0.5 - elif capacity == '(240-256)GB': - capacity = 0.25 - elif capacity == '(120-128)GB': - capacity = 0.125 - elif capacity == '2TB及以上': - pat = r'\dT|\d+G|\d\.\d*T' - res = re.search(pat, capacity) - if res: - res = res.group() - if res and res[-1] == 'T': - capacity = round(eval(res[:-1])) - elif res and res[-1] == 'G': - capacity = eval(res[:-1]) // 250 * 0.25 - else: - print("Error in converting capacity") - print(res) - print(record) - exit(1) - else: - name = record['name'] - pat = r'\dT|\d+G|\d\.\d*T' - res = re.search(pat, name) - if res: - res = res.group() - else: - res = '0T' - if res and res[-1] == 'T': - capacity = round(eval(res[:-1])) - elif res and res[-1] == 'G': - capacity = eval(res[:-1]) // 250 * 0.25 - else: - print("Error in converting capacity") - print(res) - print(record) - exit(1) - record['total_capacity'] = capacity - - # 清洗评论和好评率 - record['comment_num'], record['praise_rate'] = self.washComments( - record['comment_num'], record['praise_rate']) - # 清洗 brand - record['brand'] = self.washBrand(record['brand']) - - return record - - def cleanSSD(self): - ''' - description: 清洗 CPU 数据 - ''' - connection = pymysql.connect( - host=MYSQL_HOSTS, - port=MYSQL_PORT, - user=MYSQL_USER, - passwd=MYSQL_PASSWORD, - db=MYSQL_DB, - charset="utf8") - # 获取游标 - cursor = connection.cursor(cursor=pymysql.cursors.DictCursor) - - cursor.execute("drop table " + self.accessory_type) - cursor.execute( - "create table test."+self.accessory_type+" as select * from computer_accessories."+self.accessory_type) - - instruct = "alter table " + self.accessory_type + " modify price int default NULL" - row = cursor.execute(instruct) # 返回被影响的行数 - cursor.execute("select * from " + self.accessory_type) - data = cursor.fetchall() # 以字典列表的形式读出表中所有数据 - - # 数据清洗 - data_len = len(data) - # print(data_len) - for i in range(data_len): - # 逐条数据处理 - record = data[i] - # 清洗数据 - data[i] = self.handleSingleSSD(record) - - # 清空表 - cursor.execute("truncate table " + self.accessory_type) - # 将评论数和好评率修改为 int 类型 - instruct = "alter table "+self.accessory_type+" modify comment_num int default 0" - row = cursor.execute(instruct) # 返回被影响的行数 - instruct = "alter table "+self.accessory_type+" modify praise_rate int default 0" - row = cursor.execute(instruct) # 返回被影响的行数 - instruct = "alter table "+self.accessory_type + \ - " modify total_capacity float default 0" - row = cursor.execute(instruct) # 返回被影响的行数 - # 重新写入 - sql_insert = "INSERT INTO ssd (id, name, comment_num, praise_rate, shop_name, price, link,"\ - "brand, interface, total_capacity, introduction, Ptable_params) VALUES (%(id)s, %(name)s, %(comment_num)s,"\ - "%(praise_rate)s, %(shop_name)s, %(price)s, %(link)s, %(brand)s, %(interface)s, "\ - "%(total_capacity)s, %(introduction)s, %(Ptable_params)s)" - cursor.executemany(sql_insert, data) - - connection.commit() - - def handleSingleMemory(self, record): - record['price'] = int(record['price']) - introd = eval(record['introduction']) - p_table = eval(record['Ptable_params']) - - # 清洗容量 (以TB为单位的0.25的倍数的浮点数) - capacity = record['total_capacity'] - if '及' not in capacity and '没' not in capacity: - capacity = int(capacity[:-2]) - else: - pat = r'\d+G' - name = record['name'] - res = re.search(pat, name) - if res: - res = res.group() - - if res and res[-1] == 'G': - capacity = eval(res[:-1]) - else: - print("Error in converting capacity") - print(res) - print(record) - exit(1) - - record['total_capacity'] = capacity - - # 清洗评论和好评率 - record['comment_num'], record['praise_rate'] = self.washComments( - record['comment_num'], record['praise_rate']) - # 清洗 brand - record['brand'] = self.washBrand(record['brand']) - - return record - - def cleanMemory(self): - ''' - description: 清洗 内存 数据 - ''' - connection = pymysql.connect( - host=MYSQL_HOSTS, - port=MYSQL_PORT, - user=MYSQL_USER, - passwd=MYSQL_PASSWORD, - db=MYSQL_DB, - charset="utf8") - # 获取游标 - cursor = connection.cursor(cursor=pymysql.cursors.DictCursor) - - cursor.execute("drop table " + self.accessory_type) - cursor.execute( - "create table test."+self.accessory_type+" as select * from computer_accessories."+self.accessory_type) - - instruct = "alter table " + self.accessory_type + " modify price int default NULL" - row = cursor.execute(instruct) # 返回被影响的行数 - cursor.execute("select * from " + self.accessory_type) - data = cursor.fetchall() # 以字典列表的形式读出表中所有数据 - - # 数据清洗 - data_len = len(data) - # print(data_len) - new_data = [] - for i in range(data_len): - # 逐条数据处理 - record = data[i] - name = record['name'] - if '套装' in name: - continue - # 清洗数据 - new_data.append(self.handleSingleMemory(record)) - - # 清空表 - cursor.execute("truncate table " + self.accessory_type) - # 将评论数和好评率修改为 int 类型 - instruct = "alter table "+self.accessory_type+" modify comment_num int default 0" - row = cursor.execute(instruct) # 返回被影响的行数 - instruct = "alter table "+self.accessory_type+" modify praise_rate int default 0" - row = cursor.execute(instruct) # 返回被影响的行数 - instruct = "alter table "+self.accessory_type + \ - " modify total_capacity int default 0" - row = cursor.execute(instruct) # 返回被影响的行数 - # 重新写入 - sql_insert = "INSERT INTO memory (id, name, comment_num, praise_rate, shop_name, price, link,"\ - "brand, frequency, total_capacity, memory_num, appearance, ddr_gen, introduction, "\ - "Ptable_params) VALUES (%(id)s, %(name)s, %(comment_num)s, %(praise_rate)s, %(shop_name)s, %(price)s"\ - ", %(link)s, %(brand)s, %(frequency)s, %(total_capacity)s, %(memory_num)s, %(appearance)s, "\ - "%(ddr_gen)s, %(introduction)s, %(Ptable_params)s)" - cursor.executemany(sql_insert, new_data) - - connection.commit() - - def handleSinglePow(self, record): - record['price'] = int(record['price']) - introd = eval(record['introduction']) - p_table = eval(record['Ptable_params']) - - # 接线类型 - record['modularization'] = introd['接线类型'] - - # 清洗 size - pat = r'[A-Z]+' - size = record['size'] - res = re.search(pat, size) - if res: - size = res.group() - else: - print("No size info") - record['size'] = size - - # 明确功率 - ss = p_table['规格'].get('额定功率', 0) - if ss: - record['power'] = int(ss[:-1]) - else: - record['power'] = ss - - # 清洗评论和好评率 - record['comment_num'], record['praise_rate'] = self.washComments( - record['comment_num'], record['praise_rate']) - # 清洗 brand - record['brand'] = self.washBrand(record['brand']) - - return record - - def cleanPowerSupply(self): - connection = pymysql.connect( - host=MYSQL_HOSTS, - port=MYSQL_PORT, - user=MYSQL_USER, - passwd=MYSQL_PASSWORD, - db=MYSQL_DB, - charset="utf8") - # 获取游标 - cursor = connection.cursor(cursor=pymysql.cursors.DictCursor) - - cursor.execute("drop table " + self.accessory_type) - cursor.execute( - "create table test."+self.accessory_type+" as select * from computer_accessories."+self.accessory_type) - - add_col = "alter table "+self.accessory_type + \ - " add column modularization VARCHAR(255) default NULL AFTER size " - cursor.execute(add_col) - - instruct = "alter table " + self.accessory_type + " modify price int default NULL" - row = cursor.execute(instruct) # 返回被影响的行数 - cursor.execute("select * from " + self.accessory_type) - data = cursor.fetchall() # 以字典列表的形式读出表中所有数据 - - # 数据清洗 - data_len = len(data) - # print(data_len) - new_data = [] - for i in range(data_len): - # 逐条数据处理 - record = data[i] - size = record['size'] - if size == '无': - continue - name = record['name'] - if '套装' in name: - continue - # 清洗数据 - new_data.append(self.handleSinglePow(record)) - - # 清空表 - cursor.execute("truncate table " + self.accessory_type) - # 将评论数和好评率修改为 int 类型 - instruct = "alter table "+self.accessory_type+" modify comment_num int default 0" - row = cursor.execute(instruct) # 返回被影响的行数 - instruct = "alter table "+self.accessory_type+" modify praise_rate int default 0" - row = cursor.execute(instruct) # 返回被影响的行数 - instruct = "alter table "+self.accessory_type+" modify power int default 0" - row = cursor.execute(instruct) # 返回被影响的行数 - - # 重新写入 - sql_insert = "INSERT INTO power_supply (id, name, comment_num, praise_rate, shop_name, price, link,"\ - "brand, tags, power, size, modularization, transfer_efficiency, introduction, Ptable_params) VALUES (%(id)s, %(name)s, %(comment_num)s,"\ - "%(praise_rate)s, %(shop_name)s, %(price)s, %(link)s, %(brand)s, %(tags)s, %(power)s, "\ - "%(size)s, %(modularization)s, %(transfer_efficiency)s, %(introduction)s, %(Ptable_params)s)" - # cursor.executemany(sql_insert, new_data) - - for i in range(len(new_data)): - try: - cursor.execute(sql_insert, new_data[i]) - except: - print(new_data[i]) - exit(1) - - connection.commit() - - def main(self): - t = self.accessory_type - if t == 'all': - self.cleanCPU() - self.cleanMotherboard() - self.cleanGraphicsCard() - self.cleanCPURadiator() - self.cleanCase() - self.cleanHDD() - self.cleanSSD() - self.cleanMemory() - self.cleanPowerSupply() - elif t == 'cpu': - self.cleanCPU() - elif t == 'motherboard': - self.cleanMotherboard() - elif t == 'graphics_card': - self.cleanGraphicsCard() - elif t == 'cpu_radiator': - self.cleanCPURadiator() - elif t == 'computer_case': - self.cleanCase() - elif t == 'hdd': - self.cleanHDD() - elif t == 'ssd': - self.cleanSSD() - elif t == 'memory': - self.cleanMemory() - elif t == 'power_supply': - self.cleanPowerSupply() - else: - print(self.accessory_type) - print("Wrong name!") - - -if __name__ == "__main__": - # washer = DataCleaning('power_supply') - washer = DataCleaning('graphics_card') - # washer = DataCleaning('motherboard') - washer.main()