Dialogflow ES重复发送Webhook请求问题求助及处理方案咨询

问题描述 #

大约一周前，所有Dialogflow ES Agent在向Google Cloud HTTP Function作为Webhook发送首个请求后的数毫秒内，会触发第二条重复请求，导致Webhook重复处理同一业务逻辑，且两条请求共享相同的responseId。

已知Dialogflow ES Agent默认等待Webhook响应的超时时间为5秒，超时会抛出如下错误，但此前超时场景并不会触发重发：

"webhookStatus": {
    "code": 4,
    "message": "Webhook call failed. Error: DEADLINE_EXCEEDED, State: URL_TIMEOUT, Reason: TIMEOUT_WEB."
  }

尝试用npm node-cache缓存responseId来避免重复处理，但由于重复请求在首个请求处理完成前就已到达，内存级缓存的原子性不足，导致缓存机制无法生效。

可行解决方案 #

1. 改用支持原子操作的分布式缓存 #

内存级缓存（如node-cache）在并发请求场景下无法保证锁的原子性，建议使用支持原子操作的缓存服务：

• 采用Google Cloud Memorystore（Redis）的SETNX命令，在处理请求前尝试以responseId为键设置锁定状态，仅当设置成功的请求才执行业务逻辑，失败的直接返回空响应或缓存结果。
• 核心逻辑示例：

  const redisClient = require('./redis-client');
  const LOCK_TTL = 10; // 锁定时长覆盖Webhook超时时间
  
  async function handleWebhook(req) {
    const responseId = req.body.responseId;
    // 原子性获取锁
    const lockAcquired = await redisClient.set(`lock:${responseId}`, 'processing', 'NX', 'EX', LOCK_TTL);
    
    if (!lockAcquired) {
      // 重复请求，返回缓存结果或空响应
      const cachedResult = await redisClient.get(`result:${responseId}`);
      return {
        statusCode: 200,
        body: cachedResult ? JSON.parse(cachedResult) : {}
      };
    }
  
    try {
      // 执行核心业务逻辑
      const result = await processBusiness(req);
      // 缓存处理结果
      await redisClient.set(`result:${responseId}`, JSON.stringify(result), 'EX', 300);
      return { statusCode: 200, body: result };
    } finally {
      // 可选：主动释放锁，依赖TTL也可自动过期
      await redisClient.del(`lock:${responseId}`);
    }
  }
  

2. 优化Webhook响应速度 #

重复请求可能是Dialogflow ES检测到首请求响应过慢触发的隐性重试，可通过以下方式提速：

• 为Google Cloud HTTP Function配置预留实例，避免冷启动延迟；将函数部署在与Dialogflow ES相同或邻近的区域。
• 剥离非核心逻辑（如日志、数据统计）改为异步处理，优先返回Dialogflow所需的响应内容。
• 替换低效的数据库查询，改用内存缓存存储高频访问数据，减少IO等待时间。

3. 检查Dialogflow与云项目配置 #

确认是否存在配置变更导致的重试触发：

• 进入Dialogflow ES控制台，查看Fulfillment模块，确认是否开启了自定义重试策略。
• 检查Google Cloud项目的VPC网络、防火墙规则，是否存在网络延迟导致请求未及时被Dialogflow接收。
• 核实Agent的Error Handling配置，是否有自动重试的规则被误启用。

4. 用响应状态码终止重试 #

首次处理请求时返回200 OK并缓存结果，后续重复请求直接返回304 Not Modified或缓存的响应内容，明确告知Dialogflow无需继续重试。

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