camilo cabrales
Posted on December 6, 2021
Vamos a utilizar DynamoDB para el manejo de la sesión de una aplicación Web en Python.
Lo primero que debemos hacer es crear la tabla en la cual vamos a tener los datos de la sesión.
dynamodb.create_table(
TableName='ManejoSesion',
KeySchema=[
{
'AttributeName': 'Sesion_Id',
'KeyType': 'HASH' # Partition key
}
],
#Se deben crear las llaves nuevamente con su tipo de dato
AttributeDefinitions=[
{
'AttributeName': 'Sesion_Id',
'AttributeType': 'S' # Se utiliza S para tipos de datos String y N para numeros
}
],
ProvisionedThroughput={
'ReadCapacityUnits': 5,
'WriteCapacityUnits': 5
}
)
El siguiente paso es definir cuál atributo (columna) se va utilizar para que los registros sean borrados después del tiempo definido.
Para eso vamos a la consola de DynamoDB de la tabla creada y vamos al menu Aditional Settings.
Después buscamos la sección TTL y presionamos el botón Enable.
En la siguiente pantalla especificamos el nombre del atributo por el cual queremos que se borre el registro o la fila (Expire_Session).
Para definir el tiempo de borrado vamos agregar un registro a la tabla en donde se va a definir la fecha de borrado (fecha actual + 5 minutos) para el registro en el campo Expire_Session que acabamos de configurar.
from datetime import datetime
from datetime import timedelta
import boto3
import os
import uuid
from decimal import Decimal
dynamo = boto3.resource("dynamodb")
tabla = dynamo.Table("ManejoSesion")
def obtener_vencimiento_sesion():
hora_fin_sesion = datetime.now() + timedelta(minutes = 5)
return Decimal(round(hora_fin_sesion.timestamp(),0))
sesion_id = uuid.uuid4().hex
sesion ={
"Sesion_Id":str(sesion_id),
"Expire_Session":obtener_vencimiento_sesion()
}
tabla.put_item(Item=sesion)
De esta forma hemos definido que el registro se va a borrar 5 minutos después de la fecha actual. Es importante tener en cuenta que pasados los 5 minutos aun vamos a ver el registro en nuestra tabla. De acuerdo a la documentación, DynamoDb ejecuta un proceso en segundo plano para eliminar estos registros y este proceso puede llegar a tardar 48 horas.
En caso que necesitemos obtener los registros que aun no se les ha vencido la fecha de borrado podemos hacer una consulta de este tipo:
hora = Decimal(round(datetime.now().timestamp(),0))
tabla.query(KeyConditionExpression=Key("Sesion_Id").eq("b05ce2de320a4cddbcc1fa64400d14c9"),
FilterExpression= 'Expire_Session >= :Expire_Session' ,
ExpressionAttributeValues= {
':Expire_Session': hora
})
Referencias
Me pueden encontrar en
Posted on December 6, 2021
Join Our Newsletter. No Spam, Only the good stuff.
Sign up to receive the latest update from our blog.
Related
