Azure Event Hubs

配置

要安装 Azure Event Hubs pubsub，请创建一个类型为 pubsub.azure.eventhubs 的组件。 请参阅本指南，了解如何创建和应用 pubsub 配置。

apiVersion: dapr.io/v1alpha1
kind: Component
metadata:
  name: eventhubs-pubsub
  namespace: default
spec:
  type: pubsub.azure.eventhubs
  version: v1
  metadata:
  - name: connectionString
    value: "Endpoint=sb://{EventHubNamespace}.servicebus.windows.net/;SharedAccessKeyName={PolicyName};SharedAccessKey={Key};EntityPath={EventHub}"
  - name: storageAccountName
    value: "myeventhubstorage"
  - name: storageAccountKey
    value: "112233445566778899"
  - name: storageContainerName
    value: "myeventhubstoragecontainer"

元数据字段规范

创建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，因此没有在元数据中提供。

订阅 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组件的基本格式
• 阅读 本指南，了解配置 发布/订阅组件的说明
• 发布/订阅构建块