.NET 6隔离进程Azure Function使用Service Bus及TimerTrigger问题

一、Service Bus 功能实现 #

1. 所需NuGet依赖 #

安装以下稳定版包即可，不要混用进程内模型的WebJobs扩展包：

• Microsoft.Azure.Functions.Worker：隔离进程模型核心运行时
• Microsoft.Azure.Functions.Worker.Sdk：隔离进程模型编译SDK
• Microsoft.Azure.Functions.Worker.Extensions.Http：HTTP触发器支持
• Microsoft.Azure.Functions.Worker.Extensions.ServiceBus：Service Bus触发器、输出绑定支持
• 可选：Microsoft.Azure.Functions.Worker.Extensions.Http.NewtonsoftJson：需要用Newtonsoft.Json做序列化时安装
• 你已安装的Microsoft.Azure.Functions.Worker.Extensions.Timer为定时器触发器官方包，版本正确无需更换

2. 项目基础配置 #

隔离进程模型包含显式的Program入口，示例配置如下：

using Microsoft.Extensions.Hosting;

var host = new HostBuilder()
    .ConfigureFunctionsWorkerDefaults()
    // 启用Newtonsoft.Json序列化时取消注释下一行
    // .ConfigureFunctionsWorkerDefaults(builder => builder.UseNewtonsoftJson())
    .Build();

host.Run();

同时确保local.settings.json配置正确，FUNCTIONS_WORKER_RUNTIME必须指定为隔离模式：

{
  "IsEncrypted": false,
  "Values": {
    "AzureWebJobsStorage": "UseDevelopmentStorage=true",
    "FUNCTIONS_WORKER_RUNTIME": "dotnet-isolated",
    "ServiceBusConnection": "你的Service Bus命名空间连接串",
    "MAIL_HOST": "smtp.sendgrid.net",
    "MAIL_PORT": "587",
    "MAIL_USERNAME": "apikey",
    "MAIL_PASSWORD": "你的SendGrid密钥",
    "MAIL_SSL": "false"
  }
}

3. HTTP触发入队消息实现 #

和进程内模型的核心差异是：输出绑定特性从[ServiceBus]改为[ServiceBusOutput]，HTTP请求、响应类型从HttpRequest/ActionResult改为HttpRequestData/HttpResponseData，日志支持构造函数注入。示例代码：

using Microsoft.Azure.Functions.Worker;
using Microsoft.Azure.Functions.Worker.Http;
using Microsoft.Extensions.Logging;
using Newtonsoft.Json;
using System.Net;

public class MailEnqueueHttpFunction
{
    private readonly ILogger<MailEnqueueHttpFunction> _logger;

    public MailEnqueueHttpFunction(ILogger<MailEnqueueHttpFunction> logger)
    {
        _logger = logger;
    }

    [Function("EnqueueMailRequest")]
    public async Task<HttpResponseData> Run(
        [HttpTrigger(AuthorizationLevel.Function, "post", Route = null)] HttpRequestData req,
        [ServiceBusOutput("mail-sender", Connection = "ServiceBusConnection")] IAsyncCollector<dynamic> outgoingMessage)
    {
        var mailPayload = await req.ReadFromJsonAsync<MailViewModel>();
        if (mailPayload == null)
        {
            var badResponse = req.CreateResponse(HttpStatusCode.BadRequest);
            await badResponse.WriteStringAsync("Invalid mail request payload");
            return badResponse;
        }

        await outgoingMessage.AddAsync(JsonConvert.SerializeObject(mailPayload));
        await outgoingMessage.FlushAsync();

        var okResponse = req.CreateResponse(HttpStatusCode.OK);
        await okResponse.WriteStringAsync("Mail request enqueued");
        return okResponse;
    }
}

4. Service Bus触发器处理邮件发送 #

触发器特性[ServiceBusTrigger]命名和进程内一致，但来自Worker扩展的命名空间，日志推荐通过构造函数注入使用。示例代码：

using Microsoft.Azure.Functions.Worker;
using Microsoft.Extensions.Logging;
using Newtonsoft.Json;

public class MailSenderQueueFunction
{
    private readonly ILogger<MailSenderQueueFunction> _logger;

    public MailSenderQueueFunction(ILogger<MailSenderQueueFunction> logger)
    {
        _logger = logger;
    }

    [Function("ProcessMailQueueMessage")]
    public void Run([ServiceBusTrigger("mail-sender", Connection = "ServiceBusConnection")] string myQueueItem)
    {
        try
        {
            var mailHost = Environment.GetEnvironmentVariable("MAIL_HOST") ?? "smtp.sendgrid.net";
            var mailPort = Convert.ToInt32(Environment.GetEnvironmentVariable("MAIL_PORT") ?? "587");
            var mailUsername = Environment.GetEnvironmentVariable("MAIL_USERNAME") ?? "apikey";
            var mailPassword = Environment.GetEnvironmentVariable("MAIL_PASSWORD") ?? "8755faf7-78c9-4389-b3a5-f1578953bc00";
            var ssl = Convert.ToBoolean(Environment.GetEnvironmentVariable("MAIL_SSL") ?? "false");

            using (var mailHelpers = new MailHelpers(mailHost, mailPort, mailUsername, mailPassword, ssl))
            {
                var mail = JsonConvert.DeserializeObject<MailViewModel>(myQueueItem);
                mailHelpers.Send(mail);
            }
        }
        catch (Exception ex)
        {
            _logger.LogError(ex, "Error during sending email.");
        }
    }
}

说明：隔离进程下Service Bus触发器默认自动处理消息锁续订、异常消息重试/死信逻辑，和进程内模型行为一致，无需额外编写消息处理样板代码。如果需要手动完成、死信消息，直接在函数参数中加入ServiceBusMessageActions类型参数即可直接调用相关方法。

二、TimerTrigger无法断点调试解决方案 #

按优先级逐一排查以下问题即可解决：

• 调试器附加时机问题
  你当前使用的CRON表达式* * * * * *为每秒触发一次，本地启动函数时如果调试器附加速度慢于第一次触发时机，就会出现函数正常执行但断点未命中的情况。可以先在函数入口第一行加System.Threading.Thread.Sleep(3000)等待调试器完全附加，或者将CRON表达式调整为0 */1 * * * *（每分钟0秒触发），启动后等待触发点到来即可命中断点。
• 运行时配置错误
  检查local.settings.json中FUNCTIONS_WORKER_RUNTIME是否配置为dotnet-isolated，如果误写为dotnet会按进程内模型加载你的隔离进程程序集，导致运行逻辑异常、断点无法命中。同时必须配置合法的AzureWebJobsStorage连接串（本地调试可填UseDevelopmentStorage=true启用存储模拟器），定时器触发器依赖存储做分布式锁，缺失存储配置会导致触发器运行状态异常。
• 启动模式错误
  确认是通过调试模式启动：Visual Studio中按F5启动（不要选“开始执行不调试”），VS Code中在运行调试面板选择.NET Function调试配置启动，不要直接用dotnet run无调试模式启动。
• SDK版本问题
  将Microsoft.Azure.Functions.Worker和Microsoft.Azure.Functions.Worker.Sdk升级到最新稳定版，旧预览版存在调试器无法正确附加到独立工作进程的已知问题。
• 编译配置问题
  确认当前构建配置为Debug模式，项目属性中未开启代码优化，调试信息格式设置为Portable或Full，Release模式下的编译优化会导致断点无法映射到源码位置。

内容的提问来源于stack exchange，提问作者jack.pop