详解轻易云平台上金蝶云星空API接口数据集成过程

  • 轻易云集成顾问-何语琴

使用轻易云数据集成平台实现金蝶云星空数据对接的技术案例分享

在现代企业信息化进程中，数据的无缝集成与高效处理是提升业务效率和决策准确度的重要环节。本篇技术文章将详细解析如何利用轻易云数据集成平台，将金蝶云星空的数据进行有效对接。本文聚焦于实际案例“Done-金蝶-其他出库单——>空操作”的执行过程，探讨从调用金蝶云星空接口、处理海量数据流动，到确保持续可靠的数据同步等关键环节。

为了成功完成金蝶云星空与轻易云平台的数据集成，我们首先需要通过executeBillQuery接口定时抓取所需的出库单信息。这一步骤不仅需要考虑到API限流和分页问题，还必须保证每一个请求的快速响应，并避免因网络波动或服务异常导致的数据丢失。因此，实现一个稳定、高效且具有错误重试机制的数据抓取方案显得尤为重要。

当我们获取到必要的出库单数据后，需要解决两个主要问题：一是如何将大量原始业务数据批量写入到轻易云平台；二是处理两者之间可能存在的数据格式差异。对于前者，我们优化了传输协议和并发机制，以保证大规模、多类型数据能够迅速且准确地写入目标系统。而对于后者，通过定义定制化的数据映射规则，确保各字段与属性在转换过程中精准对接。

此外，在整个系统对接过程中，我们设计了实时监控与日志记录功能，以便随时观测各类操作状态，从而及时发现并修正潜在问题。同时，为应对不同场景下可能出现的不确定性，我们还引入了详细的异常处理策略，包括自动重试机制，以最大程度减少人工干预需求，提高整体效率和可靠性。

下面我们将深入探讨这一实际方案中的具体技术细节及其实施步骤，希望能为读者提供有价值的参考。 打通钉钉数据接口

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

在数据集成的生命周期中，调用源系统接口是至关重要的一步。本文将深入探讨如何使用轻易云数据集成平台，通过调用金蝶云星空的executeBillQuery接口来获取并加工数据。

接口配置与调用

首先，我们需要了解元数据配置中的各个字段及其作用。以下是关键字段的解释：

  • api: 接口名称，这里为executeBillQuery。
  • effect: 操作类型，表示这是一个查询操作（QUERY）。
  • method: 请求方法，这里使用的是POST。
  • number和id: 用于标识数据实体的字段，这里均为FEntity_FEntryID。
  • name: 数据实体的名称字段，这里为FBillNo。
  • idCheck: 是否进行ID检查，设置为true。

请求参数配置

请求参数分为两部分：常规请求参数和其他请求参数。

  1. 常规请求参数:

    • FEntity_FEntryID: 分录ID
    • FID: 实体主键
    • FMATERIALID_FNumber: 物料编码
    • F_TLQG_TextDDLSH: 钉钉流水单号

  2. 其他请求参数:

    • Limit: 最大行数，用于分页
    • StartRow: 开始行索引，用于分页
    • TopRowCount: 返回总行数
    • FilterString: 过滤条件，例如：FApproveDate>='{{LAST_SYNC_TIME|dateTime}}' and FStockDirect='GENERAL' and FPickOrgId.FNUMBER='101'
    • FieldKeys: 需查询的字段key集合，例如：FPOOrderEntry_FEntryId,FPurchaseOrgId.FNumber
    • FormId: 业务对象表单Id，这里为STK_MisDelivery

示例代码

以下是一个示例代码片段，展示如何通过轻易云平台调用金蝶云星空接口：

{
  "api": "executeBillQuery",
  "effect": "QUERY",
  "method": "POST",
  "number": "FEntity_FEntryID",
  "id": "FEntity_FEntryID",
  "name": "FBillNo",
  "idCheck": true,
  "request": [
    {"field":"FEntity_FEntryID","label":"FEntryID","type":"string","describe":"FEntryID","value":"FEntity_FEntryID"},
    {"field":"FID","label":"实体主键","type":"string","describe":"实体主键","value":"FID"},
    {"field":"FMATERIALID_FNumber","label":"物料编码","type":"string","describe":"物料编码","value":"FMATERIALID.FNumber"},
    {"field":"F_TLQG_TextDDLSH","label":"钉钉流水单号","type":"string","value":"F_TLQG_TextDDLSH"}
  ],
  "otherRequest": [
    {"field":"Limit","label":"最大行数","type":"string","describe":"金蝶的查询分页参数","value":"{PAGINATION_PAGE_SIZE}"},
    {"field":"StartRow","label":"开始行索引","type":"string","describe":"金蝶的查询分页参数","value":"{PAGINATION_START_ROW}"},
    {"field":"TopRowCount","label":"返回总行数","type":"int","describe":"金蝶的查询分页参数"},
    {"field":"FilterString","label":"过滤条件","type":"string","describe":"示例写法 FSupplierId.FNumber = 'VEN00010' and FApproveDate>=","value":
      "FApproveDate>='{{LAST_SYNC_TIME|dateTime}}' and FStockDirect='GENERAL' and FPickOrgId.FNUMBER='101'"},
    {"field":"FieldKeys","label":"需查询的字段key集合","type":"array", 
      "describe": "金蝶分录主键ID格式：FPOOrderEntry_FEntryId,其它格式 FPurchaseOrgId.FNumber", 
      "parser":{"name": "ArrayToString", "params": ","}},
    {"field": "FormId", 
      "label": "业务对象表单Id", 
      "type": "string", 
      "describe": "必须填写金蝶的表单ID如:PUR_PurchaseOrder", 
      "value": "STK_MisDelivery"}
  ],
  "autoFillResponse": true
}

数据清洗与转换

在获取到数据后，需要对其进行清洗和转换，以便后续处理。以下是一些常见的数据清洗和转换操作：

  1. 去除无效数据: 根据业务规则过滤掉不需要的数据。
  2. 格式转换: 将日期、数字等字段转换为标准格式。
  3. 字段映射: 将源系统中的字段映射到目标系统中的相应字段。

例如，可以使用以下代码进行简单的数据清洗和转换：

def clean_and_transform(data):
    cleaned_data = []
    for record in data:
        if record['status'] == 'VALID':
            transformed_record = {
                'entry_id': record['FEntity_FEntryID'],
                'material_code': record['FMATERIALID_FNumber'],
                'bill_no': record['FBillNo'],
                'timestamp': convert_to_standard_date(record['approve_date'])
            }
            cleaned_data.append(transformed_record)
    return cleaned_data

def convert_to_standard_date(date_str):
    # 假设日期格式为 YYYY-MM-DD HH:MM:SS
    return datetime.strptime(date_str, '%Y-%m-%d %H:%M:%S').isoformat()

通过以上步骤，我们可以高效地从金蝶云星空获取并加工所需的数据，为后续的数据处理和分析奠定基础。 打通企业微信数据接口

数据转换与写入：实现轻易云集成平台API接口的数据接收

在数据集成的生命周期中，数据转换与写入是关键的一步。本文将详细探讨如何将已经集成的源平台数据进行ETL转换，并转为目标平台轻易云集成平台API接口所能够接收的格式，最终写入目标平台。

API接口配置

在进行数据写入之前，我们首先需要了解目标平台API接口的配置。根据提供的元数据配置，目标平台API接口如下：

{
  "api": "写入空操作",
  "effect": "EXECUTE",
  "method": "POST",
  "idCheck": true
}

从上述配置可以看出，该API接口使用POST方法进行数据传输，并且需要进行ID校验。下面我们将详细讨论如何利用这些信息进行数据转换和写入。

数据转换过程

  1. 数据请求与清洗：首先，我们从源平台（金蝶）获取出库单数据。这一步通常包括通过API调用或数据库查询获取原始数据，并对其进行必要的清洗和预处理，例如去除冗余字段、标准化日期格式等。

  2. 数据映射：接下来，我们需要将清洗后的数据映射到目标平台所需的数据结构。这一步至关重要，因为不同系统之间的数据格式和字段名称可能有所不同。例如，金蝶出库单中的字段名称可能与轻易云集成平台API所要求的不一致，需要通过映射表进行转换。

    {
 "sourceField1": "targetFieldA",
 "sourceField2": "targetFieldB",
 ...
}

  3. ID校验：根据元数据配置，目标平台API接口要求进行ID校验。我们需要确保每条记录在发送之前都包含有效的ID。如果源平台的数据没有直接提供ID，可以通过自定义规则生成或从其他系统获取。

  4. 构建请求体：完成上述步骤后，我们可以构建最终的请求体，以符合目标平台API接口的要求。以下是一个示例请求体：

    {
 "id": "12345",
 "fieldA": "value1",
 "fieldB": "value2",
 ...
}

数据写入过程

  1. 初始化HTTP客户端：使用编程语言（如Python）的HTTP客户端库（如requests）初始化HTTP客户端，以便与目标平台API进行通信。

    import requests

url = 'https://api.qingyiyun.com/writeEmptyOperation'
headers = {'Content-Type': 'application/json'}

  2. 发送POST请求：构建好请求体后，通过POST方法将其发送到目标平台API接口。

    response = requests.post(url, headers=headers, json=request_body)

if response.status_code == 200:
   print("Data written successfully")
else:
   print(f"Failed to write data: {response.status_code}, {response.text}")

  3. 错误处理与重试机制：为了确保数据可靠地写入，我们需要实现错误处理和重试机制。例如，如果由于网络问题导致请求失败，可以设置重试逻辑以再次尝试发送请求。

实际案例应用

假设我们有一个金蝶出库单，其原始数据如下：

{
  "orderId": "OD12345",
  "productCode": "P001",
  "quantity": 100,
  ...
}

经过清洗和映射后，转换为目标平台所需的数据格式：

{
  "id": "OD12345",
  "productCode": "P001",
  "quantity": 100,
  ...
}

然后，通过上述步骤将其发送到轻易云集成平台API接口，实现最终的数据写入。

总结

本文详细探讨了如何利用轻易云集成平台的API接口，将源平台（金蝶）的出库单数据经过ETL转换后，成功写入目标平台。通过理解和应用元数据配置，我们能够高效地完成这一过程，从而实现不同系统间的数据无缝对接。 企业微信与OA系统接口开发配置

版权声明

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

营销云系统与经销商ERP对接
更多系统对接方案