A .NET Core Azure function that forwards EventHub events to a Loggly endpoint

loggly-endpoint.cs

#r "Microsoft.Azure.EventHubs"


using System;
using System.Text;
using Microsoft.Azure.EventHubs;

public static async Task Run(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);

            log.LogInformation($"message body: {messageBody}");

            // Replace these two lines with your processing logic.
            var client = new HttpClient();
            var content = new StringContent(messageBody, Encoding.UTF8, "application/json");
            var response = await client.PostAsync("LOGGLY_ENDPOINT", content);
            response.EnsureSuccessStatusCode();
        }
        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();
}