C# Lambda函数处理DynamoDBEvent及NewImage为空问题排查

我之前也碰到过类似的情况，先别急着认定是Bug，咱们先从最常见的配置问题排查起，再聊聊正确处理DynamoDBEvent的姿势：

一、先排查非Bug类的常见原因 #

• 流视图类型配置错误：这是最容易踩的坑！DynamoDB流默认的视图类型是KEYS_ONLY，这种模式下只会把主键字段写入流记录，NewImage自然是空的。你需要把流视图类型改成NEW_IMAGE（仅新数据）或者OLD_AND_NEW_IMAGES（新旧数据都有）：
  • 控制台操作：打开DynamoDB控制台，找到目标表→进入「流」标签页→修改流视图类型；
  • CLI命令：aws dynamodb update-table --table-name YourTableName --stream-specification StreamEnabled=true,StreamViewType=NEW_IMAGE
• 事件类型导致的空值：如果流记录对应的是REMOVE（删除）操作，NewImage本来就是空的，只有OldImage会有数据。处理前先检查record.EventName字段，确认是INSERT或MODIFY操作再看NewImage。
• 权限遗漏（虽然概率低）：虽然函数能执行，但可以检查下Lambda执行角色的权限策略，确保包含dynamodb:GetRecords、dynamodb:GetShardIterator、dynamodb:DescribeStream这几个核心权限，避免因权限限制导致数据读取不完整。

二、正确处理C# Lambda中的DynamoDBEvent #

给你一个完整的示例代码，涵盖事件解析、类型判断和属性读取的正确方式：

using Amazon.Lambda.Core;
using Amazon.Lambda.DynamoDBEvents;
using Amazon.DynamoDBv2.Model;

[assembly: LambdaSerializer(typeof(Amazon.Lambda.Serialization.SystemTextJson.DefaultLambdaJsonSerializer))]

namespace DynamoDBStreamProcessor;

public class StreamHandler
{
    public async Task ProcessStream(DynamoDBEvent dynamoEvent, ILambdaContext context)
    {
        context.Logger.LogInformation($"收到 {dynamoEvent.Records.Count} 条流记录");

        foreach (var record in dynamoEvent.Records)
        {
            context.Logger.LogInformation($"事件ID: {record.EventID} | 事件类型: {record.EventName}");

            switch (record.EventName)
            {
                case OperationType.INSERT:
                case OperationType.MODIFY:
                    if (record.Dynamodb.NewImage != null && record.Dynamodb.NewImage.Count > 0)
                    {
                        // 示例：将NewImage转换为自定义实体
                        var user = MapToUser(record.Dynamodb.NewImage);
                        context.Logger.LogInformation($"新增/修改用户: {user.Id} - {user.Name}");
                    }
                    else
                    {
                        context.Logger.LogWarning("NewImage为空，请检查流视图配置");
                    }
                    break;
                case OperationType.REMOVE:
                    var deletedKey = record.Dynamodb.Keys["UserId"].S;
                    context.Logger.LogInformation($"删除用户ID: {deletedKey}");
                    break;
            }
        }

        await Task.CompletedTask;
    }

    // 自定义映射方法：将DynamoDB的AttributeValue字典转换为实体类
    private User MapToUser(Dictionary<string, AttributeValue> newImage)
    {
        return new User
        {
            Id = newImage["UserId"].S,
            Name = newImage["UserName"].S,
            Age = int.Parse(newImage["UserAge"].N)
        };
    }
}

// 自定义实体类示例
public class User
{
    public string Id { get; set; }
    public string Name { get; set; }
    public int Age { get; set; }
}

几点关键注意事项：

• 序列化器选择：建议使用SystemTextJson序列化器（如示例所示），确保和AWS SDK版本兼容，避免因序列化问题导致数据解析异常；
• 属性类型匹配：读取AttributeValue时要对应正确的类型，比如字符串用.S、数字用.N、布尔值用.BOOL，否则会抛出类型转换异常；
• 空值防御：处理前一定要先判断NewImage是否为null、Count是否大于0，避免空引用错误。

三、如果排查后仍异常，如何确认是否是Bug？ #

如果上面的配置都正确，且事件类型是INSERT/MODIFY，但NewImage还是空，可以用AWS CLI直接读取流记录验证：

1. 从DynamoDB表的「流」标签页获取流ARN；
2. 执行命令获取shard迭代器：

   aws dynamodb get-shard-iterator --stream-arn your-stream-arn --shard-id your-shard-id --shard-iterator-type TRIM_HORIZON
   

3. 用返回的迭代器获取原始记录：

   aws dynamodb get-records --shard-iterator your-shard-iterator
   

如果CLI返回的原始记录里有NewImage，说明问题出在Lambda的序列化或代码处理上；如果CLI里也没有，那可能是DynamoDB流的异常，这时候可以提交AWS支持工单进一步排查。

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