-
公开(公告)号:CN108243158A
公开(公告)日:2018-07-03
申请号:CN201611219818.8
申请日:2016-12-26
Applicant: 中移(苏州)软件技术有限公司 , 中国移动通信集团公司
IPC: H04L29/06
Abstract: 本发明提供了一种安全中的处理方法,接收第一用户标识和第一应用标识;获取到以第一身份访问第一应用的许可后,生成包含有第一用户标识和第一应用标识的票据,基于加密算法和加密密钥加密所述票据得到已加密票据;基于预设算法计算得到所述已加密票据的标识符,在本地存储所述已加密票据的标识符、加密算法和解密密钥,发送已加密票据。本发明还提供了一种安全认证的装置。
-
公开(公告)号:CN106921512B
公开(公告)日:2020-08-04
申请号:CN201511003092.X
申请日:2015-12-28
Applicant: 中移(苏州)软件技术有限公司 , 中国移动通信集团公司
IPC: H04L12/24
Abstract: 本发明公开了一种大数据集群租户带宽控制方法及装置,所述方法包括:获取来自于调度系统的带宽限制命令,所述带宽限制命令用于限制带宽,所述带宽限制命令包括租户信息;根据所述租户信息查询预设的关联信息,得到对应的带宽阈值;确定与所述租户信息对应的租户的当前带宽信息;判断所述当前带宽信息与所述带宽阈值之间的大小关系,得到判断结果;根据所述判断结果控制所述租户在存储系统中所使用的带宽。
-
公开(公告)号:CN106921512A
公开(公告)日:2017-07-04
申请号:CN201511003092.X
申请日:2015-12-28
Applicant: 中移(苏州)软件技术有限公司 , 中国移动通信集团公司
IPC: H04L12/24
CPC classification number: H04L41/0896
Abstract: 本发明公开了一种大数据集群租户带宽控制方法及装置,所述方法包括:获取来自于调度系统的带宽限制命令,所述带宽限制命令用于限制带宽,所述带宽限制命令包括租户信息;根据所述租户信息查询预设的关联信息,得到对应的带宽阈值;确定与所述租户信息对应的租户的当前带宽信息;判断所述当前带宽信息与所述带宽阈值之间的大小关系,得到判断结果;根据所述判断结果控制所述租户在存储系统中所使用的带宽。
-
公开(公告)号:CN113973093B
公开(公告)日:2023-10-13
申请号:CN202010725082.1
申请日:2020-07-24
Applicant: 中移(苏州)软件技术有限公司 , 中国移动通信集团有限公司
Abstract: 本申请公开了一种数据传输方法,包括:获取向目标客户端提供数据传输服务的目标线程的数量,并确定目标客户端的传输属性信息;传输属性信息用于指示目标客户端在单位时间内能够传输的最大数据量;基于目标线程的数量和目标客户端的传输属性信息,确定针对目标客户端和数据服务器之间进行数据转发时输入输出IO资源分配策略;基于IO资源分配策略,对目标客户端和数据服务器之间的数据进行转发。本申请实施例提供的数据传输方法能够对目标客户端和数据服务器之间的数据传输过程中IO资源进行调配,提高了数据服务器中数据资源的访问公平性,防止恶意占用IO资源的问题。本申请实施例同时公开了一种数据传输装置、电子设备以及计算机可读存储介质。
-
公开(公告)号:CN116594848B
公开(公告)日:2023-10-10
申请号:CN202310877195.7
申请日:2023-07-18
Applicant: 中移(苏州)软件技术有限公司 , 中国移动通信集团有限公司
Abstract: 本发明提供一种任务监控方法、装置、设备、终端设备及存储介质。该方法包括:根据接收到的第一任务,生成目标容器组;根据所述第一任务的第一任务执行标识,确定所述目标容器组的名称;在所述目标容器组中执行所述第一任务;根据所述第一任务的执行状态,更新数据库中所述第一任务的第一数据并将所述第一任务的第二数据上报给监控系统。本发明的方案,通过接收到的第一任务以及第一任务执行标识创建目标容器组,并通过所述第一任务执行标识对所述目标容器组进行命名,能够根据所述第一任务实时进行集群资源的动态扩容或缩容,提供高弹性、可伸缩的能力,解决了框架和分布式的处理引擎Flink集群资源的调度无法根据不同的任务进行动态调整的问题。
-
公开(公告)号:CN111858019B
公开(公告)日:2022-12-13
申请号:CN201910364122.1
申请日:2019-04-30
Applicant: 中移(苏州)软件技术有限公司 , 中国移动通信集团有限公司
Abstract: 本发明提供了任务调度方法、装置及计算机可读存储介质,其中所述任务调度方法包括:根据设定的至少一种资源类型计算待调度任务与资源队列之间的匹配度,所述匹配度表征所述待调度任务与所述资源队列在所述资源类型上的匹配程度;将满足设定条件的所述匹配度所对应的所述待调度任务确定为目标任务,将满足所述设定条件的所述匹配度所对应的所述资源队列确定为目标队列,以使所述目标任务被调度至所述目标队列。本发明基于待调度任务对资源类型对应资源的需求情况以及资源队列对资源类型对应资源的使用情况计算匹配度,实现了对具体任务的针对调度,提升了任务调度的准确性和针对性。
-
公开(公告)号:CN113973093A
公开(公告)日:2022-01-25
申请号:CN202010725082.1
申请日:2020-07-24
Applicant: 中移(苏州)软件技术有限公司 , 中国移动通信集团有限公司
Abstract: 本申请公开了一种数据传输方法,包括:获取向目标客户端提供数据传输服务的目标线程的数量,并确定目标客户端的传输属性信息;传输属性信息用于指示目标客户端在单位时间内能够传输的最大数据量;基于目标线程的数量和目标客户端的传输属性信息,确定针对目标客户端和数据服务器之间进行数据转发时输入输出IO资源分配策略;基于IO资源分配策略,对目标客户端和数据服务器之间的数据进行转发。本申请实施例提供的数据传输方法能够对目标客户端和数据服务器之间的数据传输过程中IO资源进行调配,提高了数据服务器中数据资源的访问公平性,防止恶意占用IO资源的问题。本申请实施例同时公开了一种数据传输装置、电子设备以及计算机可读存储介质。
-
公开(公告)号:CN116795785A
公开(公告)日:2023-09-22
申请号:CN202211370082.X
申请日:2022-11-03
Applicant: 中移(苏州)软件技术有限公司 , 中国移动通信集团有限公司
IPC: G06F16/13 , G06F16/14 , G06F16/16 , G06F16/172
Abstract: 本申请实施例公开了一种数据处理方法,包括:获取目标对象存储路径下的文件结构;对所述文件结构进行遍历,得到第一路径列表,其中,所述第一路径列表包括:至少一个从所述文件结构中的根节点到目标节点的路径;基于所述第一路径列表中文件的类型,确定第二路径列表,其中,所述第二路径列表中每一路径下的文件属于相同的类型;基于所述第二路径列表,确定第一元数据集合,以获得所述目标对象存储路径下的元数据。本申请实施例还同时提供了一种数据处理装置、电子设备及存储介质。
-
公开(公告)号:CN116594848A
公开(公告)日:2023-08-15
申请号:CN202310877195.7
申请日:2023-07-18
Applicant: 中移(苏州)软件技术有限公司 , 中国移动通信集团有限公司
Abstract: 本发明提供一种任务监控方法、装置、设备、终端设备及存储介质。该方法包括:根据接收到的第一任务,生成目标容器组;根据所述第一任务的第一任务执行标识,确定所述目标容器组的名称;在所述目标容器组中执行所述第一任务;根据所述第一任务的执行状态,更新数据库中所述第一任务的第一数据并将所述第一任务的第二数据上报给监控系统。本发明的方案,通过接收到的第一任务以及第一任务执行标识创建目标容器组,并通过所述第一任务执行标识对所述目标容器组进行命名,能够根据所述第一任务实时进行集群资源的动态扩容或缩容,提供高弹性、可伸缩的能力,解决了框架和分布式的处理引擎Flink集群资源的调度无法根据不同的任务进行动态调整的问题。
-
公开(公告)号:CN112751891B
公开(公告)日:2022-06-28
申请号:CN201911044313.6
申请日:2019-10-30
Applicant: 中移(苏州)软件技术有限公司 , 中国移动通信集团有限公司
IPC: H04L67/10 , H04L67/1097 , H04L67/63 , H04L69/22 , H04L67/568
Abstract: 本申请公开了一种基于kafka的消息处理方法,包括:接收kafka集群发送的消息请求;根据所述消息请求对应的消费者信息,获取主题topic监控线程;根据所述topic监控线程,获取所述消息请求对应的元数据;本申请还公开了一种基于kafka的消息处理装置及存储介质;通过本申请实施例,使得在消费者获取kafka集群中消费者订阅的消息的过程中,根据消费者的需求处理消费者订阅的消息,分散kafka集群的处理压力。
-
-
-
-
-
-
-
-
-