问题描述
在通过Azure Function消费Event Hub中的消息时，我们从Function 的 Trigger Details 日志中，可以获得当前Funciton中处理的消息是哪一个分区(PartitionID), 偏移量Offset,序列号SequenceNumber 等信息。
但是在Event的属性中，只发现由PartitionKey存在（该值由消息生产时复制，可以变动，可以为空），根据PartitionKey，无法在应用自己的日志中准确判断分区号（Partition ID).
所以，在Function代码中，应该如何获取到Event的分区号信息呢？
问题解答
在Event的属性中，没有直接获取 PartitionId 的属性，但是有 PartitionContext 属性。这个属性为一个JSON格式对象，它的内容中包含了当前的PartitionID，所以可以通过 event.metadata["PartitionContext"]["PartitionId"] 来完成获取分区号的目标。
实例代码如下：
import logging import azure.functions as func def main(events: func.EventHubEvent): for event in events: logging.info(f' Function triggered to process a message: {event.get_body().decode()}') logging.info(f' EnqueuedTimeUtc = {event.enqueued_time}') logging.info(f' SequenceNumber = {event.sequence_number}') logging.info(f' Offset = {event.offset}') logging.info(f' PartitionId = {event.metadata["PartitionContext"]["PartitionId"]}') #logging.info(f' PartitionId = {event.metadata["PartitionContext"].PartitionId}') # Metadata for key in event.metadata: logging.info(f'Metadata: {key} = {event.metadata[key]}')
执行结果如图:
参考资料
适用于 Azure Functions 的 Azure 事件中心触发器:https://docs.azure.cn/zh-cn/azure-functions/functions-bindings-event-hubs-trigger?tabs=in-process%2Cfunctionsv2%2Cextensionv5&pivots=programming-language-python
