in packages/lambdas/CheckRekognitionProject/src/CheckRekognitionProject/Function.cs [29:70]
public async Task FunctionHandler(string input, ILambdaContext context)
{
// Check if there any training jobs that need to be updated
AmazonSageMakerClient sageMakerClient = new AmazonSageMakerClient();
Amazon.S3.AmazonS3Client s3Client = new Amazon.S3.AmazonS3Client();
var config = new DynamoDBOperationConfig
{
OverrideTableName = TrainingJobsTableName
};
Amazon.DynamoDBv2.AmazonDynamoDBClient dynamoDbClient = new AmazonDynamoDBClient();
DynamoDBContext dbContext = new DynamoDBContext(dynamoDbClient);
var trainingJobs = dbContext.ScanAsync<TrainingJob>(new ScanCondition[] { }, config).GetRemainingAsync()
.GetAwaiter().GetResult();
foreach (var job in trainingJobs)
{
TrainingJobStates status;
if (Enum.TryParse(job.Status, out status))
{
if (status == TrainingJobStates.CreatingDataset)
{
await HandleCreatingDatasetStatus(job);
}
else if (status == TrainingJobStates.Training)
{
await HandleTrainingStatus(job);
}
else if (status == TrainingJobStates.Deploying)
{
await HandleDeployingStatus(job);
}
}
}
}