### 金蝶-币别——>轻易云-创建映射：系统对接集成案例分享
在本案例中，我们将深入探讨如何通过executeBillQuery API从金蝶云星空获取数据，并利用AddMappingData API将这些数据集成到轻易云平台。面对大量高吞吐量的数据处理需求，我们选择了定时抓取和批量写入的方案，确保数据能够快速、可靠地完成传输。
首先，通过调用金蝶云星空的接口executeBillQuery，可以高效查询到需要的数据。这一步至关重要，需要妥善处理分页和限流问题，以防止请求过多导致接口响应缓慢或失败。为了避免漏单现象发生，每次执行API请求均需记录上次查询的位置，从而实现精准续传。
然后，利用轻易云提供的可视化设计工具，对接收到的数据进行自定义转换。针对业务特定要求，将原始数据结构与目标格式进行映射。这里关键的一点是灵活运用AddMappingData API，使得每一笔数据都能无缝插入到指定位置，从而保障整个流程的准确性和效率。
在实际运行过程中，实时监控与告警系统发挥了不可替代的重要作用。该功能使我们能够及时捕获并处理任何异常情况，例如网络故障或接口错误等。此外，为了保证整体流程顺畅，我们还实施了一些重试机制，当某个环节出现异常时能够自动重新尝试，以尽可能减少人工干预带来的额外成本。
最后，通过统一控制台集中管理API资产，不仅提升了资源使用效率，而且为后续优化配置提供了更加清晰直观的决策依据。在整个项目实施期间，这种全局掌握能力促进了项目快速推进，实现最终目标：完美对接金蝶云星空与轻易云平台之间的数据流转。
下一步内容将详细阐述具体技术步骤，包括各API参数设置、转换逻辑实现及实战经验总结，希望给读者带来有价值的启发。
### 调用金蝶云星空接口executeBillQuery获取并加工数据
在数据集成生命周期的第一步，我们需要调用源系统金蝶云星空的接口`executeBillQuery`来获取并加工数据。本文将详细探讨如何配置和使用该接口，以实现高效的数据请求与清洗。
#### 接口基本信息
根据元数据配置，`executeBillQuery`接口的基本信息如下：
- **API名称**: `executeBillQuery`
- **作用**: 查询（QUERY）
- **请求方法**: POST
- **主要字段**:
- `FNumber`: 编号
- `FCUSTID`: 客户ID
- `FName`: 名称
#### 请求参数配置
在调用接口时，我们需要配置一系列请求参数。这些参数分为两类：必填字段和其他请求字段。
##### 必填字段
1. **FCODE (货币代码)**:
- 类型: string
- 示例值: `"FCODE"`
2. **FNumber (编号)**:
- 类型: string
- 示例值: `"FNumber"`
3. **FName (名称)**:
- 类型: string
- 示例值: `"FName"`
##### 其他请求字段
1. **Limit (最大行数)**:
- 类型: string
- 描述: 金蝶的查询分页参数
- 示例值: `{PAGINATION_PAGE_SIZE}`
2. **StartRow (开始行索引)**:
- 类型: string
- 描述: 金蝶的查询分页参数
- 示例值: `{PAGINATION_START_ROW}`
3. **TopRowCount (返回总行数)**:
- 类型: int
- 描述: 金蝶的查询分页参数
4. **FilterString (过滤条件)**:
- 类型: string
- 描述: 示例写法 `FSupplierId.FNumber = 'VEN00010' and FApproveDate>=`
- 示例值: `FCreateDate>='{{LAST_SYNC_TIME|datetime}}'`
5. **FieldKeys (需查询的字段key集合)**:
- 类型: array
- 描述: 金蝶分录主键ID格式：`FPOOrderEntry_FEntryId`, 其它格式 `FPurchaseOrgId.FNumber`
- 解析器：ArrayToString，使用逗号分隔各个字段
6. **FormId (业务对象表单Id)**:
- 类型: string
- 描述: 必须填写金蝶的表单ID如:`PUR_PurchaseOrder`
- 示例值: `"BD_Currency"`
#### 请求示例
以下是一个完整的请求示例，展示了如何配置上述参数以调用`executeBillQuery`接口：
```json
{
"api": "executeBillQuery",
"method": "POST",
"request": {
"FCODE": "USD",
"FNumber": "1001",
"FName": "美元"
},
"otherRequest": {
"Limit": "100",
"StartRow": "0",
"TopRowCount": 1,
"FilterString": "FCreateDate>='2023-01-01'",
"FieldKeys": ["FCODE", "FNumber", "FName"],
"FormId": "BD_Currency"
}
}
```
#### 数据清洗与转换
在获取到数据后，需要对数据进行清洗和转换，以确保其符合目标系统的要求。轻易云平台提供了自动填充响应（autoFillResponse）功能，可以简化这一过程。
例如，假设我们从金蝶云星空获取到以下响应数据：
```json
{
"Result": [
{
"FCODE": "USD",
"FNumber": "1001",
"FName": "美元"
}
]
}
```
我们可以通过轻易云平台自动将这些数据映射到目标系统所需的格式，例如：
```json
{
"currencyCode": "USD",
"currencyNumber": "1001",
"currencyName": "美元"
}
```
#### 小结
通过以上步骤，我们成功调用了金蝶云星空的`executeBillQuery`接口，并对返回的数据进行了清洗和转换。这一过程展示了如何利用轻易云平台高效地进行数据集成，为后续的数据处理和写入打下坚实基础。
### 数据集成生命周期第二步：ETL转换与写入目标平台
在数据集成生命周期的第二步，我们需要将已经集成的源平台数据进行ETL（Extract, Transform, Load）转换，转为目标平台API接口所能够接收的格式，并最终写入目标平台。本文将详细探讨如何利用轻易云数据集成平台进行这一过程，特别是针对金蝶-币别到轻易云-创建映射的具体案例。
#### 元数据配置解析
在这个案例中，我们的目标是通过轻易云的数据集成平台，将金蝶系统中的币别数据转换并写入到轻易云集成平台中。以下是我们使用的元数据配置：
```json
{
"api": "AddMappingData",
"effect": "EXECUTE",
"method": "POST",
"idCheck": true,
"request": [
{"field": "a_value", "label": "a_value", "type": "date", "value": "{FCODE}"},
{"field": "a_label", "label": "a_label", "type": "string", "value": "{FName}"},
{"field": "b_value", "label": "b_value", "type": "string", "value": "{FNumber}"},
{"field": "b_label", "label": "b_label", "type": "string", "value": "{FName}"},
{"field": "category", "label": "分类ID", "type": "string",
"value":"66e041492c264d45df0788c8"}
]
}
```
#### 数据提取与清洗
首先，我们从金蝶系统中提取币别相关的数据，这些数据包括字段`FCODE`、`FName`和`FNumber`。提取的数据可能需要进行清洗，以确保其符合目标平台的要求。例如，日期格式可能需要标准化，字符串可能需要去除空格或特殊字符等。
#### 数据转换
接下来，我们根据元数据配置对提取的数据进行转换。元数据配置中的每个字段都有明确的映射关系：
- `a_value`: 映射到金蝶系统中的`FCODE`字段，类型为日期。
- `a_label`: 映射到金蝶系统中的`FName`字段，类型为字符串。
- `b_value`: 映射到金蝶系统中的`FNumber`字段，类型为字符串。
- `b_label`: 再次映射到金蝶系统中的`FName`字段，类型为字符串。
- `category`: 固定值“66e041492c264d45df0788c8”，表示分类ID。
在转换过程中，我们需要确保每个字段都被正确地映射和转换。例如：
```python
transformed_data = {
'a_value': source_data['FCODE'],
'a_label': source_data['FName'],
'b_value': source_data['FNumber'],
'b_label': source_data['FName'],
'category': '66e041492c264d45df0788c8'
}
```
#### 数据写入
最后一步是将转换后的数据通过API接口写入到目标平台。根据元数据配置，我们使用的是POST方法，并且需要进行ID检查（idCheck: true）。以下是一个示例请求：
```python
import requests
url = 'https://api.qingyiyun.com/AddMappingData'
headers = {'Content-Type': 'application/json'}
response = requests.post(url, json=transformed_data, headers=headers)
if response.status_code == 200:
print("Data successfully written to the target platform.")
else:
print(f"Failed to write data: {response.text}")
```
在这个请求中，我们将转换后的数据作为JSON负载发送到指定的API端点。如果响应状态码为200，则表示数据成功写入；否则，需要根据响应信息进行错误排查。
#### 小结
通过上述步骤，我们实现了从金蝶系统到轻易云集成平台的数据ETL转换与写入。这一过程充分利用了元数据配置，实现了不同系统间的数据无缝对接。在实际操作中，需要根据具体需求调整和优化每个步骤，以确保数据的准确性和一致性。
