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.

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"

元数据字段规范

字段必填详情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,因此没有在元数据中提供。

相关链接