将Azure功能与事件中心集成(Integrate Azure Functions with Event Hub)

将Azure功能与事件中心集成(Integrate Azure Functions with Event Hub)

我从EventHub触发器模板创建了一个Azure函数。 但我坚持两个问题：

a）如何指定非默认的消费者群组？

b）有没有办法获取整个EventData对象而不仅仅是消息字符串？

I've created a Azure function from EventHub-trigger template. But I've stuck with two issues:

a) How to specify the consumer group other than default?

b) Is there any way to get whole EventData object rather than just the message string?

最满意答案

更新 ：现在也可以在门户中指定消费者组（下面提到的问题已得到修复）。

对于您的第一个问题，我们有一个跟踪问题的问题，我们很快就会发现（ 此处有回购问题）。

对于你的第二个问题，我假设你是从我们的C＃模板开始的，它使用了字符串，但是你可以将它改为EventData （其中参数“evt”的名称与你在绑定中选择的名称相匹配）：

#r "Microsoft.ServiceBus" using System; using Microsoft.ServiceBus.Messaging; public static void Run(EventData evt, TraceWriter log) { var id = evt.Properties["id"]; log.Info($"C# Event Hub trigger function processed event: {id}"); }

有关可能的绑定的更多信息，请参见此处的EventHub wiki页面。 您也可以通过许多其他方式进行绑定，例如您自己的POCO类，一系列事件等。

Update: Consumer Group can now be specified in the portal as well (issue mentioned below has been fixed).

For your first question, we have an issue tracking that and we'll get to it soon (repo issue here).

For your second question, I'm assuming you're starting from our C# template, which uses string, but you can change that to EventData (where the name of the parameter "evt" matches the name you chose in your binding):

#r "Microsoft.ServiceBus" using System; using Microsoft.ServiceBus.Messaging; public static void Run(EventData evt, TraceWriter log) { var id = evt.Properties["id"]; log.Info($"C# Event Hub trigger function processed event: {id}"); }

See the EventHub wiki page here for more information on possible bindings. You can bind in many other ways as well, for example your own POCO class, an array of events, etc.