告别PI/PO！用SAP CPI（BTP Integration Suite）手把手搭建你的第一个集成流

从SAP PI/PO到云原生集成：基于BTP Integration Suite的实战转型指南

当SAP传统中间件PI/PO逐渐向云端迁移时，许多开发者正面临技术栈更新的挑战。SAP BTP Integration Suite（原CPI）作为新一代云集成平台，不仅延续了企业级集成能力，更通过低代码开发模式和Apache Camel框架的深度整合，重新定义了集成效率的标准。本文将从一个真实的订单数据同步场景出发，完整演示如何利用云原生工具链重构传统集成方案。

1. 云集成平台的核心优势与架构解析

与本地部署的PI/PO相比，BTP Integration Suite最显著的变革在于其全托管式服务架构。开发环境完全基于Web浏览器，无需维护服务器基础设施，这使团队能够专注于业务逻辑而非运维工作。平台内置的300+连接器覆盖了从SAP S/4HANA到Salesforce等主流企业系统，大幅降低了适配器开发成本。

技术架构层面，三个核心组件构成了云集成的支柱：

• 设计时环境：基于Eclipse的Web IDE提供可视化流程设计器，支持拖拽式编排集成逻辑
• 运行时引擎：构建于Apache Camel的企业级扩展，在Cloud Foundry或Kyma环境中弹性扩展
• 管理监控：统一控制台集成消息追踪、日志分析和告警管理功能

典型的技术栈对比：

在实际项目中，某跨国制造企业将供应商协同系统从PI迁移到云平台后，接口平均开发周期从3周缩短至4天，主要得益于预置模板的复用和测试流程的简化。

2. 构建首个云集成流的完整流程

让我们以采购订单状态同步为例，演示端到端的开发过程。该场景需要将S/4HANA中的订单变更实时推送到Concur费用管理系统，涉及数据转换和路由逻辑。

2.1 环境准备与项目初始化

1. 登录SAP BTP Cockpit，确保已分配Integration Suite服务实例
2. 在"Design"区域创建新的集成包（建议命名规范：<公司代码>_<项目>_<版本>）
3. 右键包选择"New"→"Integration Flow"创建空白iFlow

关键配置参数：

Name: ZPO2CONCUR_ORDER_SYNC Version: 1.0.0 Processing Mode: Sync/Async (根据业务需求选择)

2.2 连接器配置与消息路由

从组件面板拖拽以下元素构建基础架构：

1. 发送方适配器：SOAP或OData V2（对接S/4HANA）
2. 接收方适配器：HTTP REST（对接Concur API）
3. 路由逻辑：使用Router组件根据订单类型分流

示例路由条件配置：

// 普通订单路由条件 ${property.OrderType} == 'NB' // 紧急订单路由条件 ${property.OrderType} == 'UR' && ${property.Value} > 10000

2.3 消息处理与转换

Content Modifier是云集成中最常用的处理组件之一，典型配置包括：

• Header设置：添加API认证令牌

  <Authorization>Bearer ${property.api_token}</Authorization>

• Property初始化：存储中间计算结果

  ${property.TotalTax} = ${body.PurchaseOrder.Total} * 0.1

• Body转换：使用Groovy脚本处理复杂逻辑

  def po = new XmlSlurper().parseText(body) def concurFormat = [ "requestId": po.Header.OrderNumber, "items": po.Items.Item.collect { [ "productCode": it.Material, "amount": it.NetPrice ] } ] return new JsonBuilder(concurFormat).toString()

3. 高级模式与性能优化

当处理大批量数据时，需要采用特殊设计模式保证系统稳定性：

3.1 批处理与并行执行

1. Splitter模式：分解主单据为行项目

   <!-- XPath拆分配置 --> /PurchaseOrder/Items/Item

2. 并行路由：对独立处理分支启用并行执行

   Parallel Processing: true Thread Count: 5 (根据系统配额调整)

3.2 错误处理机制

云平台提供多级异常捕获方案：

• 本地重试：配置指数退避策略

  Retry Interval: 5000ms Maximum Retries: 3

• 全局死信队列：持久化存储失败消息

  // Groovy异常处理脚本 if (exception.getErrorCode() == 'CONN_TIMEOUT') { setHeader('SAP_RetryLater', 'true') }

3.3 缓存与连接池优化

频繁调用的主数据建议启用缓存：

// 使用Cache Lookup组件 context.getCache().put('MATERIALS', JsonOutput.toJson(materialList), 3600 // TTL秒数 )

连接池参数建议（针对HTTP适配器）：

4. 运维监控与持续改进

部署后的集成流需要完善的观测体系支持：

4.1 消息追踪技术

1. 自定义监控维度：通过Message ID、业务键值等筛选
2. 日志级别动态调整：临时开启DEBUG级别排查问题

   # API调用示例 curl -X PATCH https://api.integration.cloud.sap/v1/LogLevels \ -H 'Authorization: Bearer <token>' \ -d '{"level":"DEBUG","duration":3600}'

4.2 健康检查与自愈

建议的监控指标看板：

4.3 版本控制策略

采用语义化版本管理集成资产：

版本格式：主版本.次版本.修订号 示例：2.1.13 变更类型： - 主版本：不兼容的架构调整 - 次版本：向后兼容的功能新增 - 修订号：问题修正

在大型零售企业的实际案例中，通过建立版本回滚机制，使生产环境故障恢复时间从小时级降至分钟级。关键是在每次重大变更前创建恢复点：

// 自动化版本标记脚本 import com.sap.gateway.ip.core.customdev.util.Message def Message processData(Message message) { def flowVersion = message.getProperties()['flowVersion'] message.setHeader('X-Deployment-Version', flowVersion) return message }

随着项目经验的积累，建议逐步构建企业专属的集成组件库。某汽车厂商通过标准化60+可复用组件，使新接口开发效率提升40%。典型的资产目录包括：

• 通用错误处理子流程
• 标准认证模块
• 日志规范模板
• 数据验证框架

迁移到云集成平台不仅是技术栈的更新，更是工作模式的转型。开发团队需要适应更快的迭代节奏和更主动的监控习惯。在实际操作中，建议先从非关键业务流开始试点，待熟悉云平台特性后再逐步迁移核心业务接口。