Function.csx

using System;
using Newtonsoft.Json;
using Newtonsoft.Json.Linq;
using System.Net;

public static void Run(string myEventHubMessage, TraceWriter log)
{
    String data = myEventHubMessage;
    log.Info($"C# Event Hub trigger function processed a message: {data}");
     data = data.Replace("http://schemas.microsoft.com", "");
                data = data.Replace("http://schemas.xmlsoap.org", "");

                JToken token = JObject.Parse(data);
                //var parsedData = format_json(data);
                string url = "http://<my_logstash_server>";
                foreach (var record in token.SelectToken("records"))
                {
                    Console.WriteLine("record:--------------------------------------------------------------------");
                    Console.WriteLine(record.ToString());
                    string result = ",";
                    using (var client = new WebClient())
                    {
                        client.Headers[HttpRequestHeader.ContentType] = "application/json";
                        result = client.UploadString(url, "POST", record.ToString());
                    }
                }
}