Serverless 冷启动案例#

# 秒杀专用架构
def seckill_handler(event, context):
    # 1. 验证请求（边缘节点已完成）
    # 2. 写入消息队列
    sqs.send_message(
        QueueUrl='https://sqs.us-east-1.amazonaws.com/123/seckill-queue',
        MessageBody=json.dumps({
            'user_id': event['user_id'],
            'product_id': event['product_id'],
            'timestamp': time.time()
        })
    )

    # 3. 立即返回
    return {
        'statusCode': 202,
        'body': json.dumps({
            'status': 'queued',
            'message': '秒杀请求已提交，请等待结果'
        })
    }

# 队列消费者
def queue_consumer(event, context):
    for record in event['Records']:
        message = json.loads(record['body'])

        # 异步处理秒杀逻辑
        result = process_seckill(message)

        # 发送结果通知
        sns.publish(
            TopicArn='arn:aws:sns:us-east-1:123:seckill-results',
            Message=json.dumps({
                'user_id': message['user_id'],
                'result': result
            })
        )

# 对于非计算密集型函数，迁移到 Python
def feature_engineering(event, context):
    # Python 冷启动 ~200ms（vs Java 8s）
    import pandas as pd

    df = pd.DataFrame(event['data'])
    result = df.describe()
    return result.to_dict()

import boto3
import time

lambda_client = boto3.client('lambda')

def scheduled_warmup(event, context):
    """定时预热 ETL 管道"""
    functions = [
        'etl-data-clean',
        'etl-feature-eng',
        'etl-model-inference',
        'etl-data-load'
    ]

    # 间隔 5 秒依次预热
    for func in functions:
        lambda_client.invoke(
            FunctionName=func,
            InvocationType='Event'
        )
        time.sleep(5)

    # 确保每个函数都有热实例
    print(f"预热了 {len(functions)} 个函数")

# 改用 SQS 触发的函数
# 队列长轮询保持函数热状态

def sqs_handler(event, context):
    """SQS 触发的函数"""
    for record in event['Records']:
        message = json.loads(record['body'])
        result = process_message(message)

    return {'processed': len(event['Records'])}

import boto3
import json

iot_core = boto3.client('iot-data')

def iot_gateway(event, context):
    """
    IoT Gateway 函数
    - 运行在容器环境，冷启动几乎为零
    - 批量接收设备数据
    - 写入 SQS 缓冲
    """
    # 获取设备数据
    topic = event['mqtt_topic']
    payload = json.loads(event['payload'])

    # 批量写入 SQS
    sqs_client = boto3.client('sqs')
    messages = [
        {
            'Id': str(i),
            'MessageBody': json.dumps({
                'device_id': payload['device_id'],
                'timestamp': payload['timestamp'],
                'data': payload['data']
            })
        }
        for i, payload in enumerate(payload['readings'])
    ]

    sqs_client.send_message_batch(
        QueueUrl='https://sqs.us-east-1.amazonaws.com/123/iot-data-queue',
        Entries=messages
    )

    return {'status': 'ok', 'processed': len(messages)}