spider_work/zhongjian_spider/add_task.py

# -*- coding: utf-8 -*-
# Author : Charley
# Python : 3.10.8
# Date   : 2025/6/9 15:38
from mysql_pool import MySQLConnectionPool
from loguru import logger

"""
519400000，519开头到40万
529300000，529开头到30万
"""

# logger.remove()
# logger.add("./logs/add_{time:YYYYMMDD}.log", encoding='utf-8', rotation="00:00",
#            format="[{time:YYYY-MM-DD HH:mm:ss.SSS}] {level} {message}",
#            level="DEBUG", retention="7 day")

sql_pool = MySQLConnectionPool(log=logger)
# ra_no_list = sql_pool.select_all('select tag_no from zhongjian_record')
# ra_no_list = [i[0] for i in ra_no_list]

info_list = []
for i in range(1, 300001):
    # rating_no_ = f'519{i:06}'
    rating_no_ = f'529{i:06}'
    data_dict = {'tag_no': rating_no_}
    info_list.append(data_dict)
    # if rating_no_ not in ra_no_list:
    #     # print(rating_no_)
    #     info_list.append(rating_no_)
    # else:
    #     logger.debug(f"{rating_no_} is exist")

# sql_pool.insert_many(query='insert into zhongjian_task (tag_no) values (%s)', args_list=info_list, ignore=True)
sql_pool.insert_many(table='zhongjian_task', data_list=info_list, ignore=True)