如何通过Push notifications跟踪Google Sheets指定工作表变更并避免无限循环

单工作表跟踪的实现 #

Google Drive API的变更推送是整个电子表格文档粒度的，原生不支持单个工作表（底部tab）级别的订阅配置，不存在可以指定只监听工作表A的接口参数，文档内任意工作表的编辑、结构调整、格式修改都会触发推送回调。

正确的实现方式：

• 本地缓存每次处理完成时，工作表A的状态快照：存工作表A实际业务数据范围的内容哈希、对应文档修订版本号即可
• 每次收到推送回调，不要直接执行业务写操作，先调用Sheets API拉取工作表A你关心的固定业务范围的最新数据，计算哈希和本地缓存比对：如果哈希完全一致，说明本次变更和工作表A无关，直接终止流程即可
• 不要浪费时间解析推送回调的请求头、请求体找工作表变更标识，推送携带的信息只有文档ID、通道ID、变更时间这类文件级元数据，根本不会包含具体哪个工作表发生变更的字段。

无限循环问题修复 #

用三层防护组合可以彻底解决循环问题，没有遗漏：

• 第一层：操作者校验。收到推送后先查本次文档变更的触发账号，如果是你API调用使用的服务账号/自有授权账号，说明变更是应用自己写入触发的，直接丢弃请求不进业务逻辑
• 第二层：内容哈希校验。就是前面提到的工作表A内容比对——你写入工作表B的操作不会改动工作表A的任何内容，这时候拉取A表算出的哈希和缓存值完全一致，直接终止流程
• 第三层：短周期幂等锁。给每个文档ID加10-15秒的处理冷却时间，冷却期内收到的同文档推送直接跳过，兜底避免接口抖动、并发请求导致的重复触发。

核心逻辑伪代码 #

import hashlib
import time

# 本地缓存，单实例部署直接用内存就行，多实例部署换成Redis
cache = {}
# 替换成你自己API调用使用的服务账号邮箱
APP_ACCOUNT = "your-app-service-account@xxx.iam.gserviceaccount.com"

def calc_sheet_a_hash(spreadsheet_id):
    # 只拉工作表A存业务数据的范围，不要拉全表省配额
    resp = sheets_client.spreadsheets().values().get(
        spreadsheetId=spreadsheet_id,
        range="工作表A!A2:Z5000" # 替换成你实际的业务数据范围
    ).execute()
    values = resp.get("values", [])
    return hashlib.md5(str(values).encode("utf-8")).hexdigest()

def push_callback(request):
    file_id = request.headers.get("X-Goog-Resource-ID")
    now_ts = int(time.time())

    # 幂等锁校验
    cache_info = cache.get(file_id, {})
    if cache_info.get("last_process", 0) > now_ts - 12:
        return "success"

    # 操作者校验：拉取该文件最新变更记录的触发者
    latest_change = get_latest_file_change(file_id)
    if latest_change["actor"]["user"]["emailAddress"] == APP_ACCOUNT:
        return "success"

    # 工作表A内容校验
    current_hash = calc_sheet_a_hash(file_id)
    if current_hash == cache_info.get("last_a_hash", ""):
        return "success"

    # 所有校验通过，执行业务逻辑：往工作表B写数据
    write_to_sheet_b(spreadsheet_id)

    # 更新缓存
    cache[file_id] = {
        "last_a_hash": current_hash,
        "last_process": now_ts
    }
    return "success"

注意：拉取工作表A数据时一定要限定固定业务范围，不要拉取整张工作表，否则空单元格、格式变动也会导致哈希变化，产生不必要的处理逻辑，还会浪费Sheets API配额。

内容的提问来源于stack exchange，提问作者Александр Хворостенко