通过轻易云平台实现旺店通到金蝶云的数据ETL和转换

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

旺店通·企业奇门数据集成到金蝶云星辰V2：实现高效无缝的数据对接

在本案例中，我们将探讨如何通过系统对接，将旺店通·企业奇门中的客户数据可靠且高效地集成到金蝶云星辰V2的ERP系统。为了确保业务连续性和数据准确性，本文重点解决了以下几个核心技术问题：

  1. 调用旺店通·企业奇门接口wdt.shop.query: 作为获取源数据的起点，必须处理分页和限流问题，以保证大规模数据抓取的稳定性。
  2. 大量数据快速写入到金蝶云星辰V2: 采用批量操作提升效率，同时注意API调用频率及异常处理机制。
  3. 定时可靠的数据抓取与实时监控: 利用轻易云平台内置的调度功能，实现定时任务并实时监控接口响应与日志记录。

让我们开始深入分析整个对接过程，从调用wdt.shop.query API获取旺店通店铺客户信息，到使用金蝶云星辰V2提供的/jdy/v2/bd/customer API写入目标系统。在此过程中，我们会详细讲解如何配置每个环节，以及应对潜在的问题，比如分页、限流、格式差异和错误重试等关键技术细节。同时，我们还将展示如何利用轻易云平台简化这些复杂操作，实现无缝连接。

这个案例不仅展示了成熟的数据集成方案，也突显出精确控制与实时监控的重要性。这些最佳实践方法，使得整个流程更加透明可视，为数字化运营提供坚实保障。 用友与WMS系统接口开发配置

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

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

接口概述

wdt.shop.query接口用于查询旺店通平台上的店铺信息。该接口采用POST请求方式，能够根据指定的店铺编号（shop_no）返回对应的店铺详细信息。

元数据配置解析

以下是针对wdt.shop.query接口的元数据配置：

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

请求参数详解

  1. 必填参数

    • platform: 平台标识符，类型为字符串。
    • shop_no: 店铺编号，是唯一标识一个店铺的字段。

  2. 可选参数

    • page_size: 每页返回的数据条数，默认值为40，可选范围是1到100。
    • page_no: 页码，不传值时默认从第0页开始。

数据请求与清洗

在轻易云数据集成平台上配置上述元数据后，可以通过以下步骤实现数据请求与清洗：

  1. 构建请求体 根据元数据配置构建请求体，例如查询特定编号为12345的店铺信息：

    {
 "platform": "<your_platform>",
 "shop_no": "12345",
    "page_size":"40",
    "page_no":"0"
}

  2. 发送请求 使用POST方法发送请求至wdt.shop.query接口，并接收响应数据。

  3. 处理响应 响应的数据会自动填充到预设的结构中（由于配置了autoFillResponse: true），无需手动解析。可以直接使用这些数据进行后续处理。

数据转换与写入

在获取并清洗了源系统的数据后，需要将其转换为目标系统所需的格式，并写入目标系统（如金蝶）。这一步通常包括以下几个子步骤：

  1. 映射字段 将源系统中的字段映射到目标系统中的相应字段。例如，将shop_no映射到金蝶中的相应字段。

  2. 格式转换 根据目标系统的要求，对数据进行必要的格式转换。例如，将日期格式从YYYY-MM-DD转换为DD/MM/YYYY。

  3. 写入操作 使用轻易云平台提供的写入功能，将转换后的数据写入目标系统中。这一步可以通过配置相应的API或数据库连接来实现。

通过以上步骤，可以高效地实现从旺店通平台到金蝶系统的数据集成。在整个过程中，轻易云平台提供了全透明可视化的操作界面和实时监控功能，使得每个环节都清晰易懂，大大提升了业务透明度和效率。 用友与外部系统接口集成开发

使用轻易云数据集成平台将源数据转换为金蝶云星辰V2API接口格式

在轻易云数据集成平台中，数据集成的第二步是将已经集成的源平台数据进行ETL（提取、转换、加载）处理，转化为目标平台所能接收的格式，并最终写入目标平台。本文将深入探讨如何将旺店通店铺的数据通过ETL转换为金蝶云星辰V2API接口所需的格式，并成功写入目标平台。

元数据配置解析

在进行ETL转换之前，首先需要理解和配置元数据。以下是针对金蝶云星辰V2API接口的元数据配置：

{
  "api": "/jdy/v2/bd/customer",
  "effect": "EXECUTE",
  "method": "POST",
  "number": "1",
  "id": "1",
  "name": "1",
  "idCheck": true,
  "request": [
    {
      "field": "name",
      "label": "名称",
      "type": "string",
      "describe": "客户名称",
      "value": "店铺-{shop_name}"
    },
    {
      "field": "number",
      "label": "编码",
      "type": "string",
      "describe": "编码,不传递则由后台生成（不设置有编码规则和更新时必传）",
      "value": "{shop_no}"
    }
  ]
}

数据提取与清洗

在ETL过程中，首先需要从源系统（旺店通店铺）提取原始数据。假设我们从旺店通获取到以下JSON格式的数据：

{
  "shop_name": "旺店通旗舰店",
  "shop_no": "WD001"
}

数据转换

接下来，我们需要根据金蝶云星辰V2API接口的要求，将上述原始数据进行转换。根据元数据配置中的request字段，我们需要将shop_name和shop_no分别映射到目标系统中的name和number字段。

具体转换过程如下：

  1. 字段映射：

    • name: 映射自shop_name，并添加前缀“店铺-”。
    • number: 映射自shop_no。

  2. 生成目标格式：

    • 根据元数据配置，将原始数据中的字段值替换到目标格式中。

转换后的JSON请求体应如下所示：

{
  "name": "店铺-旺店通旗舰店",
  "number": "WD001"
}

数据写入

完成数据转换后，需要将其通过HTTP POST方法写入到金蝶云星辰V2API接口中。根据元数据配置中的信息，HTTP请求的具体细节如下：

  • API路径： /jdy/v2/bd/customer
  • HTTP方法： POST
  • 请求体： 上述生成的JSON对象

示例代码（使用Python和requests库）如下：

import requests
import json

# 定义目标API URL
url = 'https://api.kingdee.com/jdy/v2/bd/customer'

# 定义请求头
headers = {
    'Content-Type': 'application/json',
    'Authorization': 'Bearer YOUR_ACCESS_TOKEN'
}

# 定义请求体
payload = {
    'name': '店铺-旺店通旗舰店',
    'number': 'WD001'
}

# 发起POST请求
response = requests.post(url, headers=headers, data=json.dumps(payload))

# 检查响应状态码
if response.status_code == 200:
    print('Data successfully written to Kingdee Cloud.')
else:
    print(f'Failed to write data: {response.status_code}, {response.text}')

上述代码展示了如何通过HTTP POST方法将转换后的数据写入到金蝶云星辰V2API接口中。在实际应用中，需要确保正确配置访问令牌（Authorization header），以便获得相应的权限。

总结

通过以上步骤，我们详细讲解了如何使用轻易云数据集成平台，将源系统（旺店通）的数据经过ETL处理后，成功转换为金蝶云星辰V2API接口所需的格式，并最终写入目标系统。这一过程不仅提高了业务流程的自动化程度，还确保了不同系统之间的数据无缝对接和高效传输。 金蝶云星空API接口配置

版权声明

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

数据集成平台运行原理
更多系统对接方案