AWS AppFlow:筛选并重命名字段同步至S3(无需Glue)
解决AWS AppFlow同步指定字段并重命名的问题
要解决这个报错,核心是满足AppFlow的任务校验规则——必须通过Projection任务或MAP_ALL任务明确要从源端提取的字段集合,之后再配合Map任务完成字段重命名。具体操作步骤如下:
第一步:添加Projection任务
在流的数据转换环节,先新增一个Projection任务,选择你的Salesforce源对象,然后勾选所有需要同步到S3的源字段。这个任务的作用是告诉AppFlow:只从Salesforce提取这些指定字段,替代之前MAP_ALL拉取全量字段的逻辑。第二步:添加Map任务完成重命名
在Projection任务之后,为每个需要重命名的字段单独添加Map任务:- 选择Projection任务中已包含的某个源字段
- 在目标字段处输入你想要的新名称
- 重复此操作完成所有需要重命名字段的映射
注意事项
- Projection任务必须放在所有Map任务之前,保证字段提取逻辑先执行
- Projection任务里的字段必须覆盖所有后续Map任务用到的源字段,否则会出现字段找不到的错误
- 如果有不需要重命名的字段,只要在Projection里勾选即可,不需要额外添加Map任务,AppFlow会默认保留原字段名同步到S3
这样配置后,保存流时就不会再触发Task Validation Error: You must specify a projection task or a MAP_ALL task的错误,同时实现仅同步指定字段并按需重命名的需求,全程无需依赖Glue等外部工具。
内容的提问来源于stack exchange,提问作者user3073511
相关产品推荐
相关产品推荐

