### 金蝶云星空数据集成案例：其他入库单（非外部代销）OK 在用 在企业信息化的过程中，系统之间的数据对接与集成无疑是至关重要的一环。本篇文章将分享一个基于轻易云数据集成平台，将金蝶云星空中的“其他入库单（非外部代销）”数据高效、安全地集成到另一实例金蝶云星空中的技术案例。 #### 系统对接背景 在本案例中，我们利用执行获取接口`executeBillQuery`从源系统中提取“其他入库单”数据，随后通过写入接口`batchSave`将这些数据批量导入目标系统。为了确保整个过程的顺畅进行和高效率，我们不仅支持自定义的数据转换逻辑，以适应两套系统不同的数据结构，还实现了实时监控和告警机制来及时发现并处理可能出现的异常。 #### 技术实施细节 1. **高吞吐量能力**： 为应对海量业务数据，我们配置了轻易云平台以充分发挥其高吞吐量优势，使得大量“其他入库单”记录能够快速、高效地被写入目标金蝶云星空系统。在实际操作中，通过批次处理方式有效减少网络开销，提高整体性能。 2. **API资产管理功能**： 利用统一视图和控制台全面掌握API资产使用情况，实现资源优化配置。例如，在调用执行获取接口时，可根据具体业务需求定制化请求参数，从而提高查询精度与速度。 3. **分页与限流处理**: 针对金蝶云星空接口的分页及限流问题，我们设计了一套动态调整策略。在获取大体量记录时，通过合理分配每次请求数目，同时设置重试机制，有效避免因超出限制而导致的数据丢失或失败。 4. **异常检测与错误重试机制**: 数据质量监控及异常检测功能贯穿整个流程。当探测到潜在问题如网络波动、服务器响应缓慢等情况，自动触发报警并启动预设好的错误重试策略，保障任务最终成功完成，这一功能尤其对于长时间运行的大型批处理任务显得尤为重要。 5. **定制化映射及转换逻辑**： 根据业务需求，对源系统输出结果进行必要转义、字段匹配及格式调整，以确保目标数据库中的所有字段均能正确映射，并完全符合既定规范。这样的灵活转换极大方便了后续新增或修改项目需求的快速响应能力。 以上布局奠定了本案例实施方案展开的基础，为随后的详细步骤提供技术支撑。如需了解更深入细节，请  ### 调用金蝶云星空接口executeBillQuery获取并加工数据 在数据集成的生命周期中，调用源系统接口获取数据是至关重要的一步。本文将详细探讨如何通过轻易云数据集成平台调用金蝶云星空的`executeBillQuery`接口来获取并加工数据。 #### 接口配置与调用 首先，我们需要配置元数据以便正确调用金蝶云星空的`executeBillQuery`接口。以下是元数据配置的关键部分： ```json { "api": "executeBillQuery", "method": "POST", "number": "FBillNo", "id": "FEntity_FEntryID", "pagination": { "pageSize": 500 }, "idCheck": true, "request": [ {"field":"FEntity_FEntryID","label":"FEntryID","type":"string","value":"FEntity_FEntryID"}, {"field":"FID","label":"实体主键","type":"string","value":"FID"}, {"field":"FBillNo","label":"单据编号","type":"string","value":"FBillNo"}, {"field":"FDocumentStatus","label":"单据状态","type":"string","value":"FDocumentStatus"}, {"field":"FStockOrgId_FNumber","label":"库存组织","type":"string","value":"FStockOrgId.FNumber"}, {"field":"FDate","label":"日期","type":"string","value":"FDate"}, {"field":"FBillTypeID","label":"单据类型","type":"string","value":"FBillTypeID.FNumber"}, {"field":"FSUPPLIERID_FNumber","label":"供应商","type":"string","value":"FSUPPLIERID.FName"}, {"field":"FNOTE","label":"备注","type":"string","value":"FNOTE"}, {"field":"FMATERIALID_FNumber","label":"物料编码","type":"string","value":"FMATERIALID.FNumber"}, {"field":"FSTOCKID","label":"收货仓库","type":"string","value":"FSTOCKID"}, {"field":"FQty","label":"实收数量","type":"string","value":"FQty"}, {"field": "FilterString", "label": "过滤条件", "type": "string", "describe": "示例写法 FSupplierId.FNumber = 'VEN00010' and FApproveDate>=", "value": "FAPPROVEDATE >='{{LAST_SYNC_TIME|date}}' and FBillTypeID.FNumber<>'QTRKD03_SYS' and FBillTypeID.FNumber<>'QTRKD07_SYS' and FSTOCKID.fnumber<>'406'"} ], ... } ``` #### 请求参数解析 1. **API与方法**： - `api`: `executeBillQuery` - `method`: `POST` 2. **分页设置**： - `pagination.pageSize`: 每次请求的数据量，设置为500。 3. **请求字段**： - 包含了多个字段，如`FBillNo`（单据编号）、`FID`（实体主键）、`FMATERIALID_FNumber`（物料编码）等。这些字段将用于构建请求体。 4. **过滤条件**： - `FilterString`: 用于筛选符合条件的数据，例如：`"FAPPROVEDATE >='{{LAST_SYNC_TIME|date}}' and FBillTypeID.FNumber<>'QTRKD03_SYS' and FBillTypeID.FNumber<>'QTRKD07_SYS' and FSTOCKID.fnumber<>'406'"` #### 数据请求与清洗 在实际操作中，首先需要构建请求体，并通过HTTP POST方法发送请求。以下是一个示例请求体： ```json { "FormId": "STK_MISCELLANEOUS", "FieldKeys": ["FBillNo", "FID", ...], "FilterString": "FAPPROVEDATE >='2023-01-01' and FBillTypeID.FNumber<>'QTRKD03_SYS' and FBillTypeID.FNumber<>'QTRKD07_SYS' and FSTOCKID.fnumber<>'406'", ... } ``` 发送请求后，系统会返回符合条件的数据集合。此时，需要对返回的数据进行清洗和转换，以便后续处理和写入目标系统。 #### 数据转换与写入 在数据清洗完成后，需要将其转换为目标系统所需的格式，并通过相应的接口写入目标系统。例如，将金蝶云星空返回的数据转换为ERP系统所需的格式，并调用ERP系统的API进行数据写入。 ```json { ... } ``` 通过这种方式，可以实现不同系统间的数据无缝对接，确保数据的一致性和完整性。 #### 实时监控与异常处理 在整个过程中，实时监控和异常处理同样重要。轻易云平台提供了全透明可视化的操作界面，可以实时监控数据流动和处理状态。一旦出现异常，可以及时进行处理，确保业务流程顺畅运行。 综上所述，通过合理配置元数据并调用金蝶云星空的`executeBillQuery`接口，可以高效地获取并加工所需数据，为后续的数据集成奠定坚实基础。  ### 使用轻易云数据集成平台实现金蝶云星空API接口的数据ETL转换与写入 在数据集成过程中，数据的ETL（提取、转换、加载）是关键步骤之一。本文将详细探讨如何使用轻易云数据集成平台，将已经集成的源平台数据进行ETL转换，并通过金蝶云星空API接口写入目标平台。 #### 元数据配置解析 在本案例中，我们需要将其他入库单（非外部代销）的数据通过金蝶云星空的`batchSave` API接口进行写入。以下是元数据配置的关键部分： - **API Endpoint**: `batchSave` - **HTTP Method**: `POST` - **ID Check**: `true` - **Operation Method**: `merge` - **Request Fields**: - 单据编号 (`FBillNo`) - 单据类型 (`FBillTypeID`) - 库存组织 (`FStockOrgId`) - 日期 (`FDate`) - 供应商 (`FSUPPLIERID`) - 部门 (`FDEPTID`) - 用途 (`FDJZDYyongtu_FNumber`) - 明细信息 (`FEntity`) #### 数据转换与映射 在进行数据转换时，我们需要特别注意字段的映射和转换规则。例如，库存组织字段(`FStockOrgId`)需要根据特定规则进行转换： ```json { "field": "FStockOrgId", "label": "库存组织", "type": "string", "describe": "组织", "parser": { "name": "ConvertObjectParser", "params": "FNumber" }, "value": "_function case when '{FStockOrgId_FNumber}' ='100' then '125' when '{FStockOrgId_FNumber}' ='202' then '126' when '{FStockOrgId_FNumber}' ='204' then '121' else '109' end" } ``` 此段代码通过条件判断，将不同的库存组织编号映射到相应的目标编号。 #### 明细信息处理 明细信息(`FEntity`)包含多个子字段，如物料编码、实收数量、收货仓库等。这些字段需要逐一解析和映射。例如，物料编码字段(`FMATERIALID`)的配置如下： ```json { "field": "FMATERIALID", "label": "物料编码", "type": "string", "describe": "基础资料", "parser": { "name": "ConvertObjectParser", "params": "FNumber" }, "value": "{FMATERIALID_FNumber}", "parent": "FEntity" } ``` 此配置使用了`ConvertObjectParser`解析器，将源平台的物料编码转换为目标平台可识别的格式。 #### 请求体构建 根据元数据配置，我们构建请求体，以适应金蝶云星空API接口的需求。以下是一个示例请求体结构： ```json { "FormId": "STK_MISCELLANEOUS", "IsVerifyBaseDataField": false, "Operation": { ... // 根据业务需求填充其他操作信息 }, ... } ``` #### 数据写入 最后，通过HTTP POST请求将构建好的请求体发送到金蝶云星空API接口，实现数据写入。以下是一个简化的示例代码： ```python import requests url = 'https://api.kingdee.com/batchSave' headers = {'Content-Type': 'application/json'} data = { # 构建好的请求体 } response = requests.post(url, headers=headers, json=data) if response.status_code == 200: print("Data successfully written to Kingdee Cloud.") else: print(f"Failed to write data: {response.text}") ``` 以上代码展示了如何使用Python发送HTTP POST请求，将处理后的数据写入金蝶云星空平台。 #### 总结 通过上述步骤，我们实现了从源平台到金蝶云星空平台的数据ETL转换与写入。在实际应用中，根据具体业务需求，可能需要进一步调整和优化元数据配置及请求体构建逻辑，以确保数据准确无误地传输和存储。