ARM模板无法在单个命名空间创建多Event Hub及对应Consumer Group

直接给你能跑通的ARM模板配置，核心是用copy循环批量创建资源，同时通过变量关联每个Event Hub对应的Consumer Group：

{
  "$schema": "https://schema.management.azure.com/schemas/2019-04-01/deploymentTemplate.json#",
  "contentVersion": "1.0.0.0",
  "variables": {
    "namespaceName": "<你的命名空间名称>",
    "eventHubs": [
      {
        "name": "eventhub-01",
        "consumerGroups": ["cg-01-01", "cg-01-02"]
      },
      {
        "name": "eventhub-02",
        "consumerGroups": ["cg-02-01"]
      },
      {
        "name": "eventhub-03",
        "consumerGroups": ["cg-03-01", "cg-03-02", "cg-03-03"]
      }
    ],
    "serviceBusApiVersion": "2021-11-01"
  },
  "resources": [
    // 创建Service Bus命名空间
    {
      "type": "Microsoft.ServiceBus/namespaces",
      "apiVersion": "[variables('serviceBusApiVersion')]",
      "name": "[variables('namespaceName')]",
      "location": "[resourceGroup().location]",
      "sku": {
        "name": "Standard",
        "tier": "Standard"
      },
      "properties": {}
    },
    // 批量创建Event Hub
    {
      "type": "Microsoft.ServiceBus/namespaces/eventhubs",
      "apiVersion": "[variables('serviceBusApiVersion')]",
      "name": "[concat(variables('namespaceName'), '/', variables('eventHubs')[copyIndex()].name)]",
      "copy": {
        "name": "eventHubCopy",
        "count": "[length(variables('eventHubs'))]"
      },
      "dependsOn": [
        "[resourceId('Microsoft.ServiceBus/namespaces', variables('namespaceName'))]"
      ],
      "properties": {
        "messageRetentionInDays": 7,
        "partitionCount": 4
      }
    },
    // 批量创建每个Event Hub对应的Consumer Group
    {
      "type": "Microsoft.ServiceBus/namespaces/eventhubs/consumergroups",
      "apiVersion": "[variables('serviceBusApiVersion')]",
      "name": "[concat(variables('namespaceName'), '/', variables('eventHubs')[copyIndex('eventHubCopy')].name, '/', variables('eventHubs')[copyIndex('eventHubCopy')].consumerGroups[copyIndex('cgCopy')])]",
      "copy": {
        "name": "cgCopy",
        "count": "[length(variables('eventHubs')[copyIndex('eventHubCopy')].consumerGroups)]",
        "mode": "parallel",
        "batchSize": 2,
        "dependsOn": [
          "eventHubCopy"
        ]
      },
      "dependsOn": [
        "[resourceId('Microsoft.ServiceBus/namespaces/eventhubs', variables('namespaceName'), variables('eventHubs')[copyIndex('eventHubCopy')].name)]"
      ],
      "properties": {}
    }
  ]
}

关键配置说明： #

1. 变量定义：在eventHubs数组里，每个元素同时包含Event Hub名称和它对应的Consumer Group列表，精准关联资源。
2. Event Hub批量创建：用copy循环遍历eventHubs数组，根据数组长度创建对应数量的Event Hub，依赖命名空间资源确保创建顺序。
3. Consumer Group批量创建：嵌套使用copy循环——外层循环对应每个Event Hub，内层循环创建该Event Hub下的所有Consumer Group，通过指定循环名称避免索引混淆。
4. 资源命名规则：严格按照命名空间名称/Event Hub名称/Consumer Group名称的格式拼接资源名，符合ARM对Service Bus资源的命名要求。
5. 依赖关系：Consumer Group必须依赖对应的Event Hub，确保Event Hub创建完成后再创建Consumer Group。

替换模板里的<你的命名空间名称>为实际值，就能正常部署多个Event Hub和对应的Consumer Group了。

内容的提问来源于stack exchange，提问作者Ravi kant Gautam