in functions/source/real-time-adherence/AspectKinesisLamda/ProcessKinesisEvents.cs [125:150]
private async Task<bool> ReadWriteEventsToQueueFlag()
{
_logger.Trace("Beginning ReadWriteEventsToQueueFlag");
string flagStr = null;
if (_cfgDbContext == null)
{
flagStr = Environment.GetEnvironmentVariable(WRITE_EVENTS_TO_QUEUE_ENVIRONMENT_VARIABLE_LOOKUP);
_logger.Debug($"Read environment variable: {flagStr}");
}
else
{
var dynamoRecord = await _cfgDbContext.LoadAsync<ConfigRecord>(WRITE_EVENTS_TO_QUEUE_ENVIRONMENT_VARIABLE_LOOKUP);
flagStr = dynamoRecord?.Value;
_logger.Debug($"Read config table: {flagStr}");
if (string.IsNullOrEmpty(flagStr))
{
_logger.Debug("Config table row is missing, defaulting flag to false.");
flagStr = false.ToString();
}
}
var flagValue = Convert.ToBoolean(flagStr);
_logger.Trace("Ending ReadWriteEventsToQueueFlag");
return flagValue;
}