-
公开(公告)号：CN111913996B
公开(公告)日：2023-07-18
申请号：CN202010672810.7
申请日：2020-07-14
申请人： 中国联合网络通信集团有限公司 , 联通系统集成有限公司 , 联通(黑龙江)产业互联网有限公司
IPC分类号： G06F16/2457 , G06F16/2455 , G06F16/215 , G06F16/2458 , G06F16/2453
摘要： 本申请实施例提供一种数据处理方法、装置、设备及存储介质，该方法包括：响应于用于指示向用户推送消息的触发指令，获取活动信息，所述活动信息包括活动规则和活动文本内容；从Kafka队列中获取各个省份的实时流数据，所述实时流数据包括至少一个用户的信令数据；针对各个所述省份，根据所述活动规则和所述活动文本内容，通过Spark框架对所述至少一个用户的信令数据进行筛选，确定允许推送所述活动文本内容的目标信令数据对应的目标用户；将所述活动文本内容推送至所述目标用户使用的终端。本申请实施例提供的方法能够克服现有技术无法快速有效地处理数据，进而无法有效地为用户提供更好的服务的问题。
-
公开(公告)号：CN111427706A
公开(公告)日：2020-07-17
申请号：CN202010203363.0
申请日：2020-03-20
申请人： 中国联合网络通信集团有限公司 , 联通系统集成有限公司 , 联通(黑龙江)产业互联网有限公司
IPC分类号： G06F9/54
摘要： 本公开提供的数据处理方法、多服务器系统、数据库、电子设备及存储介质，针对多服务器系统中的任一目标服务器，目标服务器的多个处理进程按照预设时间间隔向数据库发送心跳信息，以供数据库对心跳信息进行存储；其中，心跳信息包括处理进程标识和目标服务器标识，以及心跳时间；目标服务器的分配进程获取数据库存储的各心跳信息，并根据各心跳信息生成任务信息，将任务信息发送至数据库以供其存储；目标服务器的多个处理进程获取数据库存储的任务信息，并根据任务信息执行处理任务，从而多服务器多处理进程同步处理同一任务，提高了处理效率。
-
公开(公告)号：CN111274340B
公开(公告)日：2023-06-30
申请号：CN202010040005.2
申请日：2020-01-15
申请人： 中国联合网络通信集团有限公司 , 联通系统集成有限公司
摘要： 本申请提供一种人流密度的监控处理方法、设备及存储介质，该方法包括：实时获取移动终端用户的位置信息；对所述位置信息进行数据预处理，获得预处理后的位置信息；采用实时流处理引擎将所述预处理后的位置信息进行存储；按照预设时间周期从存储的预处理后的位置信息中获取当前之前预设时间段内目标区域的预处理后的位置信息；根据所述目标区域的预处理后的位置信息，确定所述目标区域在当前之前预设时间段内的人流密度；若所述目标区域在当前之前预设时间段内的人流密度的增加速度超过预设范围，则进行预警处理。本申请采用创新的人流密度的监控处理方法，实时统计特定区域内人流总数和重点区域人流密度，当流动人群密度过高时进行提前预警。
-
公开(公告)号：CN111427706B
公开(公告)日：2023-06-20
申请号：CN202010203363.0
申请日：2020-03-20
申请人： 中国联合网络通信集团有限公司 , 联通系统集成有限公司 , 联通(黑龙江)产业互联网有限公司
IPC分类号： G06F9/54
摘要： 本公开提供的数据处理方法、多服务器系统、数据库、电子设备及存储介质，针对多服务器系统中的任一目标服务器，目标服务器的多个处理进程按照预设时间间隔向数据库发送心跳信息，以供数据库对心跳信息进行存储；其中，心跳信息包括处理进程标识和目标服务器标识，以及心跳时间；目标服务器的分配进程获取数据库存储的各心跳信息，并根据各心跳信息生成任务信息，将任务信息发送至数据库以供其存储；目标服务器的多个处理进程获取数据库存储的任务信息，并根据任务信息执行处理任务，从而多服务器多处理进程同步处理同一任务，提高了处理效率。
-
公开(公告)号：CN111274340A
公开(公告)日：2020-06-12
申请号：CN202010040005.2
申请日：2020-01-15
申请人： 中国联合网络通信集团有限公司 , 联通系统集成有限公司
摘要： 本申请提供一种人流密度的监控处理方法、设备及存储介质，该方法包括：实时获取移动终端用户的位置信息；对所述位置信息进行数据预处理，获得预处理后的位置信息；采用实时流处理引擎将所述预处理后的位置信息进行存储；按照预设时间周期从存储的预处理后的位置信息中获取当前之前预设时间段内目标区域的预处理后的位置信息；根据所述目标区域的预处理后的位置信息，确定所述目标区域在当前之前预设时间段内的人流密度；若所述目标区域在当前之前预设时间段内的人流密度的增加速度超过预设范围，则进行预警处理。本申请采用创新的人流密度的监控处理方法，实时统计特定区域内人流总数和重点区域人流密度，当流动人群密度过高时进行提前预警。
-
公开(公告)号：CN111159273A
公开(公告)日：2020-05-15
申请号：CN201911420446.9
申请日：2019-12-31
申请人： 中国联合网络通信集团有限公司 , 联通系统集成有限公司
摘要： 本申请提供一种数据流处理方法、装置、服务器及存储介质。本申请提供的数据流处理方法，首先获取第一数据流，其中，第一数据流包括地域性特征信息，然后对第一数据流配置规则参数以生成第二数据流，规则参数用于表征流任务的筛选条件，再根据地域性特征信息以及规则参数将第二数据流进行树形结构分级，以使特征值根据树形结构与第二数据流进行关联，而特征值用于表征静态标签表数据。从而，减少了实时数据的处理量，提高了处理效率，优化了处理方式，满足了实时流表关联需求，保证了数据处理系统的运行稳定性。
-
公开(公告)号：CN108092768A
公开(公告)日：2018-05-29
申请号：CN201711396960.4
申请日：2017-12-21
申请人： 中国联合网络通信集团有限公司 , 联通系统集成有限公司
摘要： 本发明提供了一种数据融合方法与系统，该方法，包括：接收第一数据处理系统发送的第一待融合数据集；所述第一待融合数据集包括第一内容和加密后第一关键字；接收第二数据处理系统发送的第二待融合数据集，所述第二待融合数据包括第二内容和加密后第二关键字；所述第二关键字与所述第一关键字为分别存储于所述第二数据处理系统与所述第一数据处理系统的相同关键字，且所述加密后第二关键字与所述加密后第一关键字为利用相同的加密方式加密得到的相同的加密后关键字；根据所述相同的加密后关键字，融合所述第一融合数据集与所述第二待融合数据集，得到融合后数据集。本发明提高了安全性。
-
公开(公告)号：CN111241105B
公开(公告)日：2023-08-15
申请号：CN202010040007.1
申请日：2020-01-15
申请人： 中国联合网络通信集团有限公司 , 联通系统集成有限公司
IPC分类号： G06F16/22 , G06F16/2455 , G06F16/29 , G06Q50/26
摘要： 本公开提供一种追踪方法和装置、电子设备、存储介质。该方法包括：采集多个用户的通信数据，构建包括手机信令数据和上网详单数据的多级树形结构模型，接收对象发送的携带待追踪数据的查询请求，根据多级树形结构模型生成与待追踪数据对应的待追踪用户信息。在现有技术中，通过将待追踪数据与获取到的通信数据进行比对的方式进行追踪，而在本公开实施例中，是通过构建的多级树形结构模型，以便根据多级树形结构模型生成与待追踪数据对应的待追踪用户信息，避免了现有技术中将待追踪数据与各用户的通话记录进行依次比对造成的耗时较长等问题，从而实现了迅速确定待追踪用户信息，进而实现了提高追踪效率的技术效果。
-
公开(公告)号：CN111159273B
公开(公告)日：2023-07-18
申请号：CN201911420446.9
申请日：2019-12-31
申请人： 中国联合网络通信集团有限公司 , 联通系统集成有限公司
摘要： 本申请提供一种数据流处理方法、装置、服务器及存储介质。本申请提供的数据流处理方法，首先获取第一数据流，其中，第一数据流包括地域性特征信息，然后对第一数据流配置规则参数以生成第二数据流，规则参数用于表征流任务的筛选条件，再根据地域性特征信息以及规则参数将第二数据流进行树形结构分级，以使特征值根据树形结构与第二数据流进行关联，而特征值用于表征静态标签表数据。从而，减少了实时数据的处理量，提高了处理效率，优化了处理方式，满足了实时流表关联需求，保证了数据处理系统的运行稳定性。
-
公开(公告)号：CN108092768B
公开(公告)日：2021-06-01
申请号：CN201711396960.4
申请日：2017-12-21
申请人： 中国联合网络通信集团有限公司 , 联通系统集成有限公司
摘要： 本发明提供了一种数据融合方法与系统，该方法，包括：接收第一数据处理系统发送的第一待融合数据集；所述第一待融合数据集包括第一内容和加密后第一关键字；接收第二数据处理系统发送的第二待融合数据集，所述第二待融合数据包括第二内容和加密后第二关键字；所述第二关键字与所述第一关键字为分别存储于所述第二数据处理系统与所述第一数据处理系统的相同关键字，且所述加密后第二关键字与所述加密后第一关键字为利用相同的加密方式加密得到的相同的加密后关键字；根据所述相同的加密后关键字，融合所述第一融合数据集与所述第二待融合数据集，得到融合后数据集。本发明提高了安全性。
-
-
-
-
-
-
-
-
-
搜索结果
13 条记录 (耗时 0.053 秒)
