PynamoDB模型优化：如何将ParsedOutput拆分为易读独立属性？

看起来你遇到的核心问题是旧数据没有自动迁移到新的属性类型，加上自定义MapAttribute的写法和更新逻辑没触碰到ParsedOutput字段，导致改动没生效。下面分步骤给你解决思路：

1. 修正自定义MapAttribute的定义 #

你之前写的MyMapAttribute嵌套了一层my_internal_map，这其实是多余的，反而会让数据结构变复杂。根据你的需求（让ParsedOutput以键值对Map形式存储，方便查看），分两种情况处理：

情况A：ParsedOutput的键是固定的（比如有明确的字段名） #

直接在自定义MapAttribute里定义对应的属性：

class ParsedOutputMap(MapAttribute):
    # 替换成你实际需要的字段名
    UserEmail = UnicodeAttribute(null=True)
    OrderNumber = UnicodeAttribute(null=True)
    InvoiceAmount = UnicodeAttribute(null=True)

class Parser(MapAttribute):
    ParserType = UnicodeAttribute()
    MailBody = UnicodeAttribute()
    BestTemplate = UnicodeAttribute(null=True)
    ParseStatus = ParseStatus()
    ParsedOutput = ParsedOutputMap(null=True)

情况B：ParsedOutput的键是动态的（不确定具体字段） #

不需要自定义，直接用原生的MapAttribute即可：

class Parser(MapAttribute):
    ParserType = UnicodeAttribute()
    MailBody = UnicodeAttribute()
    BestTemplate = UnicodeAttribute(null=True)
    ParseStatus = ParseStatus()
    ParsedOutput = MapAttribute(null=True)

2. 手动迁移现有数据（最关键的一步） #

PynamoDB不会自动帮你把旧的JSONAttribute数据转换成MapAttribute类型，因为DynamoDB是无模式数据库，模型定义的改动不会自动同步已有数据。你需要遍历所有条目，手动转换并更新：

import datetime
from datetime import timezone

# 遍历表中所有OMPStatus条目
for item in OMPStatusModel.scan():
    # 检查是否有Parser和ParsedOutput数据
    if item.Parser and item.Parser.ParsedOutput:
        # 假设原来的ParsedOutput是[{"key": "xxx", "value": "yyy"}, ...]的列表格式
        # 把列表转换成键值对字典
        parsed_data_dict = {entry["key"]: entry["value"] for entry in item.Parser.ParsedOutput}
        
        # 更新Parser对象的ParsedOutput字段
        updated_parser = item.Parser
        updated_parser.ParsedOutput = parsed_data_dict
        
        # 执行更新操作，同时更新UpdatedDateTime
        item.update(actions=[
            OMPStatusModel.Parser.set(updated_parser),
            OMPStatusModel.UpdatedDateTime.set(datetime.datetime.now(timezone.utc))
        ])

注意：如果你的ParsedOutput原来不是列表格式，而是其他JSON结构，需要调整转换逻辑，确保最终输出是符合MapAttribute要求的字典类型。

3. 确保后续更新逻辑正确触发ParsedOutput修改 #

你之前的update代码只更新了SES和UpdatedDateTime，完全没涉及ParsedOutput字段，所以即使模型改了，新数据也不会自动用新的类型存储。后续处理数据时，要明确把ParsedOutput转换成字典后再赋值给模型的对应字段：

# 示例：处理新的解析结果时
new_parsed_output = {"UserEmail": "test@example.com", "OrderNumber": "ORD123"}
updated_parser = Parser(
    ParserType="your-type",
    MailBody="mail-content",
    ParseStatus=ParseStatus.your_status,
    ParsedOutput=new_parsed_output
)

# 更新条目
OMPStatusModel.update(
    actions=[
        OMPStatusModel.SES.set(kwargs[key]),
        OMPStatusModel.Parser.set(updated_parser),
        OMPStatusModel.UpdatedDateTime.set(datetime.datetime.now(timezone.utc))
    ]
)

4. 验证结果 #

迁移完成后，你可以直接在DynamoDB控制台查看OMPStatus表的条目，此时Parser.ParsedOutput应该以可展开的Map形式展示，而不是之前的JSON字符串或列表，方便团队查看。

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