从金蝶到小满OKKICRM：使用轻易云平台实现场景化的ETL转换

  • 轻易云集成顾问-曹润

金蝶云星空与小满OKKICRM数据集成案例：实现物料到产品数据的无缝对接

在企业级应用中，跨系统的数据流转和共享是提升业务效率和决策精准度的重要环节。本次案例分享将详细解析如何通过轻易云平台，成功实现金蝶云星空物料数据向小满OKKICRM产品数据的高效集成。

首先，通过调用金蝶云星空API接口executeBillQuery获取最新的物料信息。为了确保在繁忙时段内也能稳定抓取大量数据，我们采用了定时调度机制，并借助轻易云的平台支持，实现了高吞吐量、可靠的数据提取过程。

一旦获取到所需的物料数据，我们需要针对不同字段格式进行自定义转换，以匹配小满OKKICRM的信息结构。这一步骤利用了轻易云可视化的数据流设计工具，使得复杂的数据映射逻辑更加直观明了。为解决两套系统之间API资产管理上的差异，统一视图和控制台发挥了重要作用，不仅提高了资源利用率，还简化了维护工作。

接下来，在批量写入阶段，通过调用小满OKKICRM提供的/v1/product/push API，我们确保所有处理后的物料信息能够快速且准确地导入到目标系统中。在这一过程中，为应对可能发生的大量并发请求，集中的监控和告警功能实时追踪任务状态，并及时处理异常情况，例如分页问题、限流策略等，从而保证整个操作流程不漏单。

最后，为进一步优化集成效果并增强稳定性，对每个关键步骤都设立了日志记录与实时监控机制。这不仅帮助我们有效识别潜在问题，还为后续改进提供详实依据。此外，对于偶尔出现的小故障，如网络波动或临时连接失败，也设计了一套完善的错误重试机制，确保整体流程顺畅运行。 如何对接用友BIP接口

调用金蝶云星空接口executeBillQuery获取并加工数据

在数据集成的生命周期中，调用源系统接口是至关重要的一步。本文将详细介绍如何通过轻易云数据集成平台调用金蝶云星空的executeBillQuery接口，获取物料信息并进行初步加工。

接口配置与请求参数

首先，我们需要配置调用金蝶云星空接口的元数据。根据提供的元数据配置，我们可以看到主要的请求参数和字段映射关系。

{
  "api": "executeBillQuery",
  "method": "POST",
  "number": "FNumber",
  "id": "FMATERIALID",
  "pagination": {
    "pageSize": 100
  },
  "request": [
    {"field":"FMATERIALID","label":"实体主键","type":"string","value":"FMATERIALID"},
    {"field":"FNumber","label":"编码","type":"string","value":"FNumber"},
    {"field":"FName","label":"名称","type":"string","value":"FName"},
    {"field":"FSpecification","label":"规格型号","type":"string","value":"FSpecification"},
    {"field":"FOldNumber","label":"旧物料编码","type":"string","value":"FOldNumber"},
    {"field":"FBARCODE","label":"条码","type":"string","value":"FBARCODE"},
    {"field":"FDescription","label":"描述","type":"string","value":"FDescription"},
    {"field":"FMaterialGroup_FNumber","label":"物料分组","type":"string","value":"FMaterialGroup.FNumber"},
    {"field":"FErpClsID","label":"物料属性","type":"string","value":"FErpClsID"},
    {"field":"FDocumentStatus","label":"数据状态","type":"string","value":"FDocumentStatus"},
    {"field":"FForbidStatus","label":"禁用状态","type":"string","value":"FForbidStatus"},
    {"field":...}
  ],
  "otherRequest": [
    {"field": "Limit", "label": "最大行数", "type": "string", "describe": "金蝶的查询分页参数", "value": "{PAGINATION_PAGE_SIZE}"},
    {"field": "StartRow", "label": "开始行索引", "type": "string", "describe": "金蝶的查询分页参数", "value": "{PAGINATION_START_ROW}"},
    ...
  ]
}

构建请求体

根据元数据配置，我们需要构建一个POST请求体，包含必要的字段和分页参数。以下是一个示例请求体：

{
  "FormId": "BD_MATERIAL",
  "FieldKeys": [
    "FMATERIALID",
    "FNumber",
    ...
  ],
  "FilterString": "{{LAST_SYNC_TIME|dateTime}} and FUseOrgId.FNumber='100' and (FNumber LIKE '01%' or FNumber LIKE '09%' or FNumber LIKE '08%')",
  ...
}

调用API并处理响应

通过轻易云数据集成平台，我们可以发送上述请求到金蝶云星空接口，并获取响应数据。以下是一个示例代码片段，用于处理API响应：

import requests

url = 'https://api.kingdee.com/executeBillQuery'
headers = {'Content-Type': 'application/json'}
payload = {
  # 构建请求体
}

response = requests.post(url, headers=headers, json=payload)
data = response.json()

# 数据处理逻辑
for item in data['Result']:
    material_id = item['FMATERIALID']
    number = item['FNumber']
    name = item['FName']
    # 更多字段处理...

数据清洗与转换

在获取到原始数据后，需要进行初步的数据清洗与转换，以确保数据符合目标系统的要求。例如，可以对某些字段进行格式化或单位转换：

def clean_data(item):
    item['name'] = item['name'].strip()
    item['number'] = int(item['number'])

for item in data['Result']:
    clean_data(item)

写入目标系统

最后，将清洗后的数据写入目标系统。在轻易云平台上，可以通过配置相应的数据写入模块，实现自动化的数据传输。

def write_to_target_system(cleaned_data):
    # 实现写入逻辑，例如调用目标系统API

综上所述，通过轻易云数据集成平台调用金蝶云星空接口executeBillQuery，我们能够高效地获取、清洗和转换物料信息，为后续的数据处理和分析打下坚实基础。 打通用友BIP数据接口

使用轻易云数据集成平台实现金蝶物料到小满OKKICRM的ETL转换

在数据集成过程中，ETL（Extract, Transform, Load）是关键步骤之一。本文将详细探讨如何使用轻易云数据集成平台，将金蝶物料数据转换为小满OKKICRM API接口所能接收的格式，并写入目标平台。

数据请求与清洗

首先，我们需要从源系统（金蝶）中提取所需的物料数据。假设我们已经完成了这一阶段，并获得了原始数据。接下来，我们将进入数据转换与写入阶段。

数据转换与写入

在这一阶段，我们需要将提取的数据进行格式转换，以符合小满OKKICRM API接口的要求。以下是具体的元数据配置：

{
  "api": "/v1/product/push",
  "method": "POST",
  "idCheck": true,
  "request": [
    {
      "field": "product_id",
      "label": "产品id",
      "type": "string",
      "describe": "产品名称",
      "value": "_mongoQuery d0f8fac1-8e5c-3ce9-bee0-bbdf83566c03 findField=content.product_id where={\"content.product_no\" : {\"$eq\":\"{FNumber}\"}}"
    },
    {
      "field": "name",
      "label": "产品名称",
      "type": "string",
      "describe": "产品名称",
      "value": "{FName}"
    },
    {
      "field": "product_no",
      "label": "产品编码",
      "type": "string",
      "describe": "ATC NO",
      "value": "{FNumber}"
    },
    {
      "field": "model",
      "label": "产品型号",
      "type": "string",
      "describe": "产品型号",
      "value": "{FSpecification}"
    },
    {
      // 其他字段配置省略...
    }
  ]
}

配置解读

  1. API路径与方法：api字段指定了目标API的路径，即/v1/product/push，而method字段指定了HTTP方法为POST。

  2. ID检查：idCheck字段设置为true，表示在推送数据前需要检查是否存在相同ID的数据。

  3. 字段映射：

    • product_id: 使用MongoDB查询语句从数据库中获取对应的产品ID。
    • name: 直接映射金蝶物料中的FName字段。
    • product_no: 映射金蝶物料中的FNumber字段。
    • model: 映射金蝶物料中的FSpecification字段。
    • 其他字段根据需求进行类似配置。

实际操作步骤

  1. 配置数据源：在轻易云平台上配置金蝶作为数据源，确保能够正确提取所需物料信息。

  2. 编写转换规则：根据上述元数据配置，编写相应的转换规则，将金蝶物料字段映射到小满OKKICRM API所需格式。

  3. 测试与验证：通过轻易云平台提供的测试功能，验证转换后的数据是否符合预期。如果有问题，及时调整映射规则和查询条件。

  4. 执行写入操作：当所有配置和测试都通过后，执行实际的数据写入操作，将转换后的数据推送到小满OKKICRM系统中。

技术要点

  • MongoDB查询语句：在元数据配置中使用了MongoDB查询语句来获取特定字段值，这对于处理复杂的数据关系非常有用。

  • 动态映射：通过模板字符串（如 {FName}）实现动态映射，使得配置更加灵活和可维护。

  • 全生命周期管理：虽然本文重点讨论的是ETL过程，但轻易云平台提供了全生命周期管理功能，包括实时监控和错误处理，这些都确保了整个集成过程的高效和可靠性。

通过上述步骤和技术要点，我们可以高效地将金蝶物料数据转换并推送到小满OKKICRM系统，实现不同系统间的数据无缝对接。 钉钉与MES系统接口开发配置

版权声明

该文章《从金蝶到小满OKKICRM：使用轻易云平台实现场景化的ETL转换》为原创内容，版权归 广东轻亿云软件科技有限公司 所有。 未经本公司书面授权，严禁转载、引用、复制或建立镜像等行为。 若需转载或引用本文内容，请联系本公司获取授权，并在显著位置注明作者姓名、文章出处（包括原文链接）等信息。

轻易云AI数据分析
更多系统对接方案