如何在AWS Lambda（Node.js）中保存最后读取的唯一ID？

Lambda是无状态服务，每次调用的执行环境可能被销毁或重置，所以不能把ID存在Lambda的内存变量或本地文件里，必须用外部持久化存储来保存这个值。下面是几个适合新手的实用方案：

方案一：用Amazon DynamoDB（推荐） #

DynamoDB是轻量级NoSQL数据库，适合存储这种小量状态数据，免费额度完全能满足你的需求。

操作步骤： #

1. 创建DynamoDB表，比如命名为LambdaLastRecord，主键设为Key（字符串类型），用来标识记录用途（比如LastShipId）。
2. 给Lambda执行角色添加DynamoDB的读写权限（生产环境可以配置更细粒度的权限，避免过度授权）。
3. 在Lambda代码中实现读写逻辑：
   • 调用API前，从DynamoDB读取上次保存的ID；
   • 拉取API数据后，筛选出ID晚于（或大于）该值的新增数据；
   • 将最新的ID写入DynamoDB覆盖旧值。

Python代码示例： #

import boto3
import requests

dynamodb = boto3.resource('dynamodb')
table = dynamodb.Table('LambdaLastRecord')

def lambda_handler(event, context):
    # 1. 读取最后保存的ID
    response = table.get_item(Key={'Key': 'LastShipId'})
    last_id = response.get('Item', {}).get('Value', '')
    
    # 2. 调用API获取数据
    api_url = "你的API地址"
    response = requests.get(api_url)
    data = response.json()
    
    # 3. 筛选新增数据（假设ID是按时间生成的UUID，新ID字符串更大）
    new_data = [item for item in data if item['Id'] > last_id]
    
    # 4. 有新增数据就更新最后保存的ID
    if new_data:
        latest_id = max(item['Id'] for item in new_data)
        table.put_item(Item={'Key': 'LastShipId', 'Value': latest_id})
        print(f"找到{len(new_data)}条新增数据，最新ID: {latest_id}")
    else:
        print("没有新增数据")
    
    return {
        'statusCode': 200,
        'body': f"处理完成，最新记录ID: {latest_id if new_data else last_id}"
    }

方案二：用AWS Systems Manager Parameter Store（SSM） #

SSM参数存储适合存储配置类小值，操作简单，不用管理数据库结构。

操作步骤： #

1. 在SSM控制台创建字符串类型参数，比如/lambda/last-ship-id，初始值设为你提供的ce4b69cb-9d31-11ec-8d58-005056b636f5。
2. 给Lambda角色添加SSM的GetParameter和PutParameter权限。
3. Lambda代码中读写参数：

Python代码示例： #

import boto3
import requests

ssm = boto3.client('ssm')
PARAM_NAME = '/lambda/last-ship-id'

def lambda_handler(event, context):
    # 1. 读取最后保存的ID
    response = ssm.get_parameter(Name=PARAM_NAME)
    last_id = response['Parameter']['Value']
    
    # 2. 调用API获取数据
    api_url = "你的API地址"
    response = requests.get(api_url)
    data = response.json()
    
    # 3. 筛选新增数据
    new_data = [item for item in data if item['Id'] > last_id]
    
    # 4. 更新参数值
    if new_data:
        latest_id = max(item['Id'] for item in new_data)
        ssm.put_parameter(
            Name=PARAM_NAME,
            Value=latest_id,
            Type='String',
            Overwrite=True
        )
        print(f"更新最新ID为: {latest_id}")
    
    return {
        'statusCode': 200,
        'body': f"处理完成，当前最新ID: {latest_id if new_data else last_id}"
    }

方案三：用Amazon S3 #

如果只是存一个简单的文本值，S3也是可行的，适合极简场景。

操作步骤： #

1. 创建S3桶，上传文本文件last_id.txt，内容填初始IDce4b69cb-9d31-11ec-8d58-005056b636f5。
2. 给Lambda角色添加S3的GetObject和PutObject权限。
3. Lambda代码中读写文件：

Python代码示例： #

import boto3
import requests

s3 = boto3.client('s3')
BUCKET_NAME = "你的桶名"
FILE_KEY = "last_id.txt"

def lambda_handler(event, context):
    # 1. 读取S3中的最后ID
    response = s3.get_object(Bucket=BUCKET_NAME, Key=FILE_KEY)
    last_id = response['Body'].read().decode('utf-8').strip()
    
    # 2. 调用API获取数据
    api_url = "你的API地址"
    response = requests.get(api_url)
    data = response.json()
    
    # 3. 筛选新增数据
    new_data = [item for item in data if item['Id'] > last_id]
    
    # 4. 更新S3中的文件
    if new_data:
        latest_id = max(item['Id'] for item in new_data)
        s3.put_object(Bucket=BUCKET_NAME, Key=FILE_KEY, Body=latest_id.encode('utf-8'))
        print(f"更新S3文件，最新ID: {latest_id}")
    
    return {
        'statusCode': 200,
        'body': f"处理完成，当前最新ID: {latest_id if new_data else last_id}"
    }

注意事项 #

• 确认API返回的ID是按时间递增的（比如示例中的UUID包含时间戳），如果ID不具备时序性，可能需要用创建时间等其他字段来筛选新增数据。
• 用CloudWatch Events（EventBridge）设置Lambda每5分钟触发一次即可实现定时任务。
• 权限配置遵循最小权限原则，比如DynamoDB只授权特定表的读写，避免给过大权限。

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