开发者社区 > 大数据与机器学习 > 实时计算 Flink > 正文

如何将离线推荐系统调整为实时推荐系统?

如何将离线推荐系统调整为实时推荐系统?

展开
收起
云上静思 2021-11-05 16:17:20 1014 0
1 条回答
写回答
取消 提交回答
  • 离线推荐架构:

    1. 通过消息队里额采集实时用户行为,这个消息队列里面的实时用户行为会被导入到一个离线存储来存储用户行为,然后每天做静态特征计算,最后放到特征存储里给线上提供推理服务用;

    2. 同时,系统也会做离线的样本拼接,拼接出来的样本会被存到样本存储里,给离线的模型训练用。离线的模型训练每天会产生新的模型去验证,然后给到推理服务使用。 总结,离线的推荐架构的更新周期是T+1。

    如果要把离线推荐架构做到实时推荐系统里,主要做以下几个事情:

    1. 特征计算:静态T+1特征计算到实时特征计算;

    2. 样本生成:离线T+1样本生成到实时样本生成;

    3. 训练模型:离线训练模型T+1更新到增量训练实时更新。

    资料来源:《实时数仓“王炸组合”-实时计算 Flink 版+Hologre》链接:https://developer.aliyun.com/topic/download?id=7944

    2021-11-05 22:45:53
    赞同 展开评论 打赏

实时计算Flink版是阿里云提供的全托管Serverless Flink云服务,基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎,提高作业开发运维效率。

相关电子书

更多
百度大规模时序指标自动异常检测实战 立即下载
蘑菇街广告的排序:从历史数据学习到个性化强化学习 立即下载
统一召回引擎在搜索推荐场景的应用实践 立即下载