构建Windows Service监听Azure Blob容器并下载新增Blob

嘿Stefan，刚好你已经有了本地文件上传Azure存储的经验，这个反向的「监听容器+下载文件」需求其实可以顺着Azure的生态工具来实现，我给你梳理几个靠谱的方案，结合你提到的JobHost思路来展开：

1. 优先用Event Grid做实时触发，替代低效轮询 #

你之前用FileSystemWatcher监听本地变更，Azure这边最适合的实时触发工具是Azure Event Grid——它能在Blob创建/修改时主动推送事件，比定时轮询容器高效太多。需要先给你的存储账户配置Event Grid订阅，后续可以把事件推送到你的Windows Service能接收的端点（或者用Azure Service Bus做中间件，避免Service离线时丢失事件）。

2. 用JobHost（Azure Functions Runtime）托管监听逻辑 #

如果你想借助JobHost，其实可以把Blob触发的Function打包成自托管的Windows Service，步骤很清晰：

• 创建一个Azure Functions项目，选择Blob触发器模板，用{containerName}占位符实现「监听所有容器」（路径模板写{containerName}/{blobName}即可覆盖所有容器下的Blob变更）
• 把这个Function项目配置为自托管，再通过Microsoft.Extensions.Hosting.WindowsServices包打包成Windows Service

关键代码示例 #

Blob触发器Function（处理下载逻辑）

public class BlobDownloadFunction
{
    private readonly ILocalFileHandler _localFileHandler;

    // 依赖注入本地文件处理服务，和你之前上传逻辑的服务可以复用思路
    public BlobDownloadFunction(ILocalFileHandler localFileHandler)
    {
        _localFileHandler = localFileHandler;
    }

    [FunctionName("BlobDownloadTrigger")]
    public async Task Run(
        [BlobTrigger("{containerName}/{blobName}", Connection = "AzureStorageConn")] Stream blobStream,
        string containerName,
        string blobName,
        ILogger log)
    {
        log.LogInformation($"检测到新Blob: {containerName}/{blobName}");
        
        // 按容器名分类存储到本地，避免文件重名
        var localSavePath = Path.Combine(@"C:\YourLocalRootFolder", containerName, blobName);
        await _localFileHandler.SaveBlobToLocal(blobStream, localSavePath);
        
        log.LogInformation($"已成功下载到本地路径: {localSavePath}");
    }
}

配置自托管Windows Service（Program.cs）

using Microsoft.Extensions.DependencyInjection;
using Microsoft.Extensions.Hosting;

var host = new HostBuilder()
    .ConfigureFunctionsWorkerDefaults()
    .ConfigureServices(services =>
    {
        services.AddScoped<ILocalFileHandler, LocalFileHandler>();
    })
    .UseWindowsService() // 启用Windows Service托管支持
    .Build();

await host.RunAsync();

3. 监听所有容器的注意事项 #

• 确保你的存储账户连接字符串拥有Storage Blob Data Contributor权限，否则无法读取Blob内容
• 如果只想监听新增Blob而非修改，可以在代码里判断Blob的创建时间，或者在Event Grid订阅里过滤事件类型为Microsoft.Storage.BlobCreated
• 服务首次启动时，如果需要同步历史已存在的Blob，可以加个初始化逻辑：遍历所有容器，批量下载未同步的文件

4. 替代方案：自定义Windows Service直接监听Event Grid #

如果不想用JobHost/Functions，也可以完全自定义Windows Service逻辑：

• 给存储账户创建Event Grid订阅，选择Webhook作为端点，指向你的Service暴露的HTTP接口（测试阶段可以用Ngrok做反向代理）
• 或者用Azure Service Bus做中间件：Event Grid把事件推送到Service Bus队列，你的Windows Service消费队列消息后再执行Blob下载

这种方式更灵活，适合需要加入复杂业务判断的场景。

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