集成DynamoDB的AWS Lambda FSx监控脚本问题求助

问题脉络 #

• 未集成DynamoDB时，Lambda可正常采集ONTAP文件系统数据并发送监控邮件
• 集成DynamoDB后先触发**ValidationException（元素与Schema不匹配）**错误
• 修改代码后无报错，但DynamoDB表始终为空，且发送空监控邮件

一、先排查ValidationException遗留的隐性问题 #

此前的Schema不匹配错误，核心是写入DynamoDB的Item结构与表定义（主键、数据类型）不兼容。修改后无报错但数据为空，大概率是为了绕过错误破坏了数据流程：

核心排查点 #

1. 核对表结构与写入Item
   • 确认DynamoDB表的分区键/排序键名称、数据类型（字符串/数字等）与代码中put_item/batch_write_item传入的字段完全一致
   • 例：表分区键为FileSystemName（字符串型），代码中传fs_name或数字值，就会触发Schema不匹配
   • 检查修改后的代码是否为了跳过错误，把写入的Item改成空字典，或删除了核心数据字段
2. 检查写入逻辑的执行路径
   • 确认代码中是否有条件判断导致写入逻辑未执行（如if分支走了错误路径）
   • 检查是否用try-except吞了错误：比如加了except Exception:但无日志输出，导致写入失败却无法察觉

二、空邮件问题的关联排查 #

空邮件说明监控数据未正常传递到邮件组装逻辑，大概率是集成DynamoDB时的修改破坏了原数据流程：

• 原代码直接用采集到的监控数据组装邮件，修改后是否误将数据来源改成了DynamoDB（此时DB为空，导致邮件空）
• 检查监控数据变量：比如原代码monitoring_data = get_ontap_fs_data()，修改后是否被改成从DB读取，且未确保写入成功再读取
• 确认是否在写入DB前清空了原采集的监控数据变量

三、结合代码的具体检查建议 #

1. 数据采集环节 #

• 确认ONTAP数据采集函数（如get_ontap_fs_data()）返回的结构与未集成DB时一致，未被修改
• 在Lambda的CloudWatch日志中查看采集到的数据，确认数据正常生成

2. DynamoDB写入环节 #

• 打印要写入的Item内容到日志，验证结构是否符合表Schema要求：

  print(f"待写入DynamoDB的Item: {item}")
  

• 检查boto3调用格式是否正确：
  • 用client时，Item需用{'S': '字符串值'}/{'N': '数字值'}的格式
  • 用resource时，可直接传入原生Python类型（如字符串、数字）
• 添加详细的错误捕获日志，避免吞掉错误：

  try:
      response = dynamodb.put_item(Item=item)
      print(f"DynamoDB写入成功: {response}")
  except Exception as e:
      print(f"DynamoDB写入错误: {type(e).__name__}: {str(e)}")
      raise e  # 抛出异常终止执行，方便排查
  

3. 邮件发送环节 #

• 确认邮件内容组装逻辑是否依赖原始采集数据，而非DynamoDB读取的数据（若依赖DB，需确保写入成功后再读取）
• 打印邮件内容的原始数据到日志，确认数据是否为空

四、快速验证步骤 #

1. 注释所有DynamoDB相关代码，运行Lambda，确认邮件正常发送、数据正常
2. 逐步添加DynamoDB逻辑：
   • 第一步仅打印待写入的Item，不实际调用写入API，验证结构正确性
   • 第二步调用写入API，查看CloudWatch日志确认写入结果
3. 确认写入成功后，再调整邮件逻辑（若需从DB读取数据）

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