in processing-pipelines/image-v1/labeler/csharp/Startup.cs [37:82]
public void Configure(IApplicationBuilder app, IWebHostEnvironment env, ILogger<Startup> logger)
{
if (env.IsDevelopment())
{
app.UseDeveloperExceptionPage();
}
logger.LogInformation("Service is starting...");
app.UseRouting();
var eventReader = new CloudEventReader(logger);
var configReader = new ConfigReader(logger);
var outputBucket = configReader.Read("BUCKET");
app.UseEndpoints(endpoints =>
{
endpoints.MapPost("/", async context =>
{
try
{
var (bucket, name) = await eventReader.ReadCloudStorageData(context);
var storageUrl = $"gs://{bucket}/{name}";
logger.LogInformation($"Storage url: {storageUrl}");
var labels = await ExtractLabelsAsync(storageUrl);
logger.LogInformation($"This picture is labelled: {labels}");
using (var outputStream = new MemoryStream(Encoding.UTF8.GetBytes(labels)))
{
var outputObjectName = $"{Path.GetFileNameWithoutExtension(name)}-labels.txt";
var client = await StorageClient.CreateAsync();
await client.UploadObjectAsync(outputBucket, outputObjectName, "text/plain", outputStream);
logger.LogInformation($"Uploaded '{outputObjectName}' to bucket '{outputBucket}'");
}
}
catch (Exception e)
{
logger.LogError($"Error processing: " + e.Message);
throw e;
}
});
});
}