in deleteExpiredForecast/deleteExpiredForecast.py [0:0]
def onEventHandler(event, context):
response = forecast_client.list_dataset_groups()
numOfDSGroup=len(response["DatasetGroups"])
oldest_creationDate=datetime.now(timezone.utc)
if(numOfDSGroup>numberOfForecastsToKeep):
#delete the oldest
for datasetGroup in response["DatasetGroups"]:
creationTime=datasetGroup["CreationTime"]
if(oldest_creationDate>=creationTime):
oldest_creationDate=creationTime
oldest_datasetGroup=datasetGroup
logger.info ("the oldest forecast is going to be deleted, datasetGroupName="+ datasetGroup["DatasetGroupName"])
logger.debug(datasetGroup)
trigger_deleteDS(datasetGroup)
else:
logger.info("number for DatasetGroups="+str(numOfDSGroup)+", limitation="+str(numberOfForecastsToKeep)+ ", nothing to do")