有没有办法在Java中使用Azure Functions的@EventHubTrigger获取事件（EventHub）的headers数据？

Question

我有一个使用 azure-functions-java-library 实现的 Azure 函数，它从一个 EventHub 接收事件，我正在使用 @EventHubTrigger，问题是我需要来自事件的 header 数据，但我没有看不出有什么方法可以做到这一点，我已经阅读了文档，什么也没有。我需要这个的原因是因为我从 EventHub 接收到具有不同 Avro 模式的事件，所以我需要区分它们以便解析它。

非常感谢您的帮助。

Answer 1

是的，您可以通过向方法参数添加 @BindingName("Properties") 注释来检索消息元数据，如下所示。此处需要注意的事项您可以使用 binding expression 绑定到事件的任何元数据。在这种情况下，它是“属性”。另外，基数应该是 ONE。

@FunctionName("EventHubExample")
    public void logEventHubMessage(
        @EventHubTrigger(name = "message", eventHubName = "test", connection = "AzureEventHubConnection", consumerGroup = "$Default", cardinality = Cardinality.ONE, dataType = "string") 
        String message,
        final ExecutionContext context,
        @BindingName("Properties")
        Map<String, Object> properties) {            
        context.getLogger().info("Event hub message received: " + message + ", properties: " + properties);
    }

我使用 Service Bus Explorer 作为事件发送器来设置事件的元数据，如下所示，并且能够在“属性”绑定中使用上述代码在消费者端看到那些元数据。

N.B。 C# 函数 SDK 在这里优于 Java。在 C# 中，您可以获得整个 Event 对象，这更容易在输入中获取多个事件时直接导航元数据。但不幸的是，到目前为止，这在 Java SDK 中是不可能的，您必须使用单一基数单独绑定。

有没有办法在Java中使用Azure Functions的@EventHubTrigger获取事件（EventHub）的headers数据？

Is there a way to get the headers data of events (EventHub) using @EventHubTrigger of Azure Functions in Java?

java

azure

azure-eventhub

azure-functions

azure-java-tools