DynamoDB TTL未按预期删除问题及5分钟过期实现咨询

DynamoDB的TTL不会立即删除过期数据。TTL删除是后台异步执行的操作，通常在数据过期后的48小时内完成，具体清理时间受系统负载影响，没有严格的实时性保证。

实现5分钟后自动删除的步骤：

• 给DynamoDB表启用TTL功能，指定一个存储秒级Epoch时间戳的属性（比如expireAt）。
• 写入数据时，给该属性赋值为「当前秒级时间戳 + 300」（300秒即5分钟），例如(System.currentTimeMillis() / 1000) + 300。
• 确认TTL功能已正确关联到目标属性（可通过AWS控制台或CLI验证配置）。

可能的原因 #

• TTL异步延迟：DynamoDB的TTL清理不是实时的，过期后可能需要几分钟到数小时才会完成删除，并非严格在5分钟后立即执行。
• 属性配置错误：检查表的TTL是否正确绑定到expireAt属性，可能存在属性名拼写、大小写不一致的情况。
• 时间戳格式错误：如果误将毫秒级时间戳存入expireAt，会导致过期时间被设置为未来极远的时间（比如当前毫秒级时间+300，实际是300毫秒后而非5分钟），数据自然不会被删除。
• 数据更新失败：会话活动时可能未正确执行expireAt的更新操作，或者更新请求因权限、网络问题失败，导致过期时间未被延长。
• IAM权限不足：操作DynamoDB的角色如果缺少dynamodb:UpdateItem权限，会无法更新expireAt值，会话过期时间无法正常延长。

替代方案 #

方案1：查询时主动过滤过期数据 #

即便TTL未完成清理，在查询会话数据时直接过滤掉expireAt小于当前时间戳的项。示例Java代码：

long currentSecond = System.currentTimeMillis() / 1000;
DynamoDBQueryExpression<Login> queryExpr = new DynamoDBQueryExpression<Login>()
    .withHashKeyValues(login)
    .withFilterExpression("expireAt > :current")
    .withExpressionAttributeValues(Collections.singletonMap(":current", currentSecond));
List<Login> validSessions = dynamoDBMapper.query(Login.class, queryExpr);

方案2：定时任务主动清理过期数据 #

用Spring Boot的@Scheduled定时任务，定期扫描表中过期会话并主动删除。示例代码：

@Scheduled(fixedRate = 300000) // 每5分钟执行一次
public void cleanExpiredSessions() {
    long currentSecond = System.currentTimeMillis() / 1000;
    ScanRequest scanRequest = new ScanRequest()
        .withTableName("LoginSessions")
        .withFilterExpression("expireAt < :current")
        .withExpressionAttributeValues(Collections.singletonMap(":current", currentSecond));
    ScanResult scanResult = amazonDynamoDB.scan(scanRequest);
    
    // 批量构造删除请求
    List<WriteRequest> deleteRequests = scanResult.getItems().stream()
        .map(item -> new WriteRequest().withDeleteRequest(new DeleteRequest().withKey(item)))
        .collect(Collectors.toList());
    
    if (!deleteRequests.isEmpty()) {
        amazonDynamoDB.batchWriteItem(new BatchWriteItemRequest().withRequestItems(Collections.singletonMap("LoginSessions", deleteRequests)));
    }
}

方案3：DynamoDB Streams + Lambda处理过期事件 #

启用DynamoDB Streams，配置Lambda函数监听TTL过期事件，一旦数据过期就触发Lambda执行删除操作。此方案依赖DynamoDB的事件推送，延迟比被动等待TTL清理低，但仍无法做到绝对实时。

内容的提问来源于stack exchange，提问作者Satchit Desai