Hice una rutina en Python teniendo como base la documentación de Amazon para poder crear una función Lambda con el fin de reiniciar una RDS dada su región más el key y el value de una etiqueta.
La función es la siguiente:
# Función para reinicio de RDS
import boto3
import os
import sys
import time
from datetime import datetime, timezone
from time import gmtime, strftime
#REGION: la región en donde se encuentra la RDS
#KEY - VALUE: corresponden a los valores de la etiqueta de la RDS para que la función sepa a
#cual RDS hay que reiniciar
def reiniciar_rds():
region=os.environ['REGION']
key=os.environ['KEY']
value=os.environ['VALUE']
client = boto3.client('rds', region_name=region)
response = client.describe_db_instances()
v_readReplica=[]
for i in response['DBInstances']:
readReplica=i['ReadReplicaDBInstanceIdentifiers']
v_readReplica.extend(readReplica)
for i in response['DBInstances']:
#Condición que filtra si la RDS es de Aurora
if i['Engine'] not in ['aurora-mysql','aurora-postgresql']:
#Condición que filtra si la instancia es una replica o no.
if i['DBInstanceIdentifier'] not in v_readReplica and len(i['ReadReplicaDBInstanceIdentifiers']) == 0:
arn=i['DBInstanceArn']
resp2=client.list_tags_for_resource(ResourceName=arn)
#Revisa si la etiqueta que pertenece la RDS permite realizarle reinicio
if 0==len(resp2['TagList']):
print('Instancia RDS {0} no coincide etiqueta para operación de reinicio'.format(i['DBInstanceIdentifier']))
else:
for tag in resp2['TagList']:
#Si la etiqueta coincide procede a reiniciar la RDS teniendo en cuenta el estado actual de la RDS
if tag['Key']==key and tag['Value']==value:
if i['DBInstanceStatus'] == 'available':
client.reboot_db_instance(DBInstanceIdentifier=i['DBInstanceIdentifier'],ForceFailover=False)
print('Reiniciando Instancia RDS {0}'.format(i['DBInstanceIdentifier']))
elif i['DBInstanceStatus'] == 'rebooting':
print('Instancia RDS {0} ya está reinciándose, por favor espere a que finalice'.format(i['DBInstanceIdentifier']))
elif i['DBInstanceStatus'] == 'creating':
print('Instancia RDS {0} está en proceso de creación, por favor espere a que se termine el proceso'.format(i['DBInstanceIdentifier']))
elif i['DBInstanceStatus'] == 'modifying':
print('Instancia RDS {0} está en proceso de modificación, por favor espere a que se termine el proceso'.format(i['DBInstanceIdentifier']))
elif i['DBInstanceStatus'] == 'stopped':
print('Instancia RDS {0} está detenida'.format(i['DBInstanceIdentifier']))
elif i['DBInstanceStatus']=='starting':
print('Instancia RDS {0} está iniciando, por favor espere a que termine el proceso'.format(i['DBInstanceIdentifier']))
elif i['DBInstanceStatus']=='stopping':
print('Instancia RDS {0} está deteniéndose, no puede reiniciarse hasta encenderse nuevamente.'.format(i['DBInstanceIdentifier']))
elif tag['Key']!=key and tag['Value']!=value:
print('Instancia RDS {0} no existe'.format(i['DBInstanceIdentifier']))
elif len(tag['Key']) == 0 or len(tag['Value']) == 0:
print('Instancia {0} no existe'.format(i['DBInstanceIdentifier']))
else:
print('Instancia RDS {0} está en un estado que impide su reinicio, revise el monitor RDS para más información'.format(i['DBInstanceIdentifier']))
def lambda_handler(event, context):
reiniciar_rds()
Mis variables de entorno son las siguientes:
Mi evento para pruebas es el siguiente:
Y finalmente mi RDS para pruebas está en la región indicada en las varibles de entorno y tiene una etiqueta con los valores necesarios para que funcione el Lambda correctamente. Sin embargo sale este mensaje de error al probar el código:
{
"errorMessage": "2022-01-12T21:18:24.334Z 2429a912-d5f8-4710-b7d4-441fff4187f5 Task timed out after 3.00 seconds"
}
Con la siguiente llamada de registro:
START RequestId: 2429a912-d5f8-4710-b7d4-441fff4187f5 Version: $LATEST
END RequestId: 2429a912-d5f8-4710-b7d4-441fff4187f5
REPORT RequestId: 2429a912-d5f8-4710-b7d4-441fff4187f5
Duration: 3003.63 ms
Billed Duration: 3000 ms
Memory Size: 128 MB
Max Memory Used: 65 MB
Init Duration: 251.61 ms
2022-01-12T21:18:24.334Z 2429a912-d5f8-4710-b7d4-441fff4187f5
Task timed out after 3.00 seconds
¿Me podrían indicar cuál puede ser el problema con mi código? ¿Es algo que debo hacer adicionalmente en la configuración o algo que está mal configurado?
Estoy atento a sus respuestas. De antemano muchas gracias.