in cdk-project/lambda/python-functions/clean_endpoints.py [0:0]
def batch_delete_resources(client, before_timestamp, resource_type):
try:
next_token = None
more = True
while more:
logger.info("Searching for %s from before: %s", resource_type.lower(), before_timestamp)
resources, next_token = get_resources(
client, next_token, before_timestamp, resource_type
)
logger.info("Found %s items, deleting now", len(resources))
if resource_type == "MonitoringSchedules":
resource_names = [resource["MonitoringScheduleName"] for resource in resources]
elif resource_type == "Endpoints":
resource_names = [resource["EndpointName"] for resource in resources]
elif resource_type == "EndpointConfigs":
resource_names = [resource["EndpointConfigName"] for resource in resources]
elif resource_type == "Experiments":
resource_names = [resource["ExperimentName"] for resource in resources]
delete_resources(client, resource_names, resource_type)
more = next_token is not None
time.sleep(1)
finally:
logger.info(
"Finished cleaning %s at %s", resource_type.lower(), str(datetime.datetime.now())
)