请求协助开发Informatica作业：将CSV导入Oracle与MySQL数据库

一、多表CSV数据拆分转换 #

针对单CSV对应多张表的场景，按以下步骤处理：

• 源文件配置：在Source Analyzer里创建Flat File源，严格匹配样本CSV的字段分隔符、文本限定符、行分隔符，确保所有字段能被正确读取。
• 数据拆分：
  • 有标识字段的情况：如果CSV里有record_type这类区分不同表数据的字段，直接用Router转换，按字段值把数据路由到不同数据流分支，每个分支对应一张目标表。
  • 无标识字段的情况：如果是固定行分布（比如前100行是表1，接下来200行是表2），用Sequence Generator生成行号，再用Filter或Router按行号范围拆分；如果是字段逻辑区分，用Expression转换添加标记字段（比如判断某字段非空则归为表1），再路由。
• 字段映射与清洗：每个分支里加Expression转换，处理空值替换、数据格式转换（比如CSV的字符串转Oracle日期类型TO_DATE(TRIM(field), 'YYYY-MM-DD')），然后和目标表（Oracle/SQL Server）做字段映射，注意数据类型对齐。
• 目标加载策略：全量加载就Truncate目标表再Insert；增量加载用Update Strategy转换标记插入/更新，或者用Lookup判断数据是否已存在。

二、每日CSV加载自动化 #

• Workflow调度：在Workflow Manager里把映射打包成Session，再创建Workflow包含这个Session。打开Workflow的Scheduler配置，设置每日执行时间（比如凌晨2点），支持按天/周/月重复，也可以设置文件到达触发（监控指定目录是否有新CSV，有则启动作业）。
• 文件拉取自动化：
  • 用Command Task执行脚本（shell/bat）：脚本通过FTP/SFTP拉取第三方服务器的CSV到Informatica本地目录，同时加文件校验（检查文件大小是否符合预期、是否有完整结尾行），拉取成功后再启动后续Session。
  • 直接用Informatica FTP源：在Source里配置FTP/SFTP连接，直接读取远程服务器的文件，但建议先拉到本地再处理，避免网络波动导致作业失败。
• 收尾与监控：加Command Task把处理完的CSV移到归档目录（命名加上日期，比如data_20240520.csv），防止重复加载；配置Email Task，作业成功/失败时发送通知到指定邮箱，方便及时排查问题。

三、通用作业模板结构 #

一套可复用的Workflow结构：

1. Command Task：执行文件拉取+校验脚本
2. Session Task：运行多表拆分映射
3. Command Task：执行文件归档脚本
4. Email Task：发送作业执行状态通知

内容的提问来源于stack exchange，提问作者Emmanuel Odenyire Christopher