如何获取BigQuery查询出错后的成功重试历史

可通过以下3种方式实现获知重试成功查询明细的需求：

1. 复用重试框架自带的事件回调钩子做记录 #

实现重试逻辑时用到的重试器实例，本身支持传入错误触发回调函数：每次检测到可重试错误、准备进入下一轮等待时，会自动执行你定义的回调逻辑，把触发重试的错误信息、等待时长、时间戳等内容存到自定义的存储结构里。
参考实现片段：

from google.api_core import retry
import datetime

# 定义独立的重试事件存储容器
retry_records = []

def log_retry_event(error, wait_seconds):
    # 捕获当前重试触发的异常上下文
    retry_records.append({
        "event_time": datetime.datetime.utcnow(),
        "error_class": type(error).__name__,
        "error_detail": str(error),
        "retry_wait_seconds": wait_seconds
    })

# 初始化带自定义回调的重试器
query_retry_config = retry.Retry(
    predicate=retry.if_exception_type(
        google.cloud.exceptions.ServerError,
        google.cloud.exceptions.ServiceUnavailable
    ),
    on_error=log_retry_event
)

# 后续执行查询时直接传入该重试配置
query_job = client.query(sql, retry=query_retry_config)

当查询最终执行返回成功结果时，关联本次调用对应的重试记录条目，即可明确标记该查询为“经重试成功”的类型。

2. 自定义查询包装层做全链路状态绑定 #

如果默认的回调钩子没法满足把查询明细和重试事件强绑定的需求，可以自己封装一层查询执行逻辑：

• 每次发起查询前，为本次调用生成全局唯一的查询标识，提前初始化对应的状态记录
• 在包装逻辑中捕获首轮尝试抛出的可重试异常，将异常信息、重试次数等内容和当前查询标识绑定存储
• 待重试流程跑完、拿到最终查询结果后，将对应查询标识的状态更新为“执行成功”
• 后续筛选所有绑定了失败异常记录、最终状态为成功的条目，即可得到需要的全量查询明细

注意：需要严格把重试事件和当前查询的标识做一一绑定，避免因重试逻辑的循环执行，出现不同查询的失败记录串号的问题。

3. 从客户端日志流中反向筛选匹配 #

如果不想改动现有代码的重试逻辑，可以将BigQuery Python客户端的日志级别调整到INFO，让日志输出覆盖所有中间的请求交互记录：

• 从日志中提取所有关联同一个查询标识的、状态为“可重试失败”的请求记录
• 再匹配同一个查询标识下最终状态为“成功”的请求条目，反向推导得到所有经历过重试才成功的查询
• 该方式不需要改动核心业务逻辑，但对日志的结构化程度要求较高，需要保证日志里能稳定提取到查询ID和请求状态字段

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