以编程方式查询事件中心使用者组(并在需要时创建)
Programmatically query Event Hub Consumer Group (and create if required)
有谁知道如何使用 .NET SDK 在 Azure 事件中心查询和创建使用者组。我已经用谷歌搜索了负载,只能找到通过 REST API 的方法(我可以做到,但如果我可以通过 SDK 做到这一点会更好)。
提前致谢
NamespaceManager.CreateConsumerGroupIfNotExistsAsync
(...)
ConsumerGroupDescription realtimeCG = nsMgr.CreateConsumerGroupIfNotExists("PartitionedStream_AKA_EventHub_Name");
Does anyone know how to query and create consumer groups in Azure Event Hubs using the .NET SDK.
你可以尝试安装this NuGet package,正如Sreeram所说,我们可以使用NamespaceManager class
来创建消费者组。
var manager = NamespaceManager.CreateFromConnectionString("{your connection string}");
manager.CreateConsumerGroupIfNotExists("{eventHubPath}", "{consumergroup Name}");
执行代码后,您会发现消费者组已创建。
要获取消费者组,您可以尝试调用EventHubClient.GetConsumerGroup method。
var factory = MessagingFactory.CreateFromConnectionString("{your connection string}");
var client = factory.CreateEventHubClient("{eventHubPath}");
EventHubConsumerGroup group = client.GetConsumerGroup("{consumergroup Name}");
有谁知道如何使用 .NET SDK 在 Azure 事件中心查询和创建使用者组。我已经用谷歌搜索了负载,只能找到通过 REST API 的方法(我可以做到,但如果我可以通过 SDK 做到这一点会更好)。 提前致谢
NamespaceManager.CreateConsumerGroupIfNotExistsAsync
(...)
ConsumerGroupDescription realtimeCG = nsMgr.CreateConsumerGroupIfNotExists("PartitionedStream_AKA_EventHub_Name");
Does anyone know how to query and create consumer groups in Azure Event Hubs using the .NET SDK.
你可以尝试安装this NuGet package,正如Sreeram所说,我们可以使用NamespaceManager class
来创建消费者组。
var manager = NamespaceManager.CreateFromConnectionString("{your connection string}");
manager.CreateConsumerGroupIfNotExists("{eventHubPath}", "{consumergroup Name}");
执行代码后,您会发现消费者组已创建。
要获取消费者组,您可以尝试调用EventHubClient.GetConsumerGroup method。
var factory = MessagingFactory.CreateFromConnectionString("{your connection string}");
var client = factory.CreateEventHubClient("{eventHubPath}");
EventHubConsumerGroup group = client.GetConsumerGroup("{consumergroup Name}");