定时任务中调用类的方法疑似获取不到

我在使用apscheduler做一个定时任务项目,脚本代码中需要连接数据库做一些操作。所以写了一个这样的类来调用。但是在任务过程中会时常发生任务堵塞情况,经添加日志后发现是在某一次任务执行过程中,调用db_advertise对象的某个方法似乎无法唤起或者找不到这个对象(也可能这个对象死掉了)。导致程序一致卡死在这一步,既不报错,也没法终止。

以下是类的代码(config.py)

from dbutils.pooled_db import PooledDB
import pymysql
import configparser
import threading
import time
parse = configparser.ConfigParser()
parse.read("./app/config.ini", encoding='UTF-8')



class DbMysql(object): 

    def __init__(self,host,port,user,password,database):
        self.POOL = PooledDB(
            creator=pymysql,  # 使用链接数据库的模块
            maxconnections=None,  # 连接池允许的最大连接数,0和None表示不限制连接数
            mincached=0,  # 初始化时,链接池中至少创建的空闲的链接,0表示不创建
            maxcached=1,  # 链接池中最多闲置的链接,0和None不限制
            # maxshared=1,  # 链接池中最多共享的链接数量,0和None表示全部共享
            blocking=True,  # 连接池中如果没有可用连接后,是否阻塞等待。True,等待;False,不等待然后报错
            maxusage=None,  # 一个链接最多被重复使用的次数,None表示无限制
            setsession=[],  # 开始会话前执行的命令列表。如:["set datestyle to ...", "set time zone ..."]
            ping=1,
            host = host,
            port = int(port),
            user = user,
            password = password,
            database = database,
            charset='utf8'
        )
    # 连接数据库
    def connect(self):
        conn = self.POOL.connection()
        cursor = conn.cursor(cursor=pymysql.cursors.DictCursor)
        return conn,cursor
    def close(self,conn,cursor):
        cursor.close()  # 关闭游标
        conn.close()  # 关闭数据库
    def select(self,sql):
        conn,cursor = self.connect()
        cursor.execute(sql)
        data = cursor.fetchall()
        self.close(conn,cursor)
        return data
    def insertmany(self,query,rows):
        conn,cursor = self.connect()
        try:
            cursor.executemany(query,rows)
            conn.commit()
        except BaseException as e:
            conn.rollback()
        finally:
            self.close(conn,cursor)

    def insert(self,query,row):
        conn,cursor = self.connect()
        try:
            cursor.execute(query,row)
            conn.commit()
        except BaseException as e:
            conn.rollback()
        finally:
            self.close(conn,cursor)

    def update(self,sql):
        conn,cursor = self.connect()
        data = None
        try:
            data = cursor.execute(sql)
            conn.commit()
        except BaseException as e:
            conn.rollback()
        finally:
            self.close(conn,cursor)
        return data

db_advertise = DbMysql(
    parse.get('db_advertise','host'),
    parse.get('db_advertise','port'),
    parse.get('db_advertise','user'),
    parse.get('db_advertise','password'),
    parse.get('db_advertise','database')
)

任务中调用的方法是from config import db_advertise
想请教下这是由于什么原理导致的,有什么办法可以避免?

讨论数量: 1

补充:发生该错误的场景有点随机的,任务启动后一般都会正常,只是在某一个随机时间点会发生这种情况,所以我猜测是不是类的实例化对象死掉了导致

1年前 评论

讨论应以学习和精进为目的。请勿发布不友善或者负能量的内容,与人为善,比聪明更重要!