企业AI知识库

轻易云AI知识库是一个为企业量身打造的智能解决方案,它能够进行机器人角色设定、知识库训练、发布/分享机器人,同时还带有AI智能对话功能,可以设定多种AI行业场景。适用于企业智能客服、企业智能文档、专家顾问助理等多种企业级商业场景,具有较大的商业使用价值。

了解更多,请访问轻企AI知识库官网

AI智能体

AI智能体是轻易云知识库的核心组成部分,它通过录入文档或问答来创建知识库,让机器人学习。根据机器人训练情况,企业可以实时删除或替换文档,以保持知识库的更新和准确性。AI智能体支持多种角色设定,如客服、销售、培训师、营销人员、行业专家等,以满足不同业务需求。

了解更多,请访问轻易云知识库体验中心

轻易云数据集成平台的目标平台调度者生命周期

轻易云数据集成平台的目标平台调度者生命周期

轻易云为企业提供了一体化的数据处理流程,包括数据抽取、清洗、转换和转发。本文将详细解析“数据转换和写入”阶段的关键组件——目标平台调度者的生命周期和操作流程,以便于工程师更好地理解和实施数据集成方案。

数据转换和写入是数据集成的核心步骤,通常通过源平台的定时调度请求任务来实现。该过程包括以下步骤:

  1. 定时任务调度

    • 调度者分配与配置:轻易云预设了20个调度者,通过Linux crontab实现每分钟的调度命令执行。用户可在配置页面指定“调度号”以分配特定调度者,优化性能,防止任务阻塞。
    • 调度命令执行:每个调度者执行命令,根据“调度号”启动相应的集成方案。
  2. 集成方案遍历与调度命令生成

    • 异步方案识别:遍历集成方案时,首先排除非异步方案。
    • 调度命令创建:对于需要调度的方案,创建一个或多个调度命令,这些命令将根据crontab延迟执行。
  3. 调度命令执行与队列管理

    • 调度命令激活:到达指定时间点后,激活调度命令,放入AsynDispatcher队列池中排队。
    • 队列池任务消费:AsynDispatcher队列池处理排队的任务,包括确认任务启动条件、检查调度条件,以及执行调度工作。
  4. 适配器加载与任务调度

    • 适配器加载:调度过程中首先加载源平台适配器。
    • 任务调度执行&获取数据管理中数据:适配器初始化后,执行调度任务,包括插入调度日志、生成写入任务请求参数,获取数据后将数据标记为“队列中”状态,将新任务参数写入任务存储,将任务ID插入源任务队列池进行排队,最后插入调度结束日志。
  5. 异步队列池任务消费
    异步队列池的任务消费是数据写入阶段的关键。以下是任务验证至执行的流程:

    • 任务验证与条件检查:确认任务状态,检查调度条件,如有前置任务在执行则确保调度顺序和依赖性。满足调度条件后,系统调用方法执行调度工作。
    • 适配器操作与任务执行:加载并初始化源平台适配器,执行调度方法,生成写入任务请求参数,获取数据后标记为“队列中”状态,将请求参数写入异步源任务存储,将任务ID插入源任务队列池。
  6. 数据写入
    适配器完成任务调度后,接下来是实际的数据写入:

    • 数据写入任务的执行:根据任务ID获取任务详细信息,适配器连接目标平台,成功后执行数据请求操作。
    • 数据处理结果响应:适配器处理目标平台的响应数据,包括检查响应状态,处理成功或失败的响应,对成功响应的数据进行进一步处理。处理响应数据后,可能会触发回调配置,执行响应动作。
  7. 任务状态管理与日志记录
    任务执行过程中,状态管理和日志记录是核心环节:

    • 任务状态更新:任务完成后标记为“已完成”,确保任务结果正确跟踪。数据处理完成且目标平台响应正确后,数据状态更新为“已完成”,防止数据重复发送。任务执行失败时,进行错误处理,包括数据状态标记为“错误的”,异常记录,并判断是否需要重新排队。

    • 日志记录:系统记录从调度开始到结束的详细日志,包括任务开始、结束时间和状态变更。适配器操作日志也被记录,便于诊断问题和优化性能。

  8. 目标平台事件关联与触发
    轻易云支持通过执行条件判断和事件关联配置,实现集成方案间的相互触发:

    • 事件关联配置:执行调度前需检查是否有等待或队列中的数据,若有则当前方案暂不调度。成功执行的集成方案可触发其他方案的调度,通过源平台事件关联配置实现。

    • 后续方案调度触发:方案成功完成后,根据事件关联配置检查是否触发其他集成方案的调度,保证数据集成流程的连续性和自动化。

  9. 异步队列池中任务的执行过程

    • 任务获取与验证:系统通过任务ID获取任务详情,包括执行所需参数。检查任务状态,如标记为错误或已完成则不再执行并从队列移除。
    • 适配器连接与任务执行:确认任务有效后,检测与源平台的连接。连接成功后,调用适配器的invoke()方法,向目标平台发送请求并获取响应。
    • 响应处理与数据加工:接收到源平台响应后,根据响应状态处理。成功的响应进入数据加工阶段,失败的响应触发错误处理流程。成功的响应可能触发脚本加工厂的调度方法,执行数据加工。
    • 错误处理与任务重排:适配器执行过程中的错误,调用handleError方法处理。包括异常记录和判断是否需要重新排队。任务执行失败可能由临时问题造成,如网络不稳定,系统可能将任务重新放入队列稍后重试。
    • 成功响应的后续处理:成功的响应,适配器处理响应数据,可能包括数据解析、格式化等,确保数据能被后续流程正确处理。处理完响应数据后,系统将数据存入数据存储,并更新任务状态。
    • 任务完成后的事件触发:任务成功完成并处理响应数据后,系统可能再次调用脚本加工厂的事件,执行特定的后处理脚本,进一步加工或验证数据。

热门文章

利用轻易云平台高效整合金蝶云数据的实战经验

2023-01-07 18:18:44

轻易云平台中金蝶K3-WISE物料数据的提取与清洗

2023-09-05 01:33:04

轻易云助力企业实现小满OKKICRM与用友U8的数据集成

2022-08-03 04:16:38

调用金蝶云星空接口获取出库单数据的最佳实践

2024-01-09 18:40:28

调取聚水潭API接口获取出库单数据的方法

2024-02-15 22:47:53

从管易云获取发货单数据并无缝对接至金蝶云星空

2023-10-02 18:17:41

调用智邦ERP接口实现客户数据加工与同步

2022-02-07 16:31:54

轻易云与钉钉数据集成的最佳实践:从API配置到数据写入

2024-05-27 19:09:54

金蝶云与轻易云数据集成:从查询到数据写入的详细步骤

2023-03-08 17:48:31

利用API与轻易云进行聚水潭数据实时集成

2021-06-16 17:47:18

如何高效集成旺店通和金蝶云星空的销售出库单

2024-10-19 00:16:11

轻易云平台助力电商系统数据无缝对接金蝶云星空

2024-12-01 10:16:35

技术深度解析:通过API集成吉客云数据至MySQL

2024-12-10 19:25:49

采购入库单数据集成:从金蝶云星空到旺店通的最佳实践

2024-11-15 12:23:52

利用04-ToB方案提升企业销售出库数据集成效率

2024-11-13 23:16:29

钉钉报销与金蝶云星空对接方案:技术解读

2024-11-23 01:54:00

轻易云平台整合金蝶云星辰与旺店通,实现自动化盘点单

2024-10-29 11:26:11

使用轻易云平台实现旺店通销售退货数据接入金蝶云

2024-11-07 11:25:46

物料数据集成:从金蝶云星空到钉钉的高效实现

2024-12-20 11:26:56

高效数据写入:金蝶云星空与MySQL的对接详解

2025-01-29 11:26:52

接口配置打通旺店通WMS和金蝶云星空数据对接

2023-01-26 10:05:18

旺店通·企业奇门与金蝶云星空对接集成供应商查询连通创建供应商(KWQ供应商同步)

2023-01-26 10:05:17

道一云·七巧、金蝶云星空通过接口配置数据对接

2023-01-26 10:05:16

用友BIP与旺店通·企业奇门对接集成查询销售出库单连通销售订单单个保存(销售出库单对接销售订单(线下)-v)

2023-01-26 10:05:15

四化智造MES(WEB)与金蝶云星空对接集成原材料/标准件采购查询(待采购)打通采购订单新增

2023-01-26 10:05:14