in src/Assessment/Parser/AzureSQLAssessedInstancesParser.cs [20:133]
public void ParseAssessedSQLInstances(Dictionary<string, AzureSQLInstanceDataset> AzureSQLInstancesData, UserInput userInputObj)
{
if (userInputObj == null)
throw new Exception("Received null user input object.");
if (AzureSQLAssessmentStatusMap == null)
{
userInputObj.LoggerObj.LogError("Azure SQL assessment status map is null, terminating parsing");
return;
}
if (AzureSQLAssessmentStatusMap.Count <= 0)
{
userInputObj.LoggerObj.LogError("Azure SQL Assessment status map is empty, terminating parsing");
return;
}
foreach (var kvp in AzureSQLAssessmentStatusMap)
{
if (!UtilityFunctions.IsAssessmentCompleted(kvp))
{
userInputObj.LoggerObj.LogWarning($"Skipping parsing assessment {kvp.Key.AssessmentName} as it is in {new EnumDescriptionHelper().GetEnumDescription(kvp.Value)} state");
continue;
}
userInputObj.LoggerObj.LogInformation($"Parsing Azure SQL assessment {kvp.Key.AssessmentName} for SQL instance data");
string url = Routes.ProtocolScheme + Routes.AzureManagementApiHostname + Routes.ForwardSlash +
Routes.SubscriptionPath + Routes.ForwardSlash + userInputObj.Subscription.Key + Routes.ForwardSlash +
Routes.ResourceGroupPath + Routes.ForwardSlash + userInputObj.ResourceGroupName.Value + Routes.ForwardSlash +
Routes.ProvidersPath + Routes.ForwardSlash + Routes.MigrateProvidersPath + Routes.ForwardSlash +
Routes.AssessmentProjectsPath + Routes.ForwardSlash + userInputObj.AssessmentProjectName + Routes.ForwardSlash +
Routes.GroupsPath + Routes.ForwardSlash + kvp.Key.GroupName + Routes.ForwardSlash +
new EnumDescriptionHelper().GetEnumDescription(kvp.Key.AssessmentType) + Routes.ForwardSlash + kvp.Key.AssessmentName + Routes.ForwardSlash +
Routes.AssessedSQLInstancesPath +
Routes.QueryStringQuestionMark +
Routes.QueryParameterApiVersion + Routes.QueryStringEquals + Routes.AssessmentMachineListApiVersion;
while (!string.IsNullOrEmpty(url))
{
if (userInputObj.CancellationContext.IsCancellationRequested)
UtilityFunctions.InitiateCancellation(userInputObj);
string assessedInstancesResponse = "";
try
{
assessedInstancesResponse = new HttpClientHelper().GetHttpRequestJsonStringResponse(url, userInputObj).Result;
}
catch (OperationCanceledException)
{
throw;
}
catch (AggregateException aeAssessedSqlInstances)
{
string errorMessage = "";
foreach (var e in aeAssessedSqlInstances.Flatten().InnerExceptions)
{
if (e is OperationCanceledException)
throw e;
else
{
errorMessage = errorMessage + e.Message + " ";
}
}
userInputObj.LoggerObj.LogError($"Failed to retrieve assessed SQL instances data from assessment: {errorMessage}");
url = "";
continue;
}
catch (Exception exAssessedSqlInstances)
{
userInputObj.LoggerObj.LogError($"Failed to retrieve assessed SQL instances data from assessment: {exAssessedSqlInstances.Message}");
url = "";
continue;
}
AzureSQLAssessedInstancesJSON assessedInstancesObj = JsonConvert.DeserializeObject<AzureSQLAssessedInstancesJSON>(assessedInstancesResponse);
url = assessedInstancesObj.NextLink;
foreach (var value in assessedInstancesObj.Values)
{
string key = value.Properties.SqlInstanceSDSArmId?.ToLower();
UpdateAssessedInstancesDataset(AzureSQLInstancesData, key, value, kvp.Key, userInputObj.Currency.Key);
double monthlySqlMIComputeCost = value.Properties.AzureSqlMISuitabilityDetails.MonthlyComputeCost;
double monthlySqlVMComputeCost = value.Properties.AzureSqlVMSuitabilityDetails.MonthlyComputeCost;
if (kvp.Key.AssessmentTag == AssessmentTag.PerformanceBased)
{
AzureSQLInstancesData[key].AzureSQLMIMonthlyComputeCost = monthlySqlMIComputeCost;
AzureSQLInstancesData[key].AzureSQLVMMonthlyComputeCost = monthlySqlVMComputeCost;
}
else if (kvp.Key.AssessmentTag == AssessmentTag.PerformanceBased_RI3year)
{
AzureSQLInstancesData[key].AzureSQLMIMonthlyComputeCost_RI3year = monthlySqlMIComputeCost;
AzureSQLInstancesData[key].AzureSQLVMMonthlyComputeCost_RI3year = monthlySqlVMComputeCost;
}
else if (kvp.Key.AssessmentTag == AssessmentTag.PerformanceBased_AHUB)
{
AzureSQLInstancesData[key].AzureSQLMIMonthlyComputeCost_AHUB = monthlySqlMIComputeCost;
AzureSQLInstancesData[key].AzureSQLVMMonthlyComputeCost_AHUB = monthlySqlVMComputeCost;
}
else if (kvp.Key.AssessmentTag == AssessmentTag.PerformanceBased_AHUB_RI3year)
{
AzureSQLInstancesData[key].AzureSQLMIMonthlyComputeCost_AHUB_RI3year = monthlySqlMIComputeCost;
AzureSQLInstancesData[key].AzureSQLVMMonthlyComputeCost_AHUB_RI3year = monthlySqlVMComputeCost;
}
else if (kvp.Key.AssessmentTag == AssessmentTag.PerformanceBased_ASP3year)
{
AzureSQLInstancesData[key].AzureSQLVMMonthlyComputeCost_ASP3year = monthlySqlVMComputeCost;
}
}
}
}
}