如何在host.json中定义多个Azure TaskHub适配多Durable Functions？

你之前尝试的host.json配置方式不正确，因为durableTask节点本身是对象类型，不支持重复字段或数组格式。要实现多个独立的TaskHub（含独立存储/配置），正确的配置和使用方式如下：

1. 在host.json中配置多TaskHub的独立参数 #

通过durableTask.hubs节点定义每个TaskHub的专属配置（如果需要独立存储，必须配置此节；若仅需隔离数据但共用存储，可跳过此步，直接在函数中指定TaskHubName）：

{
  "version": "2.0",
  "extensions": {
    "http": { "routePrefix": "" },
    "durableTask": {
      // 全局默认配置（可选，未指定TaskHub的函数会使用此配置）
      "hubName": "DefaultHub",
      "storageProvider": {
        "connectionStringName": "AzureWebJobsStorage"
      },
      // 自定义多TaskHub配置
      "hubs": {
        "TaskHub1": {
          "storageProvider": {
            "connectionStringName": "StorageConn_TaskHub1"
          },
          "partitionCount": 4 // 其他专属配置，比如分区数
        },
        "TaskHub2": {
          "storageProvider": {
            "connectionStringName": "StorageConn_TaskHub2"
          },
          "partitionCount": 2
        }
      }
    }
  }
}

• 每个hubs下的key就是TaskHub的名称，对应的值包含该TaskHub的存储连接字符串、分区数等专属配置。
• 需要在local.settings.json或应用服务的"配置"中，添加对应的存储连接字符串（比如StorageConn_TaskHub1和StorageConn_TaskHub2）。

2. 在函数中指定使用的TaskHub #

在编排器函数、客户端触发函数上，通过[TaskHub]属性明确指定对应的TaskHub名称：

示例：TaskHub1对应的函数 #

[FunctionName("Orchestrator_TaskHub1")]
[TaskHub("TaskHub1")]
public static async Task RunOrchestrator1(
    [OrchestrationTrigger] IDurableOrchestrationContext context)
{
    // 编排器业务逻辑
}

[FunctionName("HttpStart_TaskHub1")]
[TaskHub("TaskHub1")]
public static async Task<IActionResult> HttpStart1(
    [HttpTrigger(AuthorizationLevel.Anonymous, "post")] HttpRequest req,
    [DurableClient(TaskHub = "TaskHub1")] IDurableOrchestrationClient starter,
    ILogger log)
{
    string instanceId = await starter.StartNewAsync("Orchestrator_TaskHub1", null);
    return starter.CreateCheckStatusResponse(req, instanceId);
}

示例：TaskHub2对应的函数 #

[FunctionName("Orchestrator_TaskHub2")]
[TaskHub("TaskHub2")]
public static async Task RunOrchestrator2(
    [OrchestrationTrigger] IDurableOrchestrationContext context)
{
    // 另一个编排器的业务逻辑
}

[FunctionName("HttpStart_TaskHub2")]
[TaskHub("TaskHub2")]
public static async Task<IActionResult> HttpStart2(
    [HttpTrigger(AuthorizationLevel.Anonymous, "post")] HttpRequest req,
    [DurableClient(TaskHub = "TaskHub2")] IDurableOrchestrationClient starter,
    ILogger log)
{
    string instanceId = await starter.StartNewAsync("Orchestrator_TaskHub2", null);
    return starter.CreateCheckStatusResponse(req, instanceId);
}

关键说明 #

• 每个TaskHub的数据（包括实例状态、队列消息等）完全隔离，即使共用存储账户，不同hubName也不会互相干扰。
• 如果不需要独立存储，仅需数据隔离，可简化配置：只在函数上标注[TaskHub("XXX")]，不用修改host.json的hubs节点，所有TaskHub共用默认存储配置。

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