.NET队列触发函数中如何获取host.json内的maxDequeueCount

方法一：通过构造函数注入IConfiguration（推荐） #

host.json中的配置会自动加载到应用的配置系统中，你可以通过依赖注入IConfiguration读取maxDequeueCount的值，这种方式稳定且在函数的任何代码块（包括catch）中都能访问。

步骤： #

1. 在函数类的构造函数中注入IConfiguration，并读取配置值：

using Microsoft.Extensions.Configuration;
using Microsoft.Azure.Functions.Worker;

public class YourFunctionClass
{
    private readonly int _maxDequeueCount;

    // 构造函数注入IConfiguration
    public YourFunctionClass(IConfiguration configuration)
    {
        // 对应host.json的配置路径：AzureWebJobs:Queues:MaxDequeueCount
        _maxDequeueCount = configuration.GetValue<int>("AzureWebJobs:Queues:MaxDequeueCount");
    }

    [Function("Function1")]
    public async Task Run([QueueTrigger("%QUEUE_NAME%", Connection = "AzureWebJobsStorage")] byte[] queueItem, string id, long dequeueCount)
    {
        try
        {
            DoStuff();
        }
        catch (Exception ex)
        {
            // 直接使用类成员变量，不会为null
            if (dequeueCount <= _maxDequeueCount)
            {
                HandleError1();
            }
            else
            {
                HandleError2();
            }
        }
    }

    private void DoStuff() { /* 你的业务逻辑 */ }
    private void HandleError1() { /* 重试逻辑 */ }
    private void HandleError2() { /* 死信或其他处理 */ }
}

2. 确保host.json中正确配置队列参数：

{
  "version": "2.0",
  "extensions": {
    "queues": {
      "maxDequeueCount": 5 // 自定义的重试次数
    }
  }
}

方法二：通过FunctionContext获取配置 #

如果需要通过FunctionContext获取配置，需注意：

• 优先使用非静态函数类（静态类也可传入FunctionContext，但构造函数注入仅支持非静态类）
• 从FunctionContext的InstanceServices中获取IConfiguration实例

示例代码：

using Microsoft.Extensions.Configuration;
using Microsoft.Azure.Functions.Worker;

public class YourFunctionClass
{
    [Function("Function1")]
    public async Task Run([QueueTrigger("%QUEUE_NAME%", Connection = "AzureWebJobsStorage")] byte[] queueItem, string id, long dequeueCount, FunctionContext context)
    {
        // 从FunctionContext中获取配置实例
        var configuration = context.InstanceServices.GetRequiredService<IConfiguration>();
        int maxDequeueCount = configuration.GetValue<int>("AzureWebJobs:Queues:MaxDequeueCount");

        try
        {
            DoStuff();
        }
        catch (Exception ex)
        {
            if (dequeueCount <= maxDequeueCount)
            {
                HandleError1();
            }
            else
            {
                HandleError2();
            }
        }
    }

    // 其他方法省略
}

关于FunctionContext在catch中为null的说明 #

正常情况下FunctionContext不会在catch块中为null，若出现此问题，可能是：

• 函数绑定阶段抛出异常（此时未进入Run方法逻辑）
• 静态函数的依赖注入配置异常（建议改用非静态类+构造函数注入的方式）

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