in automatic_scaling/src/app.py [0:0]
def lambda_handler(event,context):
print("Checking for query capacity units......")
response = current_capacity(INDEX_ID)
currentunits = response['CapacityUnits']['QueryCapacityUnits']
print ("Current query capacity units are: "+str(currentunits))
status = response['Status']
print ("Current index status is: "+status)
# If index is stuck in UPDATE state, don't attempt changing the capacity
if status == "UPDATING":
return ("Index is currently being updated. No changes have been applied")
if status == "ACTIVE":
if currentunits == 0:
print ("Adding query capacity...")
response = add_capacity(INDEX_ID,ADDITIONAL_UNITS)
print(response)
return response
else:
print ("Removing query capacity....")
response = reset_capacity(INDEX_ID, DEFAULT_UNITS)
print(response)
return response
else:
response = "Index is not ready to modify capacity. No changes have been applied."
return(response)