Azure Events Hub

关于 Azure Event Hubs pubsub 组件的详细文档

配置

要安装 Azure Event Hubs pubsub，请创建一个类型为 pubsub.azure.eventhubs 的组件。 See this guide on how to create and apply a pubsub configuration.

  1. apiVersion: dapr.io/v1alpha1
  2. kind: Component
  3. metadata:
  4.   name: eventhubs-pubsub
  5.   namespace: default
  6. spec:
  7.   type: pubsub.azure.eventhubs
  8.   version: v1
  9.   metadata:
  10.   - name: connectionString
  11.     value: "Endpoint=sb://{EventHubNamespace}.servicebus.windows.net/;SharedAccessKeyName={PolicyName};SharedAccessKey={Key};EntityPath={EventHub}"
  12.   - name: storageAccountName
  13.     value: "myeventhubstorage"
  14.   - name: storageAccountKey
  15.     value: "112233445566778899"
  16.   - name: storageContainerName
  17.     value: "myeventhubstoragecontainer"

Warning

以上示例将密钥明文存储， It is recommended to use a secret store for the secrets as described here.

元数据字段规范

字段必填详情Example
connectionStringYEvent Hubs的连接地址“Endpoint=sb://{EventHubNamespace}.servicebus.windows.net/;SharedAccessKeyName={PolicyName};SharedAccessKey={Key};EntityPath={EventHub}”
storageAccountNameY用于EventProcessorHost的存储账户名称“myeventhubstorage”
storageAccountKeyY用于EventProcessorHost的存储账户密钥。 可以用secretKeyRef来引用密钥。“112233445566778899”
storageContainerNameY存储账户名称的存储容器名称。“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，因此没有在元数据中提供。

相关链接