Pinpoint向Kinesis发送的事件数据不符合要求 如何对接Personalize？

以下三种方案均可实现Pinpoint数据上报到Personalize，满足活动启动要求： #

方案1：基于现有Kinesis Firehose链路改造 #

• 在当前Kinesis Data Firehose配置中添加数据转换Lambda函数，针对你当前不符合格式要求的输出做字段映射：将Pinpoint输出事件中的用户ID、应用ID、事件发生时间、事件类型，分别映射为Personalize交互数据集要求的USER_ID、ITEM_ID、TIMESTAMP、EVENT_TYPE必填字段
• 转换后的数据可以选择两种路径同步到Personalize：全量数据落S3后作为历史数据集批量导入，实时数据直接在Lambda中调用Personalize的PutEvents接口上报到事件追踪器

方案2：Pinpoint事件直连Lambda上报 #

• 跳过Kinesis Firehose中转，直接在Pinpoint控制台配置事件触发规则，匹配你需要同步到Personalize的用户行为事件，触发目标设置为自定义Lambda函数
• Lambda中完成字段校验、格式转换后直接调用PutEvents接口上报，链路更简洁，适合不需要留存原始Pinpoint事件的场景

方案3：通过EventBridge做事件路由 #

• 先将Pinpoint全量事件投递到Amazon EventBridge，配置事件规则过滤出需要上报给Personalize的行为事件
• 规则目标可直接设置为Personalize事件追踪器，或设置为转换Lambda做自定义字段处理，后续可灵活扩展其他事件消费链路

注意事项 #

• Personalize启动活动要求至少有1000条以上的有效用户交互数据，若你是刚对接实时链路，建议先导入一批历史用户和应用的交互数据打底，再叠加实时上报数据，即可满足活动启动的最低要求
• 请先确认Pinpoint侧的事件埋点已经包含Personalize要求的三个核心必填字段：用户唯一标识、应用唯一标识、事件发生时间戳，若有缺失需先补充埋点

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