-
公开(公告)号：CN115454607A
公开(公告)日：2022-12-09
申请号：CN202211182345.4
申请日：2022-09-27
Applicant: 杭州安恒信息技术股份有限公司
IPC: G06F9/48 , G06F16/901 , G06F16/9035
Abstract: 本申请公开了一种基于Flink的全链路排查方法、装置、设备及介质，涉及计算机技术领域，包括：在基于Flink构建的任务执行环境下加载初始数据；获取用于表征节点遍历顺序的拓扑结构图，基于拓扑结构图将初始数据作为当前处理节点的输入数据；获取当前处理节点对输入数据进行处理后得到的输出数据，并确定下一处理节点，将输出数据作为下一处理节点的输入数据；将下一处理节点作为当前处理节点，重新执行获取当前处理节点对输入数据进行处理得到输出数据的步骤，直到遍历完所有处理节点；基于每一处理节点的输入数据和输出数据执行全链路排查操作。能够根据每一处理节点的输入、输出数据确定出节点中数据的具体处理过程，便于全链路排查。
-
公开(公告)号：CN117149855A
公开(公告)日：2023-12-01
申请号：CN202311163590.5
申请日：2023-09-11
Applicant: 杭州安恒信息技术股份有限公司
IPC: G06F16/2458 , G06F17/18
Abstract: 本申请公开了一种基于微批处理的实时统计方法、装置、设备及存储介质，涉及数据统计领域，包括：对接收的待处理数据进行解析，并对解析后数据进行过滤，以得到处理后数据；将处理后数据划分为若干部分处理后数据，并输入至若干预设并发统计算子，以通过所述若干预设并发统计算子对输入至自身的数据进行数据统计，得到临时统计结果；确定临时统计结果对应的若干指标标识，以通过若干指标标识对临时统计结果进行分组利用预设汇总统计算子对分组后临时统计结果进行汇总统计，以输出与分组后临时统计结果相对应的目标统计结果。这样一来，可以通过不同的并发统计算子优化统计类指标的计算能力，以支持较多不同维度、不同时间窗口下的同时统计计算。
-
公开(公告)号：CN113885880A
公开(公告)日：2022-01-04
申请号：CN202111240192.X
申请日：2021-10-25
Applicant: 杭州安恒信息技术股份有限公司
IPC: G06F8/41
Abstract: 本申请公开了一种多规则匹配方法、装置、设备及存储介质。该方法包括：利用ANTLR解析器，根据AND逻辑操作符对多个逻辑表达式进行规则解析，以拆分得到多个子表达式；根据每个所述子表达式的频次，从所有所述子表达式中筛选出公共子表达式作为父节点；以所述父节点为基础，根据所述逻辑表达式以及其余所述子表达式对应的运算量和频次，依次筛选出目标子表达式作为子节点构建规则树以得到一个或多个规则树；获取待检测数据，利用所述规则树从父节点开始按照顺序对所述待检测数据进行规则匹配，若匹配失败则跳过当前节点的所有子节点的规则匹配并输出匹配结果。通过将公共子表达式作为父节点，避免同一个规则的多次匹配，提高了规则匹配的效率。
-
公开(公告)号：CN113778947A
公开(公告)日：2021-12-10
申请号：CN202111128339.6
申请日：2021-09-26
Applicant: 杭州安恒信息技术股份有限公司
Abstract: 本发明公开了一种kafka流处理平台的数据导入方法，该方法包括以下步骤：通过对待导入kafka流处理平台的目标数据流进行字段拆分，分别获取拆分得到的各初始字段的字段类型，预先设置包含各字段类型与各数据格式转换规则之间对应关系的配置文件，利用预设配置文件进行格式转换规则匹配，根据各数据格式转换规则对各初始字段进行格式转换，得到统一格式的各目标字段，将各目标字段导入至kafka流处理平台。应用本发明所提供的kafka流处理平台的数据导入方法，较大地节省了人力，节省了时间成本，较大地提高了数据导入效率。本发明还公开了一种kafka流处理平台的数据导入装置、设备及存储介质，具有相应技术效果。
-
公开(公告)号：CN119322780A
公开(公告)日：2025-01-17
申请号：CN202411524595.0
申请日：2024-10-29
Applicant: 杭州安恒信息技术股份有限公司
IPC: G06F16/22 , G06F16/2458 , G06F16/27 , G06F16/21
Abstract: 本申请公开了一种数据时序关联方法、装置、设备及存储介质，应用于Flink分布式实时处理引擎，涉及大数据技术领域，包括：提取目标关联条件，并生成目标数据相应的目标键；基于目标键对目标数据分组，并将分组后的目标数据分别存储至目标节点中；同一目标节点中存储的目标数据具有相同的事件类型以及关联字段数据；当获取到待匹配数据，则基于事件类型和关联字段数据将待匹配数据与任一目标节点中的目标数据进行匹配，并确定是否将待匹配数据与任一目标节点中的目标数据进行关联。本申请通过将相同事件类型和关联字段数据对应的目标数据存储在相同的目标节点，在新数据进入时，仅需判断相同关联字段一次，从而提高了时序关联的计算效率。
-
Patent Agency Ranking
公开(公告)号：CN119201861A
公开(公告)日：2024-12-27
申请号：CN202411426281.7
申请日：2024-10-12
Applicant: 杭州安恒信息技术股份有限公司
Abstract: 本申请公开了一种分片状态文件损坏的分片修复方法、装置、设备及介质，涉及数据存储技术领域，包括：基于预设分片查找命令查找分片状态文件损坏的目标分片，并确定目标分片对应的关联信息；根据关联信息确定目标分片所在的目标Elasticsearch节点，并利用目标Elasticsearch节点对应的节点主机关停目标Elasticsearch节点；在目标Elasticsearch节点关停后将预设分片修复工具包上传至节点主机，以便节点主机利用预设分片修复工具包修复目标Elasticsearch节点对应的目标分片。本申请解决了分片状态文件损坏的分片无法修复的问题，从而降低了数据丢失的风险。
-
公开(公告)号：CN111859929B
公开(公告)日：2024-04-09
申请号：CN202010779472.7
申请日：2020-08-05
Applicant: 杭州安恒信息技术股份有限公司
IPC: G06F40/253 , G06F40/284
Abstract: 本申请公开了一种数据可视化方法，包括利用ANTLR工具将待处理逻辑表达式转换为ANTLR语法树；采用访问者模式对所述ANTLR语法树进行转换，获得初始可视化模型；对所述初始可视化模型中的优先级信息进行优化，获得优化可视化模型；对所述优化可视化模型中的同类项信息进行合并，获得树状模型；输出所述树状模型至可视化设备进行展示；该数据可视化方法可以更为有效的简化逻辑表达式的可视化结构，提高可视化效果。本申请还公开了一种数据可视化装置、设备以及计算机可读存储介质，均具有上述有益效果。
-
公开(公告)号：CN117407156A
公开(公告)日：2024-01-16
申请号：CN202311243486.7
申请日：2023-09-25
Applicant: 杭州安恒信息技术股份有限公司
IPC: G06F9/50 , G06F16/2458 , G06F16/25
Abstract: 本申请涉及目标数据提取方法、装置、计算机设备和存储介质，应用于服务器，该服务器部署有至少一个计算单元，所述方法包括：确定计算单元对应的数据格式；基于数据格式对计算单元进行划分，得到至少两个计算单元域，并基于计算单元域分配对应的数据提取算子；其中，数据提取算子用于指示对应的算子数据结构；获取待提取数据，基于算子数据结构从待提取数据中确定对应的待提取目标数据，并基于数据提取算子进行反序列化计算，得到待提取数据中的目标数据。采用本方法能够提升计算效率，减少计算资源的浪费。
-
公开(公告)号：CN115495050A
公开(公告)日：2022-12-20
申请号：CN202211156960.8
申请日：2022-09-22
Applicant: 杭州安恒信息技术股份有限公司
Abstract: 本申请公开了一种任务处理方法、装置、设备及可读存储介质，该方法包括：载入并解析待创建flink数据流链对应的yaml配置文件，得到数据流向图和算子节点列表；利用数据流向图，初始化初始节点和各个算子节点；按照算子节点列表和/或数据流向图中对应的连接方式，连接初始节点和各个算子节点，得到flink数据流链；启动flink数据流链，并利用flink数据流链执行实时流任务。本申请能够使得开发人员方便地对数据流走向、运行配置进行调整，提升了代码的可维护性，提高开发效率。
-
公开(公告)号：CN118689911A
公开(公告)日：2024-09-24
申请号：CN202411000475.0
申请日：2024-07-24
Applicant: 杭州安恒信息技术股份有限公司
IPC: G06F16/2455 , G06F16/25
Abstract: 本申请公开了一种数据流处理方法、装置、设备及存储介质，涉及数据处理领域，包括：确定基于流处理框架执行流数据处理任务时的任务处理节点，并确定任务处理节点对应的任务处理操作；将任务处理节点对应的任务处理操作进行封装，以构建同一目标数据输出格式的算子组；获取待处理任务的业务需求，并根据业务需求确定待处理任务对应的算子组，以构建对应的流计算拓扑图，利用流计算拓扑图执行待处理任务。通过采用算子组加拓扑图的方式定义流结构，利用算子组将多个操作封装在一起作为独立单元，将数据复杂的处理屏蔽起来，可以在界面上清晰地展示业务操作，并且使用算子组规划业务的流计算拓扑图，简单明了。
-
-
-
-
-
-
-
-
-
Search Results
14
records
(took 0.026 seconds)
