案例分享：金蝶云星空数据集成到MySQL

在实际项目中，如何高效地将金蝶云星空的数据集成到MySQL数据库是一个常见的技术挑战。本文通过具体案例“cgrk-2金蝶采购入库查询-->mysql”，深入探讨这一过程中的关键技术要点和注意事项。

背景

本次集成任务主要涉及以下两个API：

1. 从金蝶云星空获取数据的API: executeBillQuery
2. 向MySQL写入数据的API: execute

为了保证大规模数据处理的时效性，我们需要支持高吞吐量的数据写入能力，同时还必须确保整个过程中不会漏单。此外，定时可靠抓取、分页与限流问题、以及异常处理与错误重试机制，也是我们需重点考虑的问题。

实现方式概述

1. 实时监控与日志记录

   集成任务过程中，我们借助实时监控系统和日志记录功能，对每一次API调用进行追踪，从而确保任何潜在问题都能被及时发现并解决。

2. 批量数据处理

   为了提升效率，本方案采用批量处理模式，每次从executeBillQuery API 获取一定数量的数据，然后通过转换逻辑，将其符合MySQL表结构后，再调用execute接口批量插入到数据库中。

3. 分页与限流管理

   由于金蝶云星空接口存在分页和限流限制，特别设置了一套智能分页策略。在抓取每个批次数据前，通过解析返回头信息确定下一页起始位置及可用请求额度，从而实现无缝对接。

4. 自定义转换逻辑

   数据源格式往往不完全吻合业务需求。因此，在实施过程中，根据具体业务规则，自定义一套适用于当前场景的数据映射逻辑，以此桥接两者间可能存在的差异。例如，对于时间戳字段格式不同的问题，进行自动转换以满足目标数据库要求。

5. 异常处理机制

   当执行某一操作失败时，例如网络超时或接口返回异常状态码，会触发预设的错误重试机制，并记录详细故障信息。多次尝试仍无法完成操作，则会启动告警系统，将相关情况快速反馈给运维团队，以便及时介入排查解决。

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

在数据集成的生命周期中，调用源系统接口是至关重要的一步。本文将详细探讨如何使用轻易云数据集成平台调用金蝶云星空的executeBillQuery接口，以获取并加工采购入库数据，并将其写入MySQL数据库。

接口调用配置

首先，我们需要配置调用金蝶云星空接口的元数据。根据提供的元数据配置，以下是关键参数和字段的详细说明：

• API: executeBillQuery
• 请求方法: POST
• 主要字段:
  • FInStockEntry_FEntryId: 入库单分录ID
  • FBillNo: 单据编号
  • FDocumentStatus: 单据状态
  • FDate: 单据日期
  • FRealQty: 实际数量
  • FAmount: 金额

此外，还有一些其他请求参数用于分页和过滤，例如Limit、StartRow、TopRowCount、FilterString和FieldKeys。

请求参数设置

在实际操作中，我们需要构建一个请求体来调用金蝶云星空的接口。以下是一个示例请求体：

{
  "FormId": "STK_InStock",
  "FieldKeys": "FBillNo,FDate,FDocumentStatus,FRealQty,FAmount,FInStockEntry_FEntryId",
  "FilterString": "FDate>='{{LAST_SYNC_TIME|date}}' and FBillNo NOT LIKE '%CGRK%' or FApproveDate>='{{LAST_SYNC_TIME|date}}' and FBillNo NOT LIKE '%CGRK%'",
  "Limit": "2000",
  "StartRow": "{PAGINATION_START_ROW}"
}

在这个请求体中，FormId指定了要查询的表单ID为采购入库单（STK_InStock），而FieldKeys列出了我们感兴趣的字段。通过设置合适的过滤条件和分页参数，我们可以高效地获取所需的数据。

数据清洗与格式化

获取到数据后，需要对其进行清洗和格式化处理。例如，将日期字段从原始格式转换为新的格式。在元数据配置中，已经定义了一个格式化规则：

"formatResponse": [
  {
    "old": "FDate",
    "new": "FDate_new",
    "format": "date"
  }
]

根据这个规则，我们将原始的日期字段FDate转换为新的字段FDate_new，并确保其格式符合要求。

数据校验与转换

在数据写入目标系统之前，还需要进行一系列的数据校验和转换操作。例如，确保每条记录都有唯一的分录ID（FInStockEntry_FEntryId），并检查单据编号（FBillNo）是否符合预期格式。如果某些记录不满足这些条件，可以选择忽略或记录错误日志以便后续处理。

数据写入MySQL

最后一步是将清洗和转换后的数据写入MySQL数据库。这一步通常涉及到构建SQL插入语句，并通过数据库连接执行这些语句。例如：

INSERT INTO cgrk_table (FBillNo, FDate_new, FDocumentStatus, FRealQty, FAmount, FInStockEntry_FEntryId)
VALUES (?, ?, ?, ?, ?, ?)

通过这种方式，我们可以确保从金蝶云星空获取的数据被正确地存储在目标数据库中，以供后续分析和使用。

总结

本文详细介绍了如何使用轻易云数据集成平台调用金蝶云星空接口获取采购入库数据，并对其进行清洗、格式化、校验和写入MySQL数据库的全过程。通过合理配置元数据和请求参数，可以高效地实现不同系统间的数据无缝对接，从而提升业务透明度和效率。

利用轻易云数据集成平台进行ETL转换并写入MySQLAPI接口

在数据集成的生命周期中，第二步是将已经集成的源平台数据进行ETL（Extract, Transform, Load）转换，并最终写入目标平台。在本案例中，我们将演示如何将金蝶采购入库查询的数据转换为MySQLAPI接口所能够接收的格式，并写入目标平台。

数据请求与清洗

首先，我们从源系统（金蝶采购入库查询）获取原始数据。假设我们已经完成了数据请求与清洗的步骤，接下来我们需要对这些数据进行ETL处理。

数据转换与写入

为了将数据写入MySQLAPI接口，我们需要配置元数据。以下是具体的元数据配置：

{
  "api": "execute",
  "effect": "EXECUTE",
  "method": "POST",
  "idCheck": true,
  "request": [
    {
      "field": "main_params",
      "label": "main_params",
      "type": "object",
      "describe": "111",
      "children": [
        {"field": "FInStockEntry_FEntryId", "label": "明细id", "type": "string", "value": "{FInStockEntry_FEntryId}"},
        {"field": "order_no_new", "label": "单号", "type": "string", "value": "{FBillNo}"},
        {"field": "FDocumentStatus", "label": "状态", "type": "string", "value": "{FDocumentStatus}"},
        {"field": "qty_count", "label": "数量", "type": "string", "value": "{FRealQty}"},
        {"field": "sales_count", ", label":"金额","type":"string","value":"{FAmount}"},
        {"field":"datetime_new","label":"时间","type":"date","value":"{FDate_new}"},
        {"field":"Document_Type","label":"单据类型","type":"string","value":"采购入库"}
      ]
    }
  ],
  ``otherRequest``: [
    {
      ``field``: ``main_sql``,
      ``label``: ``main_sql``,
      ``type``: ``string``,
      ``describe``: ``111``,
      ``value``: ``INSERT INTO `kd_cgrk`(`FInStockEntry_FEntryId`,`order_no_new`,`FDocumentStatus`,`qty_count`,`sales_count`,`datetime_new`,`Document_Type`) VALUES (:FInStockEntry_FEntryId,:order_no_new,:FDocumentStatus,:qty_count,:sales_count,:datetime_new,:Document_Type)``
    }
  ]
}

在这个配置中，我们定义了一个POST请求，用于执行插入操作。请求体包含一个名为main_params的对象，该对象包含多个字段，每个字段对应源系统中的一个数据项。这些字段包括：

• FInStockEntry_FEntryId: 明细ID，对应源系统中的FInStockEntry_FEntryId
• order_no_new: 单号，对应源系统中的FBillNo
• FDocumentStatus: 状态，对应源系统中的FDocumentStatus
• qty_count: 数量，对应源系统中的FRealQty
• sales_count: 金额，对应源系统中的FAmount
• datetime_new: 时间，对应源系统中的FDate_new
• Document_Type: 单据类型，固定值为“采购入库”

此外，在otherRequest部分，我们定义了一个SQL插入语句，用于将上述字段插入到目标数据库表中。该SQL语句如下：

INSERT INTO kd_cgrk (FInStockEntry_FEntryId, order_no_new, FDocumentStatus, qty_count, sales_count, datetime_new, Document_Type) 
VALUES (:FInStockEntry_FEntryId, :order_no_new, :FDocumentStatus, :qty_count, :sales_count, :datetime_new, :Document_Type)

执行ETL转换

在轻易云数据集成平台上配置好上述元数据后，系统会自动执行以下步骤：

1. 提取（Extract）：从金蝶采购入库查询中提取原始数据。
2. 转换（Transform）：根据元数据配置，将提取的数据转换为目标格式。例如，将原始字段名映射到目标字段名，并进行必要的数据类型转换。
3. 加载（Load）：通过POST请求，将转换后的数据插入到MySQL数据库中。

技术要点

1. 异构系统支持：轻易云平台支持多种异构系统的数据集成，通过灵活的元数据配置，可以轻松实现不同系统之间的数据无缝对接。
2. 全透明可视化操作：通过可视化界面，用户可以清晰地看到每个环节的数据流动和处理状态，极大提升了业务透明度和效率。
3. 实时监控与错误处理：平台提供实时监控功能，可以及时发现并处理数据处理过程中的错误，确保数据准确性和完整性。

通过上述步骤，我们成功地将金蝶采购入库查询的数据转换并写入到MySQLAPI接口，实现了不同系统之间的数据无缝对接。这不仅提高了业务效率，也确保了数据的一致性和准确性。