How to receive events batch in Eventhub triggered function

[joal42]

Investigative information

I have a eventhub triggered function in python and want to receive events in batch.

In function.json set cardinality to many
"cardinality": "many",
What should the parameter in main function to pass a list of events?

This example can only get one event data:
def main(event: func.EventHubEvent):

[pragnagopa]

@asavaritayal - This needs to be documented. Receiving a batch of eventhub events is the recommended approach.
@elprans - Can you share sample code for receiving an array or list of eventHubEvent?

[asavaritayal]

@1st1 @elprans once you provide a sample, I can go update the documentation.

[maiqbal11]

While working on a different EventHub issues, came across this issue: Azure/azure-functions-eventhubs-extension#118 (unresolved as of now). Looks like setting cardinality to many has the potential to error out if valid json is not provided. Wanted to make a note of this because I ran into this with our default EventHub template in core tools. If we are going to be recommending cardinality : many as a way to get batched events, we should at least ensure that the default experience works.

[joal42]

@maiqbal11 Thanks for linking the webjobs issue. I set to many and use the input as bytes. And then, I convert bytes to array of string. It looks working fine. It would be better if you can share some default usage example.

[joal42]

@maiqbal11 I found that I lose eventhub meta data, like offset if I use batch model. Could you also help with how to get eventhub meta date in batch processing?

[pragnagopa]

For batch processing, trigger data and metadata is received as an array via RPC. Please see java sample code here: https://github.com/Azure/azure-functions-java-worker/blob/dev/endtoendtests/src/main/java/com/microsoft/azure/functions/endtoend/EventHubTriggerTests.java#L27
Note: SystemPropertiesArray is populated by the java worker.

@elprans / @maiqbal11 - Does python worker expose an array of metadata?