python 日志到mysql

import logging
import mysql.connector

# 配置MySQL连接
db_config = {
    'host': 'localhost',
    'user': 'your_username',
    'password': 'your_password',
    'database': 'your_database'
}

# 创建MySQL连接
conn = mysql.connector.connect(**db_config)
cursor = conn.cursor()

# 创建日志表（如果尚未存在）
cursor.execute('''
CREATE TABLE IF NOT EXISTS logs (
    id INT AUTO_INCREMENT PRIMARY KEY,
    message TEXT NOT NULL,
    levelname VARCHAR(50) NOT NULL,
    created_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP
)
''')
conn.commit()

# 配置Python日志记录器
logger = logging.getLogger('example_logger')
logger.setLevel(logging.DEBUG)

# 创建一个自定义的日志处理器，将日志写入MySQL数据库
class MySQLHandler(logging.Handler):
    def emit(self, record):
        log_entry = self.format(record)
        cursor.execute('INSERT INTO logs (message, levelname) VALUES (%s, %s)', (log_entry, record.levelname))
        conn.commit()

# 将自定义处理器添加到日志记录器
logger.addHandler(MySQLHandler())

# 记录日志
logger.debug('This is a debug message')
logger.info('This is an info message')
logger.warning('This is a warning message')
logger.error('This is an error message')
logger.critical('This is a critical message')

# 关闭数据库连接
cursor.close()
conn.close()