Azure Function中Blob上传删除的Event Grid触发器间歇性失效问题

核心排查步骤 #

1. 验证Event Grid事件投递状态 #

• 登录Azure门户，进入目标Event Grid订阅，查看指标（Metrics）：重点关注Delivery Success Rate、Failed Events、Dead-lettered Events指标，确认是否存在事件投递失败或死信的情况。
• 检查重试策略：默认Event Grid会对失败事件进行30次递增间隔重试，若重试后仍失败会进入死信队列。确认死信队列配置是否正确，是否有未处理的死信事件。

2. 检查Azure Function运行日志与状态 #

• 进入Function App的监控（Monitor）>日志，按事件ID或时间范围搜索，确认是否存在：
  • 事件已投递但代码处理出错（即使代码包含try/catch，也可能存在未捕获的异步错误）
  • 函数执行超时（默认超时5分钟，处理大PDF文件时容易触发）
• 查看**缩放（Scale Out）**配置：若使用消费计划，确认自动缩放是否正常，是否因并发限制导致事件堆积。

3. 确认存储账户事件过滤配置 #

• 检查Event Grid订阅的过滤条件：确保仅订阅了目标容器（content）的事件，未设置错误的前缀/后缀过滤规则。
• 验证Blob操作的事件触发逻辑：分块上传Blob会触发多次BlobCreated事件，若业务场景存在此类操作，需确认代码是否能正确处理重复事件。

4. 代码层面优化与修复 #

针对你提供的代码，以下几点可优化以提升稳定性：

（1）增强事件追踪日志

在函数handler开头添加事件ID、时间戳等关键信息，方便后续排查：

app.eventGrid('process-event-grid', {
    handler: async (context, eventGridEvent) => {
        try {
            // 新增：记录事件核心信息
            console.log(`Received event [${eventGridEvent.id}]: type=${eventGridEvent.eventType}, time=${eventGridEvent.eventTime}`);
            
            const event = eventGridEvent.eventType;
            const blobUrl = eventGridEvent.data?.url;
            
            if (!blobUrl) {
                console.error("Event data missing 'url':", eventGridEvent);
                return;
            }
            // ... 原有代码
        } catch (error) {
            console.error(`Failed to process event [${eventGridEvent.id}]:`, error);
        }
    }
});

（2）可靠提取Blob名称

原代码通过lastIndexOf('/')提取Blob名称，若URL包含编码字符（如空格转%20）会出错，改用URL对象处理更可靠：

// 替换原blobName提取逻辑
const blobUrlObj = new URL(blobUrl);
const blobName = decodeURIComponent(blobUrlObj.pathname.split('/').pop());

（3）调整函数超时时间

处理大PDF时容易触发默认5分钟超时，在host.json中延长超时：

{
  "version": "2.0",
  "functionTimeout": "10m",
  "logging": {
    "applicationInsights": {
      "samplingSettings": {
        "isEnabled": true,
        "excludedTypes": "Request"
      }
    }
  }
}

（4）优化错误捕获

确保indexBlob和deleteDocument中的错误能被正确追踪，可在函数内部添加更详细的错误上下文：

async function indexBlob(blobName) {
    try {
        console.log(`Starting index for blob: ${blobName}`);
        // ... 原有代码
    } catch (error) {
        console.error(`Failed to index blob ${blobName}:`, error.stack);
    }
}

5. 网络与权限验证 #

• 若Function App部署在VNet中，确认已配置服务端点或私有链接允许Event Grid访问Function。
• 检查Event Grid订阅的身份验证方式：若使用系统分配身份，确认该身份拥有向Function投递事件的权限。

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