公开(公告)号：CN110647547A

公开(公告)日：2020-01-03

申请号：CN201910895091.2

申请日：2019-09-20

Applicant: 北京百分点信息科技有限公司

Inventor： 黄伟 ,  廖锐 ,  刘译璟 ,  于帮付 ,  马志峰 ,  杜晓梦 ,  苏海波 ,  苏萌 ,  左云鹏 ,  陆攀

IPC: G06F16/2455 ,  G06F16/2458

Abstract: 本说明书实施例公开了一种消费延迟监控方法、装置、电子设备及计算机可读存储介质。其中，该方法应用于基于Spark Streaming框架的流处理系统，包括：按照预设时间间隔从Kafka系统中读取流数据，所述流数据中包括多条携带有生产时间戳的业务数据；基于所述流数据中的目标业务数据的生产时间戳确定所述Kafka系统的消费延迟时间，其中，所述目标业务数据为所述流数据中生产时间戳最晚的业务数据；基于所述消费延迟时间，对所述Kafka系统进行消费延迟监控。本申请能够实现对Kafka系统中的消费延迟信息的有效监控。

公开(公告)号：CN110674112A

公开(公告)日：2020-01-10

申请号：CN201910899832.4

申请日：2019-09-23

Applicant: 北京百分点信息科技有限公司

Inventor： 黄伟 ,  孙伟 ,  苏海波 ,  杜晓梦 ,  马志峰 ,  刘译璟 ,  于帮付 ,  赵丹

IPC: G06F16/21 ,  G06F16/22 ,  G06F16/27 ,  G06F16/28

Abstract: 本发明实施例公开了一种数据查询的方法、装置及电子设备，所述方法、装置及电子设备包括：获取待查询语句中包含的目标实体信息；基于目标实体信息，从预设数据库中获取与目标实体信息匹配的目标关联信息，预设数据库包括第一数据库和第二数据库，第一数据库用于存储实体信息，第二数据库用于存储与实体信息匹配的关联信息，其中，关联信息包括实体执行和/或响应的关联事件以及所述关联事件的响应或执行对象。采用该方法、装置及电子设备，在查询目标实体的多个关联信息时，不需要多次查询，可以基于待查询语句中的目标实体信息，从预设数据库中获取与目标实体信息匹配的多个目标关联信息，从而提高关联信息的查询效率。

公开(公告)号：CN110704871A

公开(公告)日：2020-01-17

申请号：CN201910900541.2

申请日：2019-09-23

Applicant: 北京百分点信息科技有限公司

Inventor： 黄伟 ,  马志峰 ,  刘译璟 ,  于帮付 ,  倪路 ,  段振楠 ,  刘钰 ,  苏萌

IPC: G06F21/62

Abstract: 本发明公开了一种权限管理方法、装置、电子设备以及计算机可读存储介质。该方法包括：接收用户对多源融合数据的数据访问请求；获取所述用户请求访问的数据，其中所述数据包括至少一个属性值；确定所述用户对所述数据的数据源的权限；根据所述属性值的数据源标识和所述权限，确定用户对所述属性值的权限，并执行与所述属性值的权限对应的操作；其中所述数据源标识用于表征所述属性值的数据源。