azure - 监视 Azure 事件中心分区队列大小的可用方法

Question

Kafka提供了监控当前偏移量和最新偏移量的能力。同样，azure eventhub是否公开任何api来持续监视分区的当前偏移量和最新可用偏移量？

Answer 1

扩展上述答案，您可以看到两种方式的偏移。

1. 打印您正在监听 EventHub 的日志文件中的偏移量

例如使用Azure功能

    public static async Task Run([EventHubTrigger("EventHubname", ConsumerGroup = "ConsumerGroupname", Connection = "EventHubConnection")]EventData eventMessage,
        [Inject]IService service, [Inject]ILog log)
    {
    log.Info($"PartitionKey {eventMessage.PartitionKey}, Offset {eventMessage.Offset} and SequenceNumber {eventMessage.SequenceNumber}");
    }

我正在通过 Azure Functions 监听 Eventhub，您可以在下面看到 Azure 函数按分区维护偏移量的位置。

选项 3(最新)

Offset 不是衡量 Eventhub 深度的正确方法，特别是当您想检查需要处理多少消息时。

现在我们使用 Eventhub 消息 SequenceNumber 而不是 Offset。我们创建了 TimerTrigger Azure 函数。每 5 分钟，我们从 Eventhub 获取 LastEnqueuedSequenceNumber 并从 Blob 存储(检查点位置)获取每个分区的 SequenceNumber，然后将差异存储在 ApplicationInsight customMetrics 中。

然后，ApplicationInsights 帮助我们在 Azure 仪表板中识别 Eventhub 深度信息并设置警报。

Timer Trigger Code

希望这会有所帮助!