使用Azure Function从第三方服务器下载文件并存储至Azure Storage

没问题，我来给你详细拆解这个需求的实现方案，包括步骤和优化后的代码示例，确保流程顺畅高效：

核心实现步骤 #

• 创建带HTTP触发器的Azure Function：作为第三方WebHook的接收端点，配置合适的访问权限（比如允许匿名，或者匹配第三方的认证规则），确保第三方能成功触发执行。
• 配置Azure Storage连接：在Function的应用设置中添加你的Storage账户连接字符串（通常用AzureWebJobsStorage键，也可以自定义键名），让Function具备访问Storage服务的权限。
• 实现文件下载+上传逻辑：通过WebHook传递的下载URL和认证token拉取文件内容，直接流式上传到Azure Blob Storage（避免本地存储，提升性能和可靠性）。

优化后的代码示例 #

首先需要安装两个NuGet包：Azure.Storage.Blobs（用于操作Blob Storage）和System.Net.Http（推荐用HttpClient替代WebClient，性能更优）。

using System;
using System.IO;
using System.Net.Http;
using System.Net.Http.Headers;
using System.Threading.Tasks;
using Microsoft.Azure.WebJobs;
using Microsoft.Azure.WebJobs.Extensions.Http;
using Microsoft.AspNetCore.Http;
using Microsoft.Extensions.Logging;
using Azure.Storage.Blobs;

public static class FileTransferFunction
{
    [FunctionName("FileToStorage")]
    public static async Task<IActionResult> Run(
        [HttpTrigger(AuthorizationLevel.Anonymous, "post", Route = null)] HttpRequest req,
        ILogger log)
    {
        log.LogInformation("Received webhook trigger to transfer file.");

        // 从WebHook请求中解析下载URL和认证token（示例中模拟解析，实际要根据第三方WebHook格式调整）
        var requestBody = await new StreamReader(req.Body).ReadToEndAsync();
        // 这里替换成实际的解析逻辑，比如从JSON Body中提取参数
        string downloadUrl = "https://www.server.com/file1.mp4";
        string downloadToken = "your-actual-download-token";
        string storageContainerName = "your-target-container";
        string blobFileName = "file1.mp4"; // 可根据需求自定义文件名

        // 初始化HTTP客户端和Blob客户端
        using var httpClient = new HttpClient();
        httpClient.DefaultRequestHeaders.Authorization = new AuthenticationHeaderValue("Bearer", downloadToken);
        httpClient.DefaultRequestHeaders.Accept.Add(new MediaTypeWithQualityHeaderValue("application/json"));

        try
        {
            // 直接获取文件流，避免本地存储
            using var fileStream = await httpClient.GetStreamAsync(downloadUrl);
            
            // 连接到Blob Storage并上传流
            var blobServiceClient = new BlobServiceClient(Environment.GetEnvironmentVariable("AzureWebJobsStorage"));
            var blobContainerClient = blobServiceClient.GetBlobContainerClient(storageContainerName);
            await blobContainerClient.CreateIfNotExistsAsync(); // 确保目标容器存在
            
            var blobClient = blobContainerClient.GetBlobClient(blobFileName);
            await blobClient.UploadAsync(fileStream, overwrite: true);

            return new OkObjectResult("File transferred to Azure Storage successfully.");
        }
        catch (Exception ex)
        {
            log.LogError(ex, "Error occurred during file transfer.");
            return new BadRequestObjectResult($"Transfer failed: {ex.Message}");
        }
    }
}

关键细节说明 #

• 选择HttpClient的原因：相比WebClient，HttpClient是.NET官方推荐的HTTP客户端，支持更好的异步处理、连接池管理，性能更稳定，尤其适合Azure Function这类无服务器场景。
• 流式传输优势：直接通过流传递文件内容，不需要把整个文件加载到内存或保存到临时文件，对大文件友好，能有效降低资源占用。
• 配置注意点：务必确保Azure Function的应用设置中已正确配置Storage连接字符串，并且Function拥有该Storage账户的写入权限（可通过系统分配身份或连接字符串密钥实现）。
• WebHook参数解析：示例中模拟了参数获取，实际要根据第三方WebHook的规范，从请求Body、Query参数或Headers中提取下载URL和token。

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