买专利卖专利找龙图腾，真高效！ 查专利查商标用IPTOP,全免费！专利年费监控用IP管家,真方便！

龙图腾网获悉中国联合网络通信集团有限公司;联通数字科技有限公司申请的专利实时推送方法、装置、设备和介质获国家发明授权专利权，本发明授权专利权由国家知识产权局授予，授权公告号为：CN118869795B 。

龙图腾网通过国家知识产权局官网在2026-03-20发布的发明授权授权公告中获悉：该发明授权的专利申请号/专利号为：202410808853.1，技术领域涉及：H04L67/55；该发明授权实时推送方法、装置、设备和介质是由姜雨彤;穆纯进设计研发完成，并于2024-06-21向国家知识产权局提交的专利申请。

本实时推送方法、装置、设备和介质在说明书摘要公布了：本申请提供一种实时推送方法、装置、设备和介质。包括：确定订阅用户，并将订阅用户对应的用户数据存储至数据湖中，得到用户数据存储表；根据预设的kafka处理平台，确定订阅用户的订阅数据，并根据预设的flink程序接口，将用户数据存储表和订阅数据进行数据关联，得到数据关联表；根据预设的mysql规则表，确定订阅数据的推送时段和推送阈值，并根据推送时段和推送阈值，对订阅数据进行过滤，得到目标订阅数据；根据数据关联表，确定目标订阅数据对应的目标用户数据及其目标用户；根据目标用户数据，确定对应的数据推送信息，并向目标用户推送数据推送信息。如此，对订阅用户进行实时数据提醒，实现了推送功能更完善灵活性更高。

本发明授权实时推送方法、装置、设备和介质在权利要求书中公布了：1.一种实时推送方法，其特征在于，所述方法包括： 确定订阅用户，并将所述订阅用户对应的用户数据存储至数据湖Paimon中，得到用户数据存储表； 根据预设的kafka处理平台，确定所述订阅用户的订阅数据，并根据预设的flink程序接口，以流计算方式将所述用户数据存储表和所述订阅数据进行流表关联，得到数据关联表；其中，通过所述数据湖Paimon流批一体的读写特性，对所述流表关联的中间结果进行存储，以实现所述中间结果的实时可查与数据一致性保证； 根据预设的mysql规则表，确定所述订阅数据的推送时段和推送阈值，并根据所述推送时段和推送阈值，对所述订阅数据进行过滤，得到目标订阅数据； 根据所述数据关联表，确定所述目标订阅数据对应的目标用户数据及其目标用户； 根据所述目标用户数据，确定对应的数据推送信息，并向所述目标用户推送所述数据推送信息； 所述根据预设的mysql规则表，确定所述订阅数据的推送时段和推送阈值，并根据所述推送时段和推送阈值，对所述订阅数据进行过滤，得到目标订阅数据，包括： 确定所述mysql规则表，并根据所述mysql规则表的表结构，确定所述推送时段和所述推送阈值； 比对所述订阅数据的获取时段和所述推送时段，得到比对结果； 若所述比对结果为所述获取时段在所述推送时段内，则确定所述订阅数据为待过滤订阅数据； 若所述比对结果为所述获取时段不在所述推送时段内，则确定所述订阅数据为非过滤订阅数据； 根据所述推送阈值，对所述待过滤订阅数据进行过滤，得到所述目标订阅数据； 所述确定订阅用户，并将所述订阅用户对应的用户数据存储至数据湖Paimon中，得到用户数据存储表，包括： 确定预设的hive数据表，并根据所述hive数据表，确定历史订阅用户及其对应的用户数据； 将所述用户数据存储至所述数据湖中，得到初始用户数据存储表； 获取预设的kafka处理平台发送的平台用户及其平台用户数据，并将所述平台用户数据与所述初始用户数据存储表中的用户数据进行数据匹配，得到匹配结果； 根据所述匹配结果，确定所述用户数据存储表； 所述根据所述推送阈值，对所述待过滤订阅数据进行过滤，得到所述目标订阅数据，包括： 确定所述待过滤订阅数据的数据值，并比对所述数据值和所述推送阈值，得到比对结果； 若所述比对结果为所述数据值不超过所述推送阈值，则确定所述待过滤订阅数据为所述目标订阅数据； 若所述比对结果为所述数据值超过所述推送阈值，则确定所述待过滤订阅数据为非目标订阅数据。

如需购买、转让、实施、许可或投资类似专利技术，可联系本专利的申请人或专利权人中国联合网络通信集团有限公司;联通数字科技有限公司，其通讯地址为：100033 北京市西城区金融大街21号；或者联系龙图腾网官方客服，联系龙图腾网可拨打电话0551-65771310或微信搜索“龙图腾网”。

以上内容由龙图腾AI智能生成。