Azure eventhub 多个分区键指向同一分区

Azure eventhub multiple partition key points to same partition

我们正在开发一个多租户应用程序,其中 eventhub 将在不同租户之间共享。我们将在我们的租户之间分配分区。每个租户都会在不同的分区上发送消息。我们想在分区级别对租户进行身份验证。如 Microsoft 网站所述,我们根据租户 ID 定义分区键。但问题是不止一个分区键在同一分区上发送消息。事实并非如此。理想情况下,每个分区键都应映射到不同的分区。

        var serviceNamespace = "namespace name here";
        var hubName = "hub name here";
        var deviceName = "device name here";
        var sasToken = "SAS TOKEN HERE";

        Mymessage subGroup1 = CreateMessage();

        var factory = MessagingFactory.Create(ServiceBusEnvironment.CreateServiceUri("sb", serviceNamespace, ""), new MessagingFactorySettings
        {
            TokenProvider = TokenProvider.CreateSharedAccessSignatureTokenProvider(sasToken),
            TransportType = TransportType.Amqp
        });
        var client = factory.CreateEventHubClient(String.Format("{0}/publishers/{1}", hubName, deviceName));

        var data = new EventData(Encoding.UTF8.GetBytes(JsonConvert.SerializeObject(subGroup1)));
        data.PartitionKey = "jeep";

        client.Send(data);

请帮助我理解我的方法有什么问题。

很简单,将 ~infinite space 可能的字符串分区键映射到事件中心内非常有限的 space 分区。除非你向 Microsoft 要求更多,否则你的 EventHub 中最多有 32 个分区。分区键被散列,然后散列 space 被划分到 space 个分区中。这提供了 documentation

中的保证

Event Hubs ensures that any and all events sharing the same partition key value are delivered in order, and to the same partition. Importantly, if partition keys are used with publisher policies, described in the next section, then the identity of the publisher and the value of the partition key must match.

在这种具有良好性能的系统中不能保证,也不能保证的是,每个分区键都转到不同的分区。 this question 中讨论了其中的一些内容。通过发布商政策,您还知道

When using publisher policies, the PartitionKey value is set to the publisher name. In order to work properly, these values must match.

这意味着来自单个发布者的所有事件都将转到单个分区。就我个人而言,我并不认为这总是一件好事,因为您最终会为每个发布者设置一个吞吐量单位的硬上限(如果您在哈希方面运气不佳,则更少)。

如果您需要将每个客户的数据分隔在不同的分区中,并通过提供给客户的凭据强制执行以直接与 EventHub 对话,我认为您唯一的选择可能是使用多个 EventHub。我相信(在某种意义上我还没有检查我们的账单)同一服务总线中的 EventHub 共享吞吐量单位。

但是,如果您只需要您的消费者能够分辨 publisher/customer 它来自什么,那么我相信您可以只使用 EventData.PartitionKey 保证是记录的发布者名称以上。