如何在事件中心触发 Azure 函数中获取 PartitionId？

Question

我有一个由事件中心触发的 Azure 函数。我在 host.json 中将函数应用配置为 MaxBatchSize 为 32。我的事件中心有 6 个分区，我不希望一个事件被处理两次。

所以，我需要分区 ID 和序列号来唯一标识事件。我想在我的数据库中保存 PartitionID 和 SequenceNumber 作为主键。我的函数是在 EventData 数组的输入中触发的。对数组进行迭代，我可以获得每条消息的 SequenceNumber，但我不知道如何获取每个 PartitionID。我试图在输入参数中包含 PartitionContext 类型的参数，但它不起作用。

这是我的代码：

[FunctionName("EventHubTriggeredFunction")]
public static void Run([EventHubTrigger("events", Connection = "EventHubConnection")]EventData[] eventHubMessages, TraceWriter log)
{
    foreach (var message in eventHubMessages)
    {
        using (Stream stream = message.GetBodyStream())
        {
            using (StreamReader reader = new StreamReader(stream))
            {
                try
                {
                    //... do something

                    //SequenceNumber: message.SequenceNumber
                    Save(reader.ReadToEnd(), message);

                    //... do something else
                }
            }
        }
 }

如何获取每条已处理消息的 PartitionID？

Answer 1

定义 EventHub 触发器to include Event Metadata。然后在上下文对象上使用receiverRuntimeInfo。

PartitionContext.RuntimeInfo.PartitionId