利用客户基本信息(订单、消费、人为操作),精准定位喜好、行为、购买等信息。
定时(Hangfire)生成发布任务(采集、计算),使用RabbitMQ消费处理逻辑,确保长时间运行无中断
一、 消费采集任务
采集客户分布在不同数据库的(订单、消费金额、消费时间),并保存到Elasticsearch
订单:淘宝、京东、拼多多、抖音、微盟等等之类订单
二、 消费计算任务
程序读取Elasticsearch的海量数据【过亿数据】,二次分析与逻辑计算数据,得出客户的行为轨迹,并保存到Elasticsearch
三、 商家查询
例:用户最近1年或者半年的消费信息
查询Elasticsearch的行为轨迹索引,获取统计数据
使用到的技术:
.Net Core、RabbitMQ、Elasticsearch、Hangfire、Kafka
测试与灰度环境统一容器化,部署在Docker上
点击空白处退出提示
评论