Azure Blob异步上传失败无异常/状态返回问题排查求助

可能的根因分析 #

• 异步调用未正确等待：如果定时器触发器中调用上传方法时未使用await，任务会在后台执行，函数宿主可能提前回收资源，导致后续上传任务被终止，且未捕获到异常（未等待的任务异常会被静默吞掉）。
• 连接字符串失效：应用停用数月后，Azure存储账户可能发生密钥轮换、权限变更，旧连接字符串失去效力，但部分操作可能不会立即抛出明确异常。
• 流位置未重置：如果循环复用同一个Stream对象，上传后流的Position会停在末尾，后续上传会写入空内容，看似“成功”但实际无数据。
• 存储账户网络限制：停用期间存储账户可能新增防火墙规则、虚拟网络配置，导致函数应用无法访问Blob存储，部分场景下不会抛出StorageException。

代码修复方案（含异常捕获与状态码记录） #

修改上传方法，新增异常捕获逻辑、流位置重置，并记录上传状态码：

public async Task UploadToAzureBlobStorageAsync(Stream stream, string remoteFilePath, string connectionString)
{
    try
    {
        BlobServiceClient blobServiceClient = new BlobServiceClient(connectionString);
        BlobContainerClient containerClient = blobServiceClient.GetBlobContainerClient("myblob");

        if (!await containerClient.ExistsAsync())
        {
            _logger.LogWarning("目标容器不存在，已创建新容器");
            await containerClient.CreateAsync();
        }

        BlobClient blobClient = containerClient.GetBlobClient(remoteFilePath);
        
        // 重置流位置到起始点，避免复用流时上传空内容
        stream.Position = 0;
        
        var uploadResult = await blobClient.UploadAsync(stream, true);
        
        // 记录上传成功的状态码与ETag，验证上传结果
        _logger.LogInformation($"文件 {remoteFilePath} 上传成功，状态码：{(int)uploadResult.Value.Status}，ETag：{uploadResult.Value.ETag}");
    }
    catch (StorageException ex)
    {
        // 提取Azure存储专属的状态码与详细错误信息
        int statusCode = ex.RequestInformation.HttpStatusCode;
        string errorDetails = ex.RequestInformation.ExtendedErrorInformation?.ErrorMessage ?? ex.Message;
        _logger.LogError($"文件 {remoteFilePath} 上传失败，状态码：{statusCode}，错误信息：{errorDetails}");
        // 重新抛出异常，确保上层触发器的try-catch能捕获
        throw;
    }
    catch (Exception ex)
    {
        _logger.LogError($"文件 {remoteFilePath} 上传发生未知错误：{ex.Message}", ex);
        throw;
    }
}

同时确保定时器触发器中正确等待所有上传任务：

public async Task TimerTrigger([TimerTrigger("0 */5 * * * *")] TimerInfo myTimer, ILogger log)
{
    try
    {
        var filesToUpload = GetUploadFileList(); // 替换为你的文件列表获取逻辑
        // 推荐用Task.WhenAll批量等待，提升效率
        var uploadTasks = filesToUpload.Select(file => 
        {
            using var stream = File.OpenRead(file.LocalPath);
            return UploadToAzureBlobStorageAsync(stream, file.RemotePath, _connectionString);
        });
        
        await Task.WhenAll(uploadTasks);
        log.LogInformation("批量上传任务全部完成");
    }
    catch (Exception ex)
    {
        log.LogError("批量上传失败：{Message}", ex.Message);
    }
}

排查步骤 #

• 验证连接字符串：登录Azure门户，复制存储账户的最新连接字符串，替换函数应用配置中的旧值，测试上传。
• 检查存储网络配置：临时将存储账户的防火墙设置改为“允许所有网络”，测试是否能正常上传，排查网络限制问题。
• 查看函数日志：在Azure门户的函数应用“监控”->“日志”中，查看详细的错误日志，尤其是StorageException的状态码（如403权限不足、404资源不存在、503服务不可用等）。
• 验证流的有效性：确保每个上传任务使用独立的Stream实例，或在上传前强制重置stream.Position = 0。

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