使用Redis实现最近N条数据的决策

前言

很多时候,我们会根据用户最近一段时间的行为,做出一些相应的策略,从而改变系统的运动轨迹。

举个简单的例子来说明一下:

假设A公司现在有两个合作伙伴(B和C),B和C都是提供天气数据的,现在A公司做了一个聚合接口,把B和C的接口融合了,那么这个时候,要怎么去B和C公司获取数据呢?

其实这个要考虑的东西有很多很多,下面根据本文的主题,拿出其中一个点来讨论说明。

最简单的做法就是,随机调用。当然不是那么简单的随机调用。

根据调用的最近一百条数据的得到成功率,耗时等指标,再根据这些指标去判断一次查询要去那个公司获取数据。

思路已经有了,这个时候就是怎么实践的问题了。

本文介绍的做法是借助redis来完成的。

如何用redis来处理

redis的list类型可以说非常适合用来处理这个情况。

首先,可以把查询按顺序写进去,一个个的入队。

其次,写进去之后可以对它进行裁剪,保留最近的100条数据。(换句话说,我们可以保证在这个list里面,最多就是100条数据)

最后,获取这个list里面的100条数据,进行计算即可。

正常情况下,我们不会把计算放在查询的过程里面,在查询的时候,只需要一个决策的结果值就可以了,当然这个结果值也是计算后写进redis的。

所以要将这个计算的过程从查询中独立出来,定时去执行即可。

总结上面所说的,大概可以画出下面这样一样图。

640?wx_fmt=png

其中的第三步操作,将查询记录写进list,然后进行裁剪这两个操作,可以直接操作redis,也可以考虑通过MQ去写,虽说没什么太大的必要。

简单的示例代码

查询的控制器

[Route("api/[controller]")][ApiController]public class AreaController : ControllerBase{    private readonly ILogger _logger;    private readonly IRedisCachingProvider _provider;    public AreaController(ILoggerFactory loggerFactory, IRedisCachingProvider provider)    {        _logger = loggerFactory.CreateLogger<AreaController>();        _provider = provider;    }        [HttpGet("provinceId")]    public async Task<string> GetAsync(string provinceId)    {                var datasource = await GetQueryDataSourceIdAsync(provinceId);        if (string.IsNullOrWhiteSpace(datasource)) return "not support";        var beginTime = DateTime.Now;                       var (val, isSucceed) = await QueryDataSourceAsync(datasource);        var endTime = DateTime.Now;                var dsInfo = new DataSourceInfo        {            Cost = (long)endTime.Subtract(endTime).TotalMilliseconds,            IsSucceed = isSucceed        };                _ = Task.Run(async () =>        {            try            {                await _provider.LPushAsync($"info:{datasource}", new List<DataSourceInfo> { dsInfo });                await _provider.LTrimAsync($"info:{datasource}", 0, 99);            }            catch (Exception ex)            {                _logger.LogError(ex, $"record #{datasource}# error");            }        });        return val;    }    private async Task<string> GetQueryDataSourceIdAsync(string provinceId)    {        var datasourceIds = GetDataSourceIdProvinceId(provinceId);        if (datasourceIds.Count <= 0) return string.Empty;               var cacheKey = "dskpi";        var kpis = await _provider.HMGetAsync(cacheKey, datasourceIds);        var datasource = datasourceIds.First();        if (kpis != null && kpis.Any())        {                        datasource = kpis.OrderByDescending(x => x.Value).First().Key;        }        return datasource;    }    private async Task<(string val, bool isSucceed)> QueryDataSourceAsync(string datasource)    {        await Task.Delay(100);        var rd = new Random().NextDouble();        return (datasource, rd > 0.5d);    }    private List<string> GetDataSourceIdProvinceId(string provinceId)    {        return new List<string> { "100", "900" };    }}

由调度系统触发的计算控制器

也可以在Github上面找到上面的示例代码 RecentRecordsDemo

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.mzph.cn/news/314454.shtml

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

为什么我不喜欢数据库三范式

插曲最近&#xff0c;一个远房亲戚的小表弟准备选修专业找到我问&#xff1a;"哥&#xff0c;现在学数据库有没有前途阿?""当然有啊&#xff0c;前途大大的呢""那我现在开始学数据库&#xff0c;需要先从什么开始呢?""学课程的话&#xf…

硬货 - 技术人也能轻松玩转公众号?正确姿势竟然是...

最近在知乎上看到关于「公众号是否有“前”途」的相关问题... 问题下面有些精华回答~微信公众号还有“前”途吗&#xff1f; - 知乎https://www.zhihu.com/question/324575670很好的问题&#xff01;作为一个技术人&#xff0c;我决定将此问题和自身情况结合起来&#xff0c;于…

你必须知道的Dockerfile

本篇已加入《.NET Core on K8S学习实践系列文章索引》&#xff0c;可以点击查看更多容器化技术相关系列文章。本文预计阅读时间为5分钟。01—关于Dockerfile在Docker中创建镜像最常用的方式&#xff0c;就是使用Dockerfile。Dockerfile是一个Docker镜像的描述文件&#xff0c;我…

RabbitMQ 死信/死信队列

一、RabbitMQ 死信/死信队列1、DLXDead Letter Exchange 的缩写DLX&#xff08;Dead Letter Exchanges&#xff09;死信交换&#xff0c;死信队列本身也是一个普通的消息队列&#xff0c;在创建队列的时候&#xff0c;通过设置一些关键参数&#xff0c;可以将一个普通的消息队列…

centos7 rabbitmq安装/配置

一、RabbitMQ简单介绍RabbitMQ就是当前最主流的消息中间件之一。RabbitMQ是一个开源的AMQP实现&#xff0c;服务器端用Erlang语言编写&#xff0c;支持多种客户端&#xff0c;如&#xff1a;Python、Ruby、.NET、Java、JMS、C、PHP、ActionScript、XMPP、STOMP等&#xff0c;支…

Hyper-V + CentOS7 安装视频教程

一、前言本文使用图文视频的方式展示安装Centos7&#xff0c;【喜欢看视频学习的童靴请拖至文尾观看视频】二、虚拟机配置指定虚拟机名称&安装位置选择虚拟机代数 第一代虚拟机&#xff08;例如Server 2008等平台技术&#xff0c;支持Vista、Win7&#xff09; 第二代虚拟机…

程序员修神之路--用NOSql给高并发系统加速

领取福利记得长按&#xff0c;领取技术书籍哦随着互联网大潮的到来&#xff0c;越来越多网站&#xff0c;应用系统需要海量数据的支撑&#xff0c;高并发、低延迟、高可用、高扩展等要求在传统的关系型数据库中已经得不到满足&#xff0c;或者说关系型数据库应对这些需求已经显…

限时团购,6.5折:《C# 7.0 核心技术指南》

大家好&#xff0c;经过近两年的翻译&#xff0c;《C# 7.0 核心技术指南》终于和大家见面了。全书由 ThoughtWorks 高级咨询师&#xff0c;资深 .NET 专家刘夏翻译。作为一本第七次再版的图书&#xff0c;此次翻译对书中的字句进行了重新整理。期间和图书的原作者 Joe Albahari…

Azure 命令行工具大混战,都是什么,该选哪个?

点击上方蓝字关注“汪宇杰博客”导语最近在学习 Azure 的命令行玩法&#xff0c;发现官方有不止一种命令行工具&#xff0c;容易对新手产生混淆&#xff0c;本文将介绍各种工具都是干啥的&#xff0c;以及如何选择。目前&#xff0c;微软官方有3个Azure命令行工具&#xff0c;分…

揭秘鸿蒙生态背后的DevOps实践

&#xff08;图片来源于网络&#xff09;8月9日&#xff0c;华为发布了鸿蒙操作系统&#xff0c;在发布会上我们看到了鸿蒙系统的研发历程&#xff1a;2017年&#xff0c;鸿蒙内核1.0完成技术验证&#xff1b;2018年&#xff0c;鸿蒙内核2.0用于终端TEE&#xff1b;2019年&…

AT3557 Four Coloring 切比雪夫距离 + 四色构造

传送门 由于曼哈顿距离在图上显示的是一个棱形&#xff0c;并不是很好看&#xff0c;所以我们将其旋转454545&#xff0c;转换成切比雪夫距离&#xff0c;这样就变成了一个正方形&#xff0c;正方形内部的点距离都不超过ddd&#xff0c;此时可以将正方形内部的点看成一个整体&a…

SonarQube系列一、Linux安装与部署

来源&#xff1a;https://www.cnblogs.com/7tiny/p/11269774.html【前言】随着项目团队规模日益壮大&#xff0c;项目代码量也越来越多。且不说团队成员编码水平层次不齐&#xff0c;即便是老手&#xff0c;也难免因为代码量的增加和任务的繁重而忽略代码的质量&#xff0c;最终…

P2906 [USACO08OPEN]Cow Neighborhoods G 切比雪夫距离 + 并查集 + set

传送门 考虑将曼哈顿距离转换成切比雪夫距离&#xff0c;这样问题就变成了max(∣x1−x2∣,∣y1−y2∣)≤dmax(|x_1-x_2|,|y_1-y_2|)\le dmax(∣x1​−x2​∣,∣y1​−y2​∣)≤d&#xff0c;这个式子就很好看了&#xff0c;我们首先按照(x,y)(x,y)(x,y)排序&#xff0c;让后我…

2018-2019 ACM-ICPC, Asia Shenyang Regional Contest E. The Kouga Ninja Scrolls 切比雪夫距离 +线段树

传送门 将曼哈顿距离转换成切比雪夫距离&#xff0c;现在就是求max(∣x1−x2∣,∣y1−y2∣)max(|x_1-x_2|,|y_1-y_2|)max(∣x1​−x2​∣,∣y1​−y2​∣)&#xff0c;显然我们可以将x,yx,yx,y分开考虑&#xff0c;下面以xxx为例。 考虑一段区间内不同门派的最大值和最小值&am…

ASP.NET Core 框架本质学习

本文作为学习过程中的一个记录。学习文章地址&#xff1a;https://www.cnblogs.com/artech/p/inside-asp-net-core-framework.html一. ASP.NET Core 框架上的 Hello World程序public class Program{public static void Main()> new WebHostBuilder() .UseKestrel() …

基于C#实现的轻量级多线程队列

工作中我们经常会遇到一些一些功能需要实现造作日志&#xff0c;数据修改日志&#xff0c;对于这种业务需求如果我们以同步的方式实现&#xff0c;难免会影响到系统的性能。如下我列出集中解决方案。使用Thread异步处理。使用线程池或Task异步处理。以上两种方案确实能解决我们…

【活动】厦门.NET俱乐部 省上云开发者专场

十年磨一剑&#xff0c;厦门.NET俱乐部诚挚邀请您相约软件园二期创驿站&#xff0c;参加云重启|厦门.NET俱乐部省上云开发者专场。活动干货满满&#xff0c;更有精美礼品&#xff0c;厦门.NET俱乐部期待与您“厦门论剑”。详情请点击图片或直接阅读原文报名

腾讯物联TencentOS tiny上云初探

2017年中旬曾写过一篇关于物联网平台的文章《微软最完善&#xff0c;百度最“小气” 看微软阿里百度三大物联网云平台对比》。现在已经过去两年了&#xff0c;物联网的格局又发生了不少的变化。不过针对腾讯来说&#xff0c;其物联网平台发轫的时间绝不算晚&#xff0c;基本就是…

ASP.NET Core on K8S深入学习(3-2)DaemonSet与Job

本篇已加入《.NET Core on K8S学习实践系列文章索引》&#xff0c;可以点击查看更多容器化技术相关系列文章。上一篇《3-1 Deployment》中介绍了Deployment&#xff0c;它可以满足我们大部分时候的应用部署&#xff08;无状态服务类容器&#xff09;&#xff0c;但是针对一些特…

Asp.Net Core WebAPI+PostgreSQL部署在Docker中

PostgreSQL是一个功能强大的开源数据库系统。它支持了大多数的SQL:2008标准的数据类型&#xff0c;包括整型、数值值、布尔型、字节型、字符型、日期型、时间间隔型和时间型&#xff0c;它也支持存储二进制的大对像&#xff0c;包括图片、声音和视频。PostgreSQL对很多高级开发…