ElasticUploadFunction.cs

[FunctionName("StreamOutputToElastic")]
public static async Task<HttpResponseMessage> Run([HttpTrigger(AuthorizationLevel.Function, "get", "post", Route = null)]HttpRequestMessage req, TraceWriter log)
{
    var node = new Uri("http://{username}:{password}@{ipaddress}:9200");
    var settings = new ConnectionSettings(node);
    settings.DefaultIndex("my-index");
    var elasticClient = new ElasticClient(settings);
    
    var records = await req.Content.ReadAsAsync<T>();
    await elasticClient.IndexManyAsync(timeStampedEvents, "my-index-name");
    
    return req.CreateResponse(HttpStatusCode.OK);
  }