Azure Functions + EventHub批处理延迟持续升高问题排查

监控观测到两个异常表现：

• 批处理延迟持续攀升
• 出站消息数量持续下降

当前Function的核心逻辑为向Blob存储执行追加写入操作，但Blob存储侧的监控指标显示服务状态完全正常，无报错、无限流、可用性达标，无法直接定位延迟升高原因。

Function事件处理逻辑 #

const parsedEvents = eventHubMessages.map((event) => {
    try {
        return JSON.parse(event);
    } catch (error) {
        context.log(`Error: cannot parse next event: ${event}`);
        return {};
    }
});

for (const event of parsedEvents) {
    const { id } = event;

    const data = {
        data: 'data',
    };

    const filename = `${id}.log`;

    await blob.append(filename, JSON.stringify(data));
}

自定义Blob操作类实现 #

class AzureStorage {
    constructor(config) {
        this.config = config;
        this.blobServiceClient = BlobServiceClient.fromConnectionString(this.config.storageConnectionString);
        this.containerClient = this.blobServiceClient.getContainerClient(this.config.containerName);
    }

    async append(filename, data) {
        const client = this.containerClient.getAppendBlobClient(filename);
        await client.createIfNotExists();
        await client.appendBlock(data, data.length);
    }
}

问题根因 #

延迟持续升高的核心原因是Blob写入逻辑存在冗余请求：原代码每次执行append追加操作前，都会无条件调用client.createIfNotExists()方法。该方法每次执行都会向Blob存储发起独立的HTTP请求校验Blob是否存在，即使目标Blob早已创建完成，这部分请求的网络开销会随着写入次数线性累积，直接拉高单批消息的总处理时长。
当消息生产速度超过Function实际处理速度时，延迟会不断堆积，最终表现为批处理延迟持续上涨、处理完成的出站消息吞吐量持续下降。由于这些存在性校验请求全部为正常成功请求，Blob存储侧的服务健康指标不会出现异常，因此无法从存储监控中直接发现问题。

修复方案 #

调整Blob追加写入逻辑，移除每次写入前的强制存在性校验，改为异常兜底的懒创建模式：

• 写入时优先直接调用client.appendBlock尝试追加数据
• 捕获调用抛出的异常，若判定为Blob不存在的错误，则先执行client.create()创建目标追加Blob，再重新调用client.appendBlock完成本次写入

调整后，仅首次写入新Blob时会触发创建流程，后续追加操作不会产生额外的校验请求开销，延迟问题即可解决。

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