轻易云平台助力ETL转换并写入金蝶云星空

  • 轻易云集成顾问-李国敏

旺店通·企业奇门数据集成到金蝶云星空：技术实施案例

在本次系统对接集成案例中，核心任务是将旺店通·企业奇门的数据实时抓取并高效地写入金蝶云星空，以确保业务流程的无缝衔接。在实际操作中，我们主要采用了强大的API接口，包括旺店通·企业奇门的wdt.shop.query和金蝶云星空的batchSave。

确保集成旺店通·企业奇门数据不漏单

为了防止数据丢失，我们首先设计了一套可靠的数据抓取机制。通过定时任务调用 wdt.shop.query 接口，可以持续、稳定地获取最新的数据。同时，为进一步提升安全性和准确率，系统会对每一次成功抓取的数据进行确认存储，加上独特的日志记录功能，实现全程透明化监控。

处理分页和限流问题

鉴于 API 的调用限制及海量数据传输需要解决的问题，我们特别关注了处理分页与限流策略。在实现过程中，通过合理设置分页参数，在分批获取完所有所需数据后再进行批量处理。此外，还配置了重试机制，对于网络波动或接口响应失败等异常情况，也能做到快速恢复，保证系统平稳运行。

金蝶云星空数据格式差异转换

由于两个平台间的数据格式存在明显差异，为确保最终成功写入，必须进行必要的格式转换。为此，我们利用轻易云平台提供的可视化操作界面，对源数据字段做精细映射和类型转换，使得每条记录都符合金蝶云星空 batchSave API 的要求。这不仅提高了操作效率，也大幅降低了人为错误发生的可能性。

综合以上技术点，本项目展示了如何通过科学的方法与工具，高效、安全地实现跨平台的大规模数据集成。如果您希望了解更多关于实施细节以及遇到挑战后的具体解决方案，请继续阅读后续内容。 用友与SCM系统接口开发配置

调用旺店通·企业奇门接口wdt.shop.query获取并加工数据

在数据集成生命周期的第一步中，调用源系统接口获取数据是至关重要的环节。本文将详细探讨如何使用轻易云数据集成平台配置元数据，通过调用旺店通·企业奇门接口wdt.shop.query获取并加工数据。

接口概述

wdt.shop.query接口用于查询旺店通系统中的店铺信息。该接口采用POST请求方式，支持分页查询，返回指定平台和店铺编号的相关信息。

元数据配置解析

以下是对元数据配置的详细解析：

{
  "api": "wdt.shop.query",
  "effect": "QUERY",
  "method": "POST",
  "number": "shop_no",
  "id": "shop_id",
  "name": "shop_no",
  "idCheck": true,
  "request": [
    {
      "field": "platform",
      "label": "平台ID",
      "type": "string",
      "describe": "平台ID"
    },
    {
      "field": "shop_no",
      "label": "店铺编号",
      "type": "string",
      "describe": "代表店铺所有属性的唯一编码，用于店铺区分，ERP内支持自定义（ERP店铺界面设置），用于获取指定店铺数据信息"
    }
  ],
  "otherRequest": [
    {
      "field": "page_size",
      "label": "分页大小",
      "type": "string",
      "describe": "每页返回的数据条数，输入值范围1~100，不传本参数，输入值默认为40，使用举例单击这里",
      "value":"{PAGINATION_PAGE_SIZE}"
    },
    {
      "field":"page_no",
      "label":"页号",
      "type":"string",
      "describe":"不传值默认从0页开始",
      "value":"{PAGINATION_START_PAGE}"
    }
  ],

请求参数配置

  1. 平台ID（platform）：

    • 类型：字符串
    • 描述：用于标识不同的平台。

  2. 店铺编号（shop_no）：

    • 类型：字符串
    • 描述：代表店铺所有属性的唯一编码，用于区分不同的店铺。

  3. 分页大小（page_size）：

    • 类型：字符串
    • 描述：每页返回的数据条数，输入值范围1~100，不传本参数时默认为40。

  4. 页号（page_no）：

    • 类型：字符串
    • 描述：不传值时默认从0页开始。

数据请求与清洗

在调用wdt.shop.query接口时，需要根据业务需求设置合适的请求参数。以下是一个示例请求：

{
  “platform”: “PLATFORM_ID”,
  “shop_no”: “SHOP_NO”,
  “page_size”: “50”,
  “page_no”: “0”
}

通过上述请求，可以获取指定平台和店铺编号的信息，并进行分页处理。轻易云数据集成平台会自动处理这些请求，并确保返回的数据符合预期格式。

数据转换与写入

在获取到原始数据后，需要对其进行必要的清洗和转换，以便后续写入目标系统。例如，可以将原始JSON格式的数据转换为数据库表格格式，并根据业务逻辑进行字段映射和类型转换。

以下是一个简单的数据转换示例：

{
  “shop_id”: “12345”,
  “shop_name”: “Test Shop”,
  “platform_id”: “PLATFORM_ID”
}

通过轻易云数据集成平台，可以轻松实现上述数据转换，并将处理后的数据写入目标系统，如数据库或另一个API端点。

实践案例

假设我们需要从旺店通系统中获取某个平台下所有店铺的信息，并将其存储到本地数据库中。具体步骤如下：

  1. 配置元数据，设置API、请求方法、字段映射等。
  2. 调用wdt.shop.query接口，传入必要的参数如平台ID、店铺编号等。
  3. 获取响应数据，对其进行清洗和转换。
  4. 将处理后的数据写入本地数据库。

通过以上步骤，可以实现从源系统到目标系统的数据无缝对接，大大提高了业务流程的自动化程度和效率。

综上所述，通过合理配置元数据并调用wdt.shop.query接口，可以高效地获取并加工旺店通系统中的店铺信息，为后续的数据处理和分析奠定坚实基础。 金蝶与CRM系统接口开发配置

使用轻易云数据集成平台实现数据ETL转换并写入金蝶云星空API接口

在数据集成生命周期的第二阶段，我们将已经集成的源平台数据进行ETL转换，并转为目标平台金蝶云星空API接口所能够接收的格式，最终写入目标平台。本文将详细探讨如何通过轻易云数据集成平台配置元数据，实现这一过程。

配置元数据

首先，我们需要了解如何配置元数据，以便将源数据转换为金蝶云星空API接口所需的格式。以下是我们需要配置的元数据：

{
  "api": "batchSave",
  "effect": "EXECUTE",
  "method": "POST",
  "idCheck": true,
  "request": [
    {
      "field": "FNumber",
      "label": "编码",
      "type": "string",
      "describe": "编码",
      "value": "{shop_no}"
    },
    {
      "field": "FName",
      "label": "名称",
      "type": "string",
      "describe": "名称",
      "value": "{shop_name}"
    },
    {
      "field": "FCreateOrgId",
      "label": "创建组织",
      "type": "string",
      "describe": "创建组织",
      "parser": {
        "name": "ConvertObjectParser",
        "params": "FNumber"
      },
      "value": 100
    },
    {
      ...
    }
  ],
  ...
}

数据请求与清洗

在ETL过程中，首先需要从源平台请求数据，并进行必要的清洗和转换。假设我们从一个电商平台获取店铺信息，包括店铺编号（shop_no）和店铺名称（shop_name）。这些信息需要映射到金蝶云星空API接口中的相应字段。

数据转换与写入

接下来，我们将清洗后的数据进行转换，使其符合金蝶云星空API接口的要求。根据上述元数据配置，我们需要将店铺编号映射到FNumber字段，店铺名称映射到FName字段。此外，还需要设置创建组织和使用组织等字段。

以下是具体的转换逻辑：

  1. 编码 (FNumber)：将源平台的店铺编号（shop_no）直接映射到目标平台的编码字段。
  2. 名称 (FName)：将源平台的店铺名称（shop_name）直接映射到目标平台的名称字段。
  3. 创建组织 (FCreateOrgId) 和 使用组织 (FUseOrgId)：这两个字段都使用固定值100，并通过ConvertObjectParser进行解析。
  4. 收款条件 (FRECCONDITIONID)：该字段也通过ConvertObjectParser进行解析，但具体值根据业务需求而定。

API调用

完成以上步骤后，我们通过POST方法调用金蝶云星空API接口，将转换后的数据批量保存到目标系统中。具体调用参数如下：

{
  ...
  {
    field: 'FormId',
    label: '业务对象表单Id',
    type: 'string',
    describe: '必须填写金蝶的表单ID如:PUR_PurchaseOrder',
    value: 'BD_Customer'
  },
  {
    field: 'Operation',
    label: '执行的操作',
    type: 'string',
    describe: '执行的操作',
    value: 'BatchSave'
  },
  ...
}

提交并审核

为了确保数据的一致性和完整性，我们可以选择在提交后自动审核。此功能通过设置IsAutoSubmitAndAudit为true来实现。此外，通过设置IsVerifyBaseDataField为true，可以验证所有基础资料的有效性。

总结

通过以上步骤，我们成功地将源平台的数据进行了ETL转换，并通过轻易云数据集成平台写入到了金蝶云星空API接口中。这一过程不仅提高了数据处理效率，还确保了不同系统间的数据无缝对接，为企业的数据管理提供了有力支持。 金蝶与外部系统打通接口

版权声明

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

金蝶云星空与旺店通打通
更多系统对接方案