元の名称記録: 中国工商银行股份有限公司

本申请实施例提供一种任务处理方法、装置、设备、存储介质及程序产品，涉及分布式技术领域。该方法包括：获取正在执行的任务的执行状态信息。在所述执行状态信息满足预设条件的情况下，终止所述任务的执行。根据所述任务的任务特征数据、执行所述任务的目标集群的集群状态数据，拆分所述任务得到目标工作流。基于所述目标工作流重新调度所述目标集群的数据处理资源执行所述目标工作流。本申请的方法，提高了分布式处理的任务处理效率和智能化水平。

本申请提供了一种数据处理方法、装置、设备、介质和程序产品，可以应用于分布式技术领域和金融科技技术领域。该方法包括：确定与待执行任务对应的多个节点；对多个节点各自的数据版本标识进项校验，得到目标校验结果；在目标校验结果表示目标节点的数据版本标识不满足预设更新需求条件的情况下，获取用于表征目标待处理数据中多个目标切片数据的目标默克尔树拓扑、用于表征基准待处理数据中多个基准切片数据的基准默克尔树拓扑；根据基准默克尔树拓扑和目标默克尔树拓扑的对比结果，从多个目标切片数据中确定待更新切片数据；根据基准切片数据将目标待处理数据中的待更新切片数据进行数据同步，得到用于执行待执行任务的目标切片数据。

本申请提供一种大数据平台的任务调度方法、装置、设备、介质及产品，涉及大数据技术领域。该方法包括：获取大数据平台的资源利用率，以及待调度任务的优先级，从调度策略中被配置为可调整的多个预设调度参数中，确定至少一个目标调度参数，根据资源利用率和优先级，对调度策略中的至少一个目标调度参数进行调整，基于调整后的调度策略，调度大数据平台执行待调度任务，从而能够更为有效根据大数据平台的运行状况发生变化时，及时调整任务调度策略，满足处理大规模数据时的性能需求，提高任务执行效率。

本申请实施例本申请提供一种任务处理方法、装置、设备、存储介质及程序产品，涉及数据处理技术领域。该方法通过获取待处理批次的任务，并生成待处理批次的任务对应的批量任务文件，进而调度分布式任务处理集群在文件模式下，基于批量任务文件处理上述任务，并在存在处理失败的目标任务的情况下，调度分布式任务处理集群在流式模式下处理目标任务，实现了根据任务的执行结果，动态调控任务的处理模式的技术效果，并通过流式模式处理目标任务，避免了继续采用文件模式处理目标任务，从而降低任务处理效率的问题。

本申请提供一种任务执行方法、装置、设备、存储介质及程序产品，涉及分布式领域。该方法包括：对待处理数据执行数据处理任务时，检测数据处理任务的当前执行节点是否存在异常；在当前执行节点存在异常的情况下，在数据处理任务的多个历史执行节点中，确定最接近当前执行节点的目标执行节点；获取目标执行节点中待处理数据的历史处理状态；将待处理数据恢复至历史处理状态；从当前执行节点开始，对处于历史处理状态的待处理数据继续执行数据处理任务。本申请的方法，能够实现自动化故障恢复，避免了人工干预，从而显著缩短了分布式系统的恢复周期，最终显著提升了分布式系统可靠性和运维效率。

本申请提供了一种任务调度方法、装置、电子设备、介质和程序产品，可以应用于人工智能技术领域、分布式技术领域。所述方法包括：获取多个候选节点和对应的历史监控数据，基于所述历史监控数据，利用预测模型输出压力预测值；实时计算所述候选节点的调度影响因子，基于所述调度影响因子对所述压力预测值进行动态修正，其中，所述调度影响因子用于反映新任务对所述候选节点的资源冲击；计算所述候选节点的负载振荡系数，基于所述负载振荡系数对修正后的压力预测值进行降权处理，获得调度优先级；以及基于所述调度优先级，执行任务调度。

本发明公开了一种流程调度方法、装置、设备、介质及产品，涉及计算机技术领域，可用于金融科技领域。该方法包括：调用大语言模型对输入信息进行意图解析，确定目标意图；目标意图包括至少一个目标流程的执行序列；对输入信息进行关键信息提取，获取流程参数；若流程参数存在缺失，则调用智能体中目标流程对应的对话式驱动插件，生成参数追问语句并展示于交互界面；响应于交互界面的参数补充操作，得到补充参数，根据补充参数对流程参数进行更新；基于目标意图和更新后的流程参数，生成目标调度任务；目标调度任务包括至少一个目标流程；控制执行机器人执行目标调度任务，并监测至少一个目标流程的执行状态。本发明实施例可提高流程调度效率。

本申请公开了一种数据文件的处理方法和装置、存储介质及电子设备。涉及金融科技领域，该方法包括：通过目标线程获取目标配置信息、目标文件记录列表以及目标文件处理任务；依据目标配置信息、目标文件记录列表以及目标文件处理任务，生成每个文件类型对应的任务处理线程；通过每个文件类型对应的任务处理线程，依据第一文件记录列表中的多个金融机构信息，生成每个金融机构对应的任务执行线程；通过每个金融机构对应的任务执行线程对第二文件记录列表对应的数据文件进行处理，得到处理结果。通过本申请，解决了相关技术中通过单线程方式处理各银行多种类数据文件，存在处理效率较低的问题。

本发明公开了一种业务负载的资源部署方法及装置、电子设备、存储介质，涉及信息安全领域或其他相关领域，其中，该方法包括：获取金融系统中业务负载的当前部署信息和运行信息，从资源池的资源数据库中获取用于描述资源域的类别属性和性能属性的第一标注信息，获取用于指示业务负载的资源需求数据和可驱逐属性值的第二标注信息，基于当前部署信息、运行信息、第一标注信息和第二标注信息生成目标部署方案，并依据目标部署方案重新进行资源部署。本发明解决了相关技术中传统资源混合部署方式无法为业务负载匹配合适的资源域，导致业务负载被驱逐后影响在途交易、损失系统性能的技术问题。

本公开提供了一种数据处理方法，可以应用于人工智能技术领域。该方法包括：解析接收到的数据处理请求，获得数据处理请求的属性信息；根据属性信息确定该数据处理请求对应的目标区间；基于目标区间对应的映射关系模型预测数据处理请求的处理时长；其中，映射关系模型基于历史处理日志、数据处理请求的时间戳确定数据处理请求的处理时长；根据处理时长选择目标处理方式对数据处理请求进行处理，得到处理结果，其中，目标处理方式为离线处理和在线处理中的任一种。本公开还提供了一种数据处理装置、设备、存储介质和程序产品。

本发明公开了一种数据库的确定方法、装置、设备及程序产品，涉及数据库技术领域，可应用于金融科技领域，可用于智能运维领域。该方法包括：对至少一个候选数据库进行业务压力测试，并持续监测各候选数据库的实时在线会话数；针对每一候选数据库，根据该候选数据库的实时在线会话数和原始数据库的历史在线会话数，对该候选数据库进行在线会话容量校验，得到第一校验结果；根据第一校验结果，从各候选数据库中确定目标数据库，本发明实施例的技术方案，能够根据候选数据库的在线会话容量校验结果确定目标数据库，从而使业务系统在切换到目标数据库后，仍能保障业务的正常运行。

本公开提供了一种云计算调度方法，可以应用于云计算技术领域。该云计算调度方法包括：接收作业请求，所述作业请求包括作业优先级；对所述作业请求执行预处理，得到作业执行信息；将所述作业请求和所述执行信息更新至当前的第一作业列表，得到第二作业列表，所述第二作业列表包括N个作业请求以及对应的N个作业执行信息，N为正整数；以及基于所述第二作业列表集中的所述N个作业执行信息形成调度队列，其中，所述调度队列至少按照所述作业优先级形成，所述调度队列用于云计算作业的执行。本公开还提供了一种云计算调度装置、设备、存储介质和程序产品。

本发明公开了一种请求处理方法、系统、服务器、存储介质及程序产品。涉及大数据技术领域，该方法包括：接收终端设备发送的服务请求；预测执行服务请求所需的基础数据，其中，基础数据包括函数信息和资源需求；根据函数信息、资源需求和若干个第二服务器的当前状态，从若干个第二服务器中选择目标服务器；向目标服务器发送包括函数信息和服务请求的处理指令，以使得目标服务器从中央数据库中获取并加载函数信息对应的方法函数后，执行服务请求。本发明提供的方案能够实现服务请求在目标服务器的本地执行，降低了网络通信开销，同时提升了服务器的资源利用率和响应时效。

本申请实施例本申请提供一种数据报送方法、系统、装置、设备、介质及程序产品，涉及大数据领域。该方法包括：将业务数据存储至业务数据库，在监测到业务数据库中的变更事件时，将对应的业务数据通过消息队列推送至报送系统，以在查到表名对应的目标筛选脚本时，基于目标筛选脚本对业务数据进行筛选处理，得到筛选后的数据并发送至报送系统，以在查到该表名对应的目标加工脚本时，基于目标加工脚本对筛选后的业务数据进行加工处理，得到加工后数据并进行报送。本申请的方法，提高了数据报送的灵活性，降低数据报送系统的开发成本。

本申请公开了一种针对服务调用的处理方法及装置，涉及分布式技术领域。其中，该方法包括：检测目标服务是否具备幂等属性；在检测到目标服务具备幂等属性且目标服务的调用结果为可疑状态时，对目标服务进行S次调用处理，并根据S次调用处理的处理结果对目标服务的调用状态进行标记；在检测到目标服务不具备幂等属性且目标服务的调用结果为可疑状态时，根据第一配置表确定目标服务是否为目标异常服务；在检测到目标服务为目标异常服务时，调用查询服务对目标服务进行查询，得到查询结果，并根据查询结果对目标服务的调用状态进行标记。本申请解决了在批量作业调用联机服务时频繁遭遇结果可疑状态，导致交易状态不确定性增加的技术问题。

本发明公开了一种消息队列系统的动态分区方法、装置、设备、介质及产品，涉及大数据、机器学习技术领域，可用于金融科技领域。该方法包括：从业务数据库和消息队列系统中获取目标指标数据；其中，所述目标指标数据包括消息生产速率、消息生产速率、消息滞后量和消息大小分布中至少一项；基于分区预测模型对所述目标指标数据进行生产速率预测，得到消息队列系统的目标预测生产速率；根据所述目标预测生产速率、所述消息队列系统对应的单分区可处理能力、利用率和安全系数，确定需求分区数；根据所述消息队列系统的当前分区数和所述需求分区数，对所述消息队列系统进行扩缩容，得到目标分区数。通过上述技术方案，能够提高资源利用率。

本申请提供了一种异常处理方法、装置、设备、介质和程序产品，涉及信息安全领域，可用于智能运维领域，还可用于软件异常处理技术领域或金融科技技术领域。该异常处理方法包括：响应于定时任务被触发，从目标系统的日志集合中确定表征第一中间件模组启动异常的第一目标日志和表征第二中间件模组启动异常的第二目标日志，第一中间件模组和第二中间件模组基于预设启动次序启动；基于由第一目标日志确定的第一报错标识和由第二目标日志确定的第二报错标识，从目标系统的预设修复库中确定第一目标异常修复指令和第二目标异常修复指令；利用第一目标异常修复指令和第二目标异常修复指令，按照预设启动次序，对第一中间件模组和第二中间件模组进行修复。

本申请提供了一种异常处理方法、装置、设备、介质和程序产品，可以应用于大数据技术领域和金融科技领域。异常处理方法包括：响应于结束执行批量作业处理流程中的作业，对异常作业隔离区进行检测，批量作业处理流程中包括多个作业，异常作业隔离区用于保存批量作业处理流程中运行异常的异常作业，异常作业包括有效异常作业，有效异常作业表征异常作业需要进行异常处理；在异常作业隔离区中存在有效异常作业的情况下，基于有效异常作业的信息，对有效异常作业进行评估，确定与有效异常作业匹配的异常处理策略，异常处理策略包括重新运行有效异常作业或跳过有效异常作业；基于异常处理策略，对有效异常作业进行处理。

本申请实施例公开了一种分布式异常事务闭环方法、装置、设备及存储介质。该方法包括：对目标事务执行过程中的子事务调用时序进行记录，得到目标事务对应的子事务调用时序记录表；在监测到目标事务执行过程中任一子事务出现异常的情况下，将子事务的事务信息记录到异常指令库中；周期性调用异常处理线程，每次调用异常处理线程时，根据异常指令库、子事务调用时序记录表以及预先约定的异常事物应对策略库对发生异常的子事务对应的事务进行回滚闭环。基于此，通过对异常子事务的记录以及子事务调用时序的记录，实现对出现异常的主事务进行主动的彻底回滚，不再依赖可能出现问题的分布式事务框架的自身回滚机制，为异常事务的闭环进行兜底。

本发明公开了一种数据处理任务的异常检测方法、装置、设备及存储介质，涉及数据处理技术领域以及金融科技领域，该数据处理任务的异常检测包括：根据至少两个业务数据，生成所述业务数据对应的待执行的数据处理任务，并根据所述数据处理任务生成数据任务处理流；根据预先设置的客户方与单元容器的映射关系，将所述数据任务处理流中数据处理任务分配至其对应的单元容器进行任务处理，并在所述单元容器中生成该数据处理任务的任务流转日志信息。通过上述技术方案，提高了在单元化部署架构中异常的检测效率。