Python实现将日志写入到数据表中

这篇文章距离上次修改已过249天，其中的内容可能已经有所变动。

为了将日志信息写入数据库表，你可以使用Python的logging模块配合数据库接口库如sqlite3或pymysql等。以下是一个简单的例子，演示如何将日志信息写入SQLite数据库中。

首先，确保你的环境中已安装sqlite3。

import logging
import sqlite3

# 创建或连接到数据库
db_path = 'logs.db'
conn = sqlite3.connect(db_path)
cursor = conn.cursor()

# 创建日志表
create_table_query = '''
CREATE TABLE IF NOT EXISTS log_records (
    id INTEGER PRIMARY KEY AUTOINCREMENT,
    log_level TEXT,
    log_message TEXT,
    timestamp TEXT
);
'''
cursor.execute(create_table_query)
conn.commit()

# 定义记录日志的处理函数
def log_record(cursor, log_level, message):
    timestamp = logging.Formatter.formatTime(
        logging.Formatter(datefmt='%Y-%m-%d %H:%M:%S'),
        logging.LogRecord(None, logging.NOTSET, None, None, message, None, None)
    )
    insert_query = '''
    INSERT INTO log_records (log_level, log_message, timestamp)
    VALUES (?, ?, ?);
    '''
    cursor.execute(insert_query, (log_level, message, timestamp))
    conn.commit()

# 配置日志记录
logging.basicConfig(level=logging.DEBUG)
logger = logging.getLogger()

# 添加日志监听器，使用自定义的处理函数
handler = logging.StreamHandler()
handler.setLevel(logging.DEBUG)
handler.setFormatter(logging.Formatter('%(levelname)s - %(message)s'))
logger.addHandler(handler)

# 测试日志记录
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')

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

在这个例子中，我们首先创建了一个SQLite数据库和日志表。然后定义了一个函数log_record，它负责将日志信息插入到数据库表中。接着配置了logging模块，并为其添加了一个自定义的处理器，该处理器使用log_record函数来记录日志。最后，我们模拟了一些日志记录，并在结束时关闭了数据库连接。

如果你使用的是MySQL或其他数据库，你需要安装对应的数据库接口库（如pymysql），并修改数据库连接和查询语句以适配你的数据库系统。

Python实现将日志写入到数据表中

评论已关闭

推荐阅读