数据处理方法、装置、设备及存储介质
摘要:
本申请实施例提供一种数据处理方法、装置、设备及存储介质,该方法包括:响应于用于指示向用户推送消息的触发指令,获取活动信息,所述活动信息包括活动规则和活动文本内容;从Kafka队列中获取各个省份的实时流数据,所述实时流数据包括至少一个用户的信令数据;针对各个所述省份,根据所述活动规则和所述活动文本内容,通过Spark框架对所述至少一个用户的信令数据进行筛选,确定允许推送所述活动文本内容的目标信令数据对应的目标用户;将所述活动文本内容推送至所述目标用户使用的终端。本申请实施例提供的方法能够克服现有技术无法快速有效地处理数据,进而无法有效地为用户提供更好的服务的问题。
公开/授权文献
0/0