如何检查线程中运行的SQL查询参数并抑制异常

我有一组线程，每个线程调用run()函数，该函数接收一个包含SQL查询的列表作为参数。部分查询无效，会在run()函数中抛出异常。在无法修改run()函数的前提下，能否在线程内检查当前运行的是哪个查询，从而抑制对应异常？

原代码示例（存在错误）：

threads = []
for _ in range(x):
    t = Thread(target = run(), args=[list_of_queries])
    threads.append(t)

for t in threads:
    if # 检查t.start()后是否在运行无效查询，然后抑制run()抛出的错误
       # 此处逻辑无法直接实现
    else: # 正常运行

因为线程启动后无法直接干预其内部执行逻辑，且不能修改run()函数，最可行的办法是给run()套一层包装函数，在包装里逐个处理查询并捕获对应异常：

步骤1：编写包装函数 #

写一个safe_run函数，遍历查询列表，把每个查询单独传给run()（保持run()的参数格式要求），用try-except捕获单个查询的异常，实现精准抑制：

def safe_run(query_list):
    for idx, query in enumerate(query_list):
        try:
            # 单个查询包装成列表，符合run()的参数要求
            run([query])
            print(f"查询 {idx} 执行成功: {query}")
        except Exception as e:
            # 抑制该查询的异常，可按需记录日志
            print(f"查询 {idx} 执行失败，已抑制异常: {query}，错误: {str(e)}")
            # 继续执行下一个查询，不受当前异常影响

步骤2：修正线程创建逻辑 #

原代码中target=run()是错误的（会直接在主线程执行run()，而非线程内调用），要改成传入包装函数safe_run作为目标：

from threading import Thread

threads = []
x = 3  # 示例线程数
list_of_queries = ["SELECT * FROM valid_table", "INVALID SQL", "SELECT * FROM users"]

for _ in range(x):
    # target传函数对象（不加括号），args传查询列表（注意是元组格式）
    t = Thread(target=safe_run, args=(list_of_queries,))
    threads.append(t)

# 启动所有线程
for t in threads:
    t.start()

# 可选：等待所有线程执行完成
for t in threads:
    t.join()

关键说明 #

• 如果run()必须接收完整的查询列表（不能拆分单个查询调用），且run()遇到异常就终止整个列表执行，那无法直接抑制单个查询的异常，只能提前预检查查询有效性，过滤掉无效查询后再传给run()
• 包装函数的核心是把批量查询拆成单个执行，从而实现对每个查询的异常精准控制，完全不需要修改原run()函数

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