AWS Lambda传值报错：如何将前端JS输入正确传入S3 Select SQL

问题根因 #

当前触发的NameError: name 'name_Person' is not defined报错本质是跨执行上下文的变量引用断链：

• 前端JS和Lambda端Python是完全独立的运行环境，不存在自动的变量共享机制
• Lambda构造S3 Select查询语句时，直接照搬了前端JS里的输入框变量名name_Person，但Lambda的Python执行上下文中从未定义过这个变量
• 前端采集到的用户输入姓名，没有通过结构化的请求负载传递到Lambda的事件入参中

全链路正确实现步骤 #

1. 前端index.html侧改造逻辑 #

• 绑定搜索按钮点击事件时，直接从姓名输入框（DOM id为name_Person）的value属性读取用户输入的实际值
• 调用Lambda接口（API Gateway/Lambda函数URL）时，将读取到的姓名值序列化到请求body的固定字段中，不要直接把JS变量名硬塞进请求参数

正确的前端调用示例：

// 搜索按钮点击触发的检索逻辑
const handleSearch = () => {
  // 从输入框读取实际输入值
  const searchName = document.getElementById('name_Person').value.trim()
  // 发送结构化请求到Lambda
  fetch('你的Lambda服务调用地址', {
    method: 'POST',
    headers: {'Content-Type': 'application/json'},
    body: JSON.stringify({
      person_name: searchName
    })
  })
}

2. Lambda端lambda_function.py改造逻辑 #

• Lambda入口函数的所有外部入参都来自lambda_handler(event, context)的event对象，所有前端传递的参数都需要从该对象中解析提取，禁止直接引用前端的JS变量名
• 兼容不同触发场景的事件结构：如果是API Gateway代理触发，前端传的参数会包裹在event['body']字符串中，需要先做JSON解析；如果是Lambda函数URL直连、测试事件直接触发，可直接从event字典中取对应字段
• 提取到姓名值后做非空校验，再构造S3 Select查询语句，同时对输入值中的单引号做转义，避免SQL注入

正确的Lambda代码示例：

import json
import boto3

s3_client = boto3.client('s3')

def lambda_handler(event, context):
    # 解析请求结构，提取前端传递的参数
    if "body" in event:
        request_data = json.loads(event["body"])
    else:
        request_data = event
    input_name = request_data.get("person_name", "").strip()
    # 参数合法性校验
    if not input_name:
        return {
            "statusCode": 400,
            "body": json.dumps({"error": "请输入需要检索的姓名"})
        }
    # 转义特殊字符，避免SQL语法错误
    safe_input_name = input_name.replace("'", "''")
    # 构造S3 Select查询语句，使用Python侧提取的变量值
    s3_sql = f"SELECT * FROM s3object WHERE name_col = '{safe_input_name}'"
    # 调用S3 Select接口执行CSV查询
    query_resp = s3_client.select_object_content(
        Bucket="你的电话目录CSV存储桶",
        Key="电话目录CSV文件路径",
        ExpressionType="SQL",
        Expression=s3_sql,
        InputSerialization={"CSV": {"FileHeaderInfo": "USE"}},
        OutputSerialization={"JSON": {}}
    )
    # 解析S3 Select返回结果并返回给前端
    result_list = []
    for resp_event in query_resp["Payload"]:
        if "Records" in resp_event:
            result_list.append(resp_event["Records"]["Payload"].decode("utf-8"))
    return {
        "statusCode": 200,
        "body": json.dumps({"directory_info": result_list})
    }

常见踩坑提醒 #

• 不要混淆前端JS的变量名和Python的运行时变量，两个执行环境没有任何自动的变量同步机制
• 构造SQL语句时必须对用户输入的特殊字符做转义，防止恶意输入造成数据泄露或查询异常
• 日常测试Lambda时，需要构造和前端请求结构完全一致的测试事件，避免因测试环境和线上环境的事件结构不一致导致线上运行报错

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