Skip to content

Instantly share code, notes, and snippets.

@paulbatum
Last active January 24, 2019 18:38
Show Gist options
  • Save paulbatum/ebdca12ba4b95700f1cc0e08aa213252 to your computer and use it in GitHub Desktop.
Save paulbatum/ebdca12ba4b95700f1cc0e08aa213252 to your computer and use it in GitHub Desktop.
Event Hub Batch Example
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using Microsoft.Azure.EventHubs;
using Microsoft.Azure.WebJobs;
using Microsoft.Extensions.Logging;
namespace FunctionApp12
{
public static class Function1
{
[FunctionName("Function1")]
public static async Task Run(
[EventHubTrigger("scratch", Connection = "EventsConnectionString")] EventData[] events,
ILogger log)
{
var exceptions = new List<Exception>();
foreach (EventData eventData in events)
{
try
{
string messageBody = Encoding.UTF8.GetString(eventData.Body.Array, eventData.Body.Offset, eventData.Body.Count);
// Replace these two lines with your processing logic.
log.LogInformation($"C# Event Hub trigger function processed a message: {messageBody}");
await Task.Yield();
}
catch (Exception e)
{
// We need to keep processing the rest of the batch - capture this exception and continue.
// Also, consider capturing details of the message that failed processing so it can be processed again later.
exceptions.Add(e);
}
}
// Once processing of the batch is complete, if any messages in the batch failed processing throw an exception so that there is a record of the failure.
if (exceptions.Count > 1)
throw new AggregateException(exceptions);
if (exceptions.Count == 1)
throw exceptions.Single();
}
}
}
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment