使用轻易云平台实现ETL转换写入钉钉API

  • 轻易云集成顾问-张妍琪

金蝶云星空数据集成到钉钉的技术方案分享

在数据驱动的业务环境中，系统间的数据集成和对接是提升企业运营效率的重要环节。本篇文章将剖析如何通过金蝶云星空与钉钉API实现高效的数据集成，并以一个实际运行的方案——basic-（新环境）KY组织机构（V4.0）为例，详细探讨其技术要点和操作步骤。

数据获取与处理逻辑

金蝶云星空提供了强大的API接口，例如executeBillQuery，用于从系统中抓取所需数据。使用这个接口，我们可以定时、可靠地获取最新的组织机构信息。这些信息经过必要的数据转换后，将被快速写入到钉钉平台，以确保协同办公中的通讯录及时更新。据此，我们设计了一套自动化脚本，通过调用金蝶云星空接口周期性抓取数据，并进行适配转换以符合钉钉平台的数据要求。

高效数据写入能力

为了应对大量数据同步需求，此次方案采用了支持高吞吐量特性的机制，使得大量组织结构信息能够迅速、准确地被输入到目标系统中。特别是义务识别批量操作场景下，不仅保证了数据信息的完整性，还缩短了处理时间，提高了整个过程的效率。

实时监控与异常处理机制

数据集成过程中，实时监控和告警功能显得尤为重要。在轻易云的平台上，我们利用中央监控和告警系统来全方位跟踪每一次任务执行状态及性能。一旦发现异常情况，例如分页限流问题或格式不匹配导致的数据写入失败，可立即触发错误重试机制，有效减少人工干预。同时日志记录也保存着详尽的信息，为后续排查问题提供便利。

这只是基本框架介绍，更具体细节将在后续章节展开，包括怎样配置自定义转化逻辑，以满足特定业务需求，以及每一步骤代码示例等。 打通钉钉数据接口

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

在轻易云数据集成平台的生命周期中，调用源系统接口是数据请求与清洗阶段的关键步骤之一。本文将深入探讨如何通过调用金蝶云星空接口executeBillQuery来获取并加工数据，具体操作将基于以下元数据配置。

元数据配置解析

元数据配置是实现数据集成的核心，它定义了API调用的参数、请求方式以及需要处理的数据字段。以下是对提供的元数据配置的详细解析：

{
  "api": "executeBillQuery",
  "method": "POST",
  "number": "FNumber",
  "id": "FOrgID",
  "pagination": {
    "pageSize": 100
  },
  "idCheck": true,
  "request": [
    {"field": "FOrgID", "label": "FOrgID", "type": "string", "value": "FOrgID"},
    {"field": "FNumber", "label": "编码", "type": "string", "value": "FNumber"},
    {"field": "FName", "label": "名称", "type": "string", "value": "FName"},
    {"field": "FOrgFormID", "label": "形态", "type": "string", "value": "FOrgFormID"},
    {"field": "FIsAccountOrg", "label": "核算组织", "type": "string", 
"value":"FIsAccountOrg"},
    {"field":"FParentID","label":"所属法人","type":"string","value":"FParentID.FNumber"},
    {"field":"FAcctOrgType","label":"核算组织类型","type":"string","describe":"核算组织类型","value":"FAcctOrgType"}
  ],
  ...
}

API调用与参数设置

  1. API与请求方式：

    • api: executeBillQuery
    • method: POST

  2. 分页参数：

    • pagination.pageSize: 每次请求的数据条数，设置为100。

  3. 请求字段：

    • request数组中定义了需要从金蝶云星空获取的字段，包括FOrgID, FNumber, FName, FOrgFormID, FIsAccountOrg, FParentID.FNumber, 和FAcctOrgType。

  4. 其他请求参数：

    • otherRequest部分定义了分页、过滤条件等附加参数，如Limit, StartRow, 和FilterString等。

实际操作步骤

  1. 构建请求体： 根据元数据配置构建API请求体。确保所有必要字段和分页参数都已正确设置。
{
  ...
  // 示例请求体
  {
    FormId: 'ORG_Organizations',
    FieldKeys: 'FOrgID,FNumber,FName,FOrgFormID,FIsAccountOrg,FParentID.FNumber,FAcctOrgType',
    FilterString: '',
    Limit: '100',
    StartRow: '0'
  }
}
  1. 发送API请求： 使用HTTP POST方法发送构建好的请求体到金蝶云星空接口。
import requests

url = 'https://api.kingdee.com/executeBillQuery'
headers = {'Content-Type': 'application/json'}
data = {
    'FormId': 'ORG_Organizations',
    'FieldKeys': 'FOrgID,FNumber,FName,FOrgFormID,FIsAccountOrg,FParentID.FNumber,FAcctOrgType',
    'FilterString': '',
    'Limit': '100',
    'StartRow': '0'
}

response = requests.post(url, headers=headers, json=data)
result = response.json()
  1. 处理返回结果： 对返回的数据进行清洗和转换，以便后续写入目标系统。根据业务需求，可以对特定字段进行格式化或过滤。
def process_data(data):
    processed_data = []
    for item in data:
        processed_item = {
            '组织机构ID': item['FOrgID'],
            '编码': item['FNumber'],
            '名称': item['FName'],
            '形态': item['FOrgFormID'],
            '核算组织': item['FIsAccountOrg'],
            '所属法人编码': item['FParentID.FNumber'],
            '核算组织类型': item['FAcctOrgType']
        }
        processed_data.append(processed_item)

    return processed_data

cleaned_data = process_data(result)

注意事项

  • 分页处理：由于每次请求只能获取有限条数的数据，需要通过循环和更新StartRow参数来实现全量数据的获取。
  • 错误处理：在实际操作中，需要对API调用过程中的各种可能错误进行处理，如网络异常、接口返回错误信息等。
  • 性能优化：对于大规模数据集成任务，可以考虑异步处理和批量操作，以提高效率。

通过上述步骤，我们可以高效地从金蝶云星空系统中获取所需的数据，并进行必要的清洗和转换，为后续的数据写入做好准备。这一过程充分体现了轻易云数据集成平台在异构系统间无缝对接和全生命周期管理方面的强大能力。 如何对接用友BIP接口

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

在数据集成过程中，ETL（Extract, Transform, Load）转换是关键的一步。本文将详细探讨如何使用轻易云数据集成平台将源平台的数据进行ETL转换，并最终写入目标平台钉钉API接口。

数据请求与清洗

首先，我们需要从源平台提取数据并进行清洗。假设我们已经完成了这一步，并且得到了如下格式的源数据：

{
  "FName": "研发部",
  "FNumber": "RD001"
}

数据转换与写入

接下来，我们需要将上述源数据转换为钉钉API接口所能接收的格式，并通过POST请求将其写入目标平台。根据提供的元数据配置，具体步骤如下：

  1. 定义API接口和请求方法：

    • API接口：v1.0/yida/forms/instances
    • 请求方法：POST

  2. 配置请求参数： 根据元数据配置，我们需要设置以下字段：

    {
 "textField_lgg53q3l": "{FName}",
 "textField_lgg53q3n": "{FNumber}",
 "textField_lgg53q3j": "组织机构",
 "textField_lhbf2v06": "ORG_Organizations"
}

    将源数据中的FName和FNumber分别映射到目标字段textField_lgg53q3l和textField_lgg53q3n，并设置固定值字段。

  3. 配置其他请求参数： 除了主要的请求参数，还需要配置其他必要的参数，如应用编码、应用秘钥、用户ID等。这些参数通常是固定值或从环境变量中获取：

    {
 "appType": "APP_WTSCMZ1WOOHGIM5N28BQ",
 "systemToken": "IS866HB1DXJ8ODN3EXSVD750RBTK2X72R8MELL4",
 "userId": "16000443318138909",
 "language": "zh_CN",
 "formUuid": "FORM-6W9667D1OWS9850AFKPOR7CO1IXA3ZB515GGL11"
}

  4. 构建最终请求体： 将上述所有参数整合成一个完整的JSON对象，作为POST请求的请求体：

    {
 "textField_lgg53q3l": "研发部",
 "textField_lgg53q3n": "RD001",
 "textField_lgg53q3j": "组织机构",
 "textField_lhbf2v06": "ORG_Organizations",
 "appType": "APP_WTSCMZ1WOOHGIM5N28BQ",
 "systemToken": "IS866HB1DXJ8ODN3EXSVD750RBTK2X72R8MELL4",
 "userId": "16000443318138909",
 "language": "zh_CN",
 "formUuid": "FORM-6W9667D1OWS9850AFKPOR7CO1IXA3ZB515GGL11"
}

  5. 发送POST请求： 使用HTTP客户端（如curl或Postman）发送POST请求，将上述JSON对象作为请求体发送到钉钉API接口：

    curl -X POST \
    -H 'Content-Type: application/json' \
    -d '{
          ...
        }' \
    https://api.dingtalk.com/v1.0/yida/forms/instances

通过以上步骤，我们成功地将源平台的数据进行了ETL转换，并通过轻易云数据集成平台写入到了钉钉API接口。这一过程不仅确保了数据格式的正确性，还保证了数据在不同系统间的无缝对接。

技术要点总结

  • 元数据配置：明确字段映射关系和固定值字段。
  • 其他请求参数：确保所有必要的认证和环境参数正确配置。
  • HTTP请求构建：准确构建JSON对象并发送HTTP POST请求。

通过这些技术要点，可以高效地实现不同系统间的数据集成，提升业务流程的自动化程度。 钉钉与WMS系统接口开发配置

版权声明

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

金蝶云星辰与聚水潭对接
更多系统对接方案