Python实现将日志写入到数据表中
为了将日志信息写入数据库表,你可以使用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
),并修改数据库连接和查询语句以适配你的数据库系统。
评论已关闭