Azure Event Hubs

配置

要安装 Azure Event Hubs pubsub，请创建一个类型为 pubsub.azure.eventhubs 的组件。 请参阅本指南，了解如何创建和应用 pubsub 配置。 除了下面显示的配置元数据字段外，Azure 事件中心还支持 Azure 身份验证 机制。

apiVersion: dapr.io/v1alpha1
kind: Component
metadata:
  name: eventhubs-pubsub
  namespace: default
spec:
  type: pubsub.azure.eventhubs
  version: v1
  metadata:
  - name: connectionString    # Either connectionString or eventHubNamespace. Should not be used when 
  # Azure Authentication mechanism is used.
    value: "Endpoint=sb://{EventHubNamespace}.servicebus.windows.net/;SharedAccessKeyName={PolicyName};SharedAccessKey={Key};EntityPath={EventHub}"
  - name: eventHubNamespace   # Either connectionString or eventHubNamespace. Should be used when 
  # Azure Authentication mechanism is used.
    value: "namespace"
  - name: enableEntityManagement
    value: "false"
    ## The following four properties are needed only if enableEntityManagement is set to true
  - name: resourceGroupName
    value: "test-rg"
  - name: subscriptionID
    value: "value of Azure subscription ID"
  - name: partitionCount
    value: "1"
  - name: messageRetentionInDays
  ## Subscriber attributes
  - name: storageAccountName
    value: "myeventhubstorage"
  - name: storageAccountKey
    value: "112233445566778899"
  - name: storageContainerName
    value: "myeventhubstoragecontainer"

元数据字段规范

Azure Active Directory (AAD) 认证

Azure 事件中心 pubsub 组件支持使用所有 Azure Active Directory 机制进行身份验证。 更多信息和相关组件的元数据字段根据选择的AAD认证机制，参考Azure认证文档。

创建Azure Event Hub

请按照此处的说明设置 Azure Event Hubs。 由于本实施例使用Event Processor Host，你还需要一个Azure Storage Account。 请遵循此处的说明来管理存储帐户访问密钥。

请参阅这里，了解如何获取 Event Hubs 连接地址。 注意这不是Event Hubs命名空间。

为每个订阅者创建消费组

对于每个要订阅事件的Dapr应用，创建一个名称为dapr id的Event Hubs消费组。 例如，在 Kubernetes 上运行的 Dapr 应用程序的 dapr.io/app-id: "myapp"将需要一个名为myapp的Event Hubs消费组。

注意：Dapr将消费组的名称传递给EventHub，因此没有在元数据中提供。

实体管理

在配置中启用实体管理后，只要应用程序具有操作事件中心命名空间的正确角色和权限，就可以即时创建事件中心和消费者组。

Evet Hub 名称是发布或订阅的传入请求中的 topic 字段，而消费者组名称是订阅给定 Event Hub 的 dapr 应用程序 的名称。 例如，在 Kubernetes 上运行的命名为 dapr.io/app-id: "myapp"的 Dapr 应用程序需要一个名为myapp的Event Hubs消费组。

只有在使用 Azure 身份验证 机制时才可以使用实体管理，而不是通过 connectionString。

注意：Dapr将消费组的名称传递给EventHub，因此没有在元数据中提供。

订阅 Azure IoT Hub Events

Azure IoT Hub 提供了一个与 Event Hubs兼容的终结点，因此 Azure Event Hubs pubsub 组件也可用于订阅 Azure IoT Hub 的事件。

由 Azure IoT Hub 设备创建的设备到云事件将包含其他 IoT Hub System Properties，并且 Dapr 的 Azure Event Hubs pubsub 组件将返回以下内容作为响应元数据的一部分：

例如，已发送HTTP订阅消息的头部将包含：

{
  'user-agent': 'fasthttp',
  'host': '127.0.0.1:3000',
  'content-type': 'application/json',
  'content-length': '120',
  'iothub-connection-device-id': 'my-test-device',
  'iothub-connection-auth-generation-id': '637618061680407492',
  'iothub-connection-auth-method': '{"scope":"module","type":"sas","issuer":"iothub","acceptingIpFilterRule":null}',
  'iothub-connection-module-id': 'my-test-module-a',
  'iothub-enqueuedtime': '2021-07-13T22:08:09Z',
  'message-id': 'my-custom-message-id',
  'x-opt-sequence-number': '35',
  'x-opt-enqueued-time': '2021-07-13T22:08:09Z',
  'x-opt-offset': '21560',
  'traceparent': '00-4655608164bc48b985b42d39865f3834-ed6cf3697c86e7bd-01'
}

相关链接

• Dapr组件的基本格式
• 阅读 本指南，了解配置 发布/订阅组件的说明
• 发布/订阅构建块
• Authentication to Azure