公开(公告)号：CN113626470A

公开(公告)日：2021-11-09

申请号：CN202110909201.3

申请日：2021-08-09

Applicant: 杭州安恒信息技术股份有限公司

Inventor： 梁川川 ,  范渊 ,  刘博

IPC: G06F16/2452 ,  G06F16/242 ,  G06F16/2455

Abstract: 本申请公开了一种ElasticSearch查询方法、装置、设备及可读存储介质。本申请公开的方法包括：获取用户基于人机交互界面输入的查询表达式；利用递归方式拆分查询表达式得到查询条件；根据查询条件和查询表达式的语法逻辑生成DSL查询语句，并利用DSL查询语句查询ElasticSearch。该方案不要求用户输入复杂的DSL查询语句，用户只需输入查询表达式就能够快速查询ElasticSearch，查询过程更友好；也无需用户学习复杂的DSL语法和组装格式，降低了对技术人员的要求和学习成本，不会使用ElasticSearch的相关人员也能够轻易查询ElasticSearch，提高了查询效率和查询方案的普适性。相应地，本申请提供的一种ElasticSearch查询装置、设备及可读存储介质，也同样具有上述技术效果。

公开(公告)号：CN118689911A

公开(公告)日：2024-09-24

申请号：CN202411000475.0

申请日：2024-07-24

Applicant: 杭州安恒信息技术股份有限公司

Inventor： 梁川川 ,  汤乐奇

IPC: G06F16/2455 ,  G06F16/25

Abstract: 本申请公开了一种数据流处理方法、装置、设备及存储介质，涉及数据处理领域，包括：确定基于流处理框架执行流数据处理任务时的任务处理节点，并确定任务处理节点对应的任务处理操作；将任务处理节点对应的任务处理操作进行封装，以构建同一目标数据输出格式的算子组；获取待处理任务的业务需求，并根据业务需求确定待处理任务对应的算子组，以构建对应的流计算拓扑图，利用流计算拓扑图执行待处理任务。通过采用算子组加拓扑图的方式定义流结构，利用算子组将多个操作封装在一起作为独立单元，将数据复杂的处理屏蔽起来，可以在界面上清晰地展示业务操作，并且使用算子组规划业务的流计算拓扑图，简单明了。

公开(公告)号：CN115454607A

公开(公告)日：2022-12-09

申请号：CN202211182345.4

申请日：2022-09-27

Applicant: 杭州安恒信息技术股份有限公司

Inventor： 梁川川 ,  汤乐奇

IPC: G06F9/48 ,  G06F16/901 ,  G06F16/9035

Abstract: 本申请公开了一种基于Flink的全链路排查方法、装置、设备及介质，涉及计算机技术领域，包括：在基于Flink构建的任务执行环境下加载初始数据；获取用于表征节点遍历顺序的拓扑结构图，基于拓扑结构图将初始数据作为当前处理节点的输入数据；获取当前处理节点对输入数据进行处理后得到的输出数据，并确定下一处理节点，将输出数据作为下一处理节点的输入数据；将下一处理节点作为当前处理节点，重新执行获取当前处理节点对输入数据进行处理得到输出数据的步骤，直到遍历完所有处理节点；基于每一处理节点的输入数据和输出数据执行全链路排查操作。能够根据每一处理节点的输入、输出数据确定出节点中数据的具体处理过程，便于全链路排查。