SnowflakeLoadAzureFunction

LoadFunction.cs

[FunctionName("Load")]
public static async Task<HttpResponseMessage> Run(
    [HttpTrigger(AuthorizationLevel.Function, "post", Route = "v1/load")]
    HttpRequestMessage req,
    ILogger logger,
    ExecutionContext context)
{
    ServiceProvider serviceProvider = Initializer.Initialize(context);

    string body = await req.Content.ReadAsStringAsync().ConfigureAwait(false);
    LoadCommand command = JsonConvert.DeserializeObject<LoadCommand>(body);

    if (!command.Validate(out string message))
    {
        return req.CreateResponse(HttpStatusCode.BadRequest, message);
    }

    IConfiguration config = serviceProvider.GetService<IConfiguration>();
    var client = new SnowflakeClient(config["ConnectionString"]);
    try
    {
        client.Load(command.Stage, command.TargetTable, command.Files, command.Warehouse, command.Database, command.Schema, command.Force);
    }
    catch (Exception e)
    {
        logger.LogError(e, "Error processing request");
        return req.CreateResponse(HttpStatusCode.InternalServerError, e.Message);
    }

    return req.CreateResponse(HttpStatusCode.OK);
}