Python3+SQLite多线程写入报错：无法在事务内启动事务

嘿，这个错误我在做物联网数据采集的项目里碰到过好几次，核心问题不是需要间隔时间启动事务，而是你的事务管理和数据库连接使用方式出了问题，给你几个关键的解决思路：

1. 每次数据库操作后必须收尾事务 #

Python的sqlite3模块默认会在执行INSERT/UPDATE/DELETE这类修改操作时自动开启事务，但如果你不主动调用commit()提交或者rollback()回滚，这个事务会一直处于"活跃"状态，下次再执行操作时就会触发"不能在事务内开事务"的错误。

给你一个标准的数据库写入函数模板，确保事务能正确收尾：

def save_sensor_data(data1, data2):
    # 注意：每个操作单独创建连接，不要共享！
    conn = sqlite3.connect("sensor_db.db")
    cursor = conn.cursor()
    try:
        # 执行插入操作
        cursor.execute(
            "INSERT INTO sensor_readings (sensor1, sensor2) VALUES (?, ?)",
            (data1, data2)
        )
        conn.commit()  # 提交事务，结束当前会话
    except Exception as e:
        conn.rollback()  # 出错必须回滚，避免事务挂起
        print(f"写入失败: {str(e)}")
    finally:
        # 不管成功失败，都要关闭游标和连接
        cursor.close()
        conn.close()

2. 多线程绝对不能共享数据库连接 #

SQLite的连接对象完全不是线程安全的，如果你的GUI线程和传感器采集线程共用同一个连接，很容易导致事务状态混乱，触发各种奇怪的错误。正确的做法是：每个线程在需要操作数据库时，单独创建自己的连接，用完就关闭。

比如你的传感器采集线程可以这么写：

import time

def sensor_collection_loop():
    # 假设running是控制线程启停的全局变量
    global running
    while running:
        # 读取传感器数据
        sensor1_val = read_sensor_1()  # 替换成你的实际读取函数
        sensor2_val = read_sensor_2()
        # 调用上面的写入函数
        save_sensor_data(sensor1_val, sensor2_val)
        # 这里的sleep是控制采集频率，和事务无关
        time.sleep(0.05)

# 启动采集线程，设为守护线程避免阻塞GUI关闭
threading.Thread(target=sensor_collection_loop, daemon=True).start()

3. 排查隐式的未结束事务 #

有时候可能在代码的某个分支里（比如异常处理没写全），执行了修改操作但没提交/回滚，导致事务一直挂着。你可以在操作前加个检查，确保没有活跃的事务：

conn = sqlite3.connect("sensor_db.db")
if conn.in_transaction:
    conn.rollback()  # 先回滚之前的挂起事务
# 再执行你的操作

4. 批量插入提升性能（可选） #

如果你的传感器读取频率很高，频繁的单条插入会拖慢速度，建议攒一批数据再批量写入，这样既减少事务次数，也能提升整体效率：

def batch_save_data(data_batch):
    conn = sqlite3.connect("sensor_db.db")
    cursor = conn.cursor()
    try:
        cursor.executemany(
            "INSERT INTO sensor_readings (sensor1, sensor2) VALUES (?, ?)",
            data_batch
        )
        conn.commit()
    except Exception as e:
        conn.rollback()
        print(f"批量写入失败: {str(e)}")
    finally:
        cursor.close()
        conn.close()

# 采集线程里攒数据
def sensor_collection_loop():
    global running
    data_batch = []
    batch_size = 20  # 每攒20条写一次
    while running:
        sensor1_val = read_sensor_1()
        sensor2_val = read_sensor_2()
        data_batch.append((sensor1_val, sensor2_val))
        if len(data_batch) >= batch_size:
            batch_save_data(data_batch)
            data_batch = []
        time.sleep(0.05)

总的来说，你这个错误的根源就是事务没有被正确关闭，加上多线程共享连接放大了问题，不需要刻意等时间，按照上面的方法调整代码就能解决。

内容的提问来源于stack exchange，提问作者matt