简介
本页介绍了客户CPI迁移集成流程，客户数据从siebel systems迁移到marketing cloud系统已经实施
标准SAP CPI包"SAP marketing cloud–基于文件的数据加载"联系人IFlow已经根据客户进行了增强和定制要求
https://api.sap.com/package/SAPHybrisMarketingCloudfilebaseddataload？section=Artifacts
博客的第2部分描述了将数百万条记录加载到SAP marketing云系统的交互迁移流程。这里的示例描述了SAP marketing cloud，但我们可以使用相同的方法将大量数据迁移到使用相同体系结构的所有S4 HANA或C4 HANA系统中。
标准CPI营销预打包内容的限制
而标准预打包集成内容为从旧版迁移客户数据提供了一个良好的起点以下是标准CPI IFLOW的局限性。
标准集成中提供的错误处理功能通过电子邮件触发警报，这对于复杂的大容量迁移项目来说确实不是一个好的用例，除非有些人想阻塞收件箱。对于失败的数据包和成功发送到每个文件的营销云的数据包，没有完整的审计记录机制。想象一下这样一个场景：我们需要迁移2000万个客户，这些客户被分成200个100k记录的文件，每个OData调用被分成1000k个数据包，以优化性能，而客户希望具有完全可跟踪性来提取文件，以了解哪些记录失败，哪些记录成功处理。没有标准的CPI机制来自动将错误文件移动到错误文件夹。由于这一限制，CPI IFLOW在下一次运行中重新处理失败的故障，导致CPI中出现许多故障。
因此，我们增强了标准内容，以解决上述限制，并启用端到端日志记录，它将告诉我们"哪个1000k数据包的拆分步骤"已成功处理，哪个数据包已失败。日志在这个博客的AWS SFTP服务器中是启用的，但是我们将在以后的博客中讨论如何将审计日志写入hana表，注意使用hana表的审计日志空间！
高层架构
以下是使用SAP CPI DS将数据从Siebel systems迁移到营销云的高层架构。在大容量迁移中，云计算大数据，我们有一个临时区域非常重要，它可以方便地分析数据和识别数据问题，并重新处理错误数据包，协调SAP云到源系统的数据。我们使用sapcloudhana作为暂存区域，因为客户端已经获得了它的许可。但是，只要CPI DS支持，您就可以使用任何DB.
CPI Flow Description
Z。联系人.数据.加载–通过此集成流程，您可以通过SFTP或HTTPS将联系人加载到SAP Marketing云系统中。
IFLOW由主流程组成，大数据培训班，本地子流程和异常流程
CPI流程步骤
SFTP集成流程：
发送方：SFTP–IFLOW触发。步骤是读取SFTP目录，如果源目录包含符合条件的文件，则启动进程。
处理完文件后，它将被移动到存档目录或错误目录（如果在加载过程中出现错误）。
也可以在计划程序部分计划启动IFLOW的频率。
映射and Send（进程调用）–调用本地子进程"映射并发送"。
签入错误（内容修改器）–将交换属性分配给本地变量，以了解流期间是否有错误。
失败？（路由器）–根据错误，原始文件保存在错误或存档文件夹下。
错误中（内容修改器）–如果有错误，将archiveDirectory标准属性替换为错误。archiveDirectory属性告诉流在文件处理完后将其移到何处。
清除变量（写入变量）–清除变量不影响下一次运行。
"映射并发送"和"异常子进程"进程。
这样的子进程正在做一个IFLOW的主逻辑。设置属性，验证CSV和XML结构，将消息拆分为数据包，使用XSLT映射转换消息，将数据包发送到营销部门并处理错误（如果有），以及将日志发布到AWS SFTP下的相应文件夹中。
内容修改器（Content Modifier）–设置流的属性。保存原始文件名（用于日志，以判断哪个文件成功，哪个文件不成功），并将默认的archiveDirectory设置为将文件默认保存在存档下，这样的属性在出现错误时可以被覆盖。
CSV-to-XML Converter（CSV-to-XML Converter）–基于Contacts_2.xsd将CSV转换为XML。设置字段分隔符"|"。
XML验证程序（XML验证程序）–基于TBS|U Contacts|2.xsd验证XML。对字段名和类型执行检查的XML验证器。防止流发布无效数据。
通用拆分器（General Splitter）–使用xpath表达式/CSV\u Contacts/Contact将消息拆分为多个（分组参数）。并行处理已打开。
映射（XSLT映射）–此步骤将CSV文件结构映射为市场OData格式。
标准内容链接https://api.sap.com/package/SAPHybrisMarketingCloudfilebaseddataload？section=Artifacts
调用OData（OData）–通过标准API（ContactOriginData方法）向市场部发送联系人。采用后置法。Odata调用使用批处理参数+多部分/混合内容类型。OData呼叫将数据包发送给Marketing，而Marketing则将请求保存到暂存区。
检查OData响应（路由器）–检查OData呼叫响应的状态。OData调用is会返回一个状态码作为响应的一部分。
