本篇内容介绍了“计算最大连续活跃天的方法步骤”的有关知识，在实际案例的操作过程中，不少人都会遇到这样的困境，接下来就让小编带领大家学习一下如何处理这些情况吧！希望大家仔细阅读，能够学有所成！

本次我们就先讲述一下最大连续活跃天数的第二种解法，然后再讲述另一常见面试SQL题目。

这一方法就是利用row_number给每一行生成一个连续的序号，这样，在连续活跃的时间段，就有了一个对照值，利用日期和行号这两者就可以得到一个差值，在连续活跃的时段内，其差值是相同的，那么我们按照这个差值进行分组就可以进一步计算本次连续活跃有多少天了。

SQL如下

WITHactiveAS(SELECT100UID,'2021-04-01'dtUNIONALLSELECT101UID,'2021-04-01'dtUNIONALLSELECT102UID,'2021-04-01'dtUNIONALLSELECT103UID,'2021-04-01'dtUNIONALLSELECT100UID,'2021-04-02'dtUNIONALLSELECT101UID,'2021-04-02'dtUNIONALLSELECT102UID,'2021-04-02'dtUNIONALLSELECT103UID,'2021-04-02'dtUNIONALLSELECT104UID,'2021-04-02'dtUNIONALLSELECT100UID,'2021-04-03'dtUNIONALLSELECT104UID,'2021-04-03'dtUNIONALLSELECT101UID,'2021-04-04'dtUNIONALLSELECT102UID,'2021-04-04'dtUNIONALLSELECT103UID,'2021-04-04'dtUNIONALLSELECT104UID,'2021-04-04'dtUNIONALLSELECT105UID,'2021-04-04'dtUNIONALLSELECT102UID,'2021-04-03'dt)SELECTUID,max(days)daysFROM(SELECTdate_sub(dt,rn),UID,count(DISTINCTdt)daysFROM(SELECTUID,dt,row_number()over(PARTITIONBYUIDORDERBYdt)rnFROMactive)xGROUPBYdate_sub(dt,rn),UID)yGROUPBYUID

结果如下：

至此，连续活跃的问题就告一段落了。下面我们来看另一个常见问题：

2.行列转换

(1)某直播产品，直播记录表lives中有liveid(直播id)、invite_list(邀约名单，string，用户id以“，”分割)字段，直播观看记录表record中有uid(用户id)、liveid(直播id)、duration(观看时长)，试求出邀约名单中所有用户的观看时长

由于存在邀约用户未进房观看的问题，所以我们直接从观看记录中来取，不一定能将名单中所有用户包含进去，所以，我们需要以直播记录中的邀约名单为准。这就需要利用explode和lateral view来将这个string类型转换为行记录的形式。

仍然是使用with构造lives和record两个简单的临时表，详细SQL如下：

withlivesas(select100liveid,'A01,A02,A03,A04'invite_listunionallselect101liveid,'A05,A06,A07,A08'invite_list),recordas(select100liveid,'A01'uid,30durationunionallselect100liveid,'A02'uid,50durationunionallselect100liveid,'A03'uid,15durationunionallselect101liveid,'A07'uid,20durationunionallselect101liveid,'A08'uid,60duration)selectlist.liveid,list.ulist,if(record.durationisnull,0,record.duration)durationfrom(selectliveid,ulistfromliveslateralviewexplode(split(invite_list,','))uidasulist)listleftjoinrecordonlist.liveid=record.liveidandlist.ulist=record.uid

这里简单说明下：lateral view 是为原表调用explode函数，将一个array或者map的字段分解成多行并作为一个临时表，然后再与其他字段组合到一起。

(2)某APP用户访问页面记录record，含有字段uid(用户id)、pageid(页面id)，将每个用户的访问路径输出在一个字段中

前一道题目是列转行，这道题是行专列。利用collect_set可以将分组下面某个字段的所有记录聚合成一个列表，然后可以进一步使用concat_ws函数把array转为字符串，并用“>”将其连接起来。

WITHrecordas(SELECT100UID,'A01'pageidUNIONALLSELECT100UID,'A02'pageidUNIONALLSELECT100UID,'A03'pageidUNIONALLSELECT101UID,'A07'pageidUNIONALLSELECT101UID,'A08'pageid)SELECTUID,concat_ws('>',collect_list(pageid))pageFROMrecordGROUPBYUID

3.求留存

对于多数互联网公司来说，任何时候留存率都是重中之重。所以在数据分析的面试当中，求留存率的SQL题目出现的频率也是极高。

所谓“留存率”，通常是定义一个初始行为与一个后继行为，符合初始条件的用户量在经过N天之后，剩余的比例就是留存率。发散来讲，回访、复看等概念也与留存相类似。如：

某APP新注册用户表user，含有字段uid(用户id)、dt(注册日期)，活跃表active，有字段uid(用户id)，dt(活跃日期)，求每天新增用户的次日留存率、次2日留存率、次3日留存率……次7日留存率

此题目就是以新注册作为初始行为，活跃作为后继行为。显而易见地，我们可以将初始行为与后继行为做左连接，然后按注册日期进行聚合，求相应的新增用户和次N日留存人数。

WITHuseras(SELECT100UID,'2021-01-01'dtUNIONALLSELECT101UID,'2021-01-01'dtUNIONALLSELECT102UID,'2021-01-01'dtUNIONALLSELECT103UID,'2021-01-02'dtUNIONALLSELECT104UID,'2021-01-02'dtUNIONALLSELECT105UID,'2021-01-02'dtUNIONALLSELECT106UID,'2021-01-02'dt),activeas(select100UID,'2021-01-01'dtunionallselect100UID,'2021-01-02'dtunionallselect100UID,'2021-01-03'dtunionallselect100UID,'2021-01-05'dtunionallselect100UID,'2021-01-07'dtunionallselect101UID,'2021-01-01'dtunionallselect101UID,'2021-01-07'dtunionallselect102UID,'2021-01-01'dtunionallselect103UID,'2021-01-01'dtunionallselect103UID,'2021-01-02'dtunionallselect103UID,'2021-01-03'dtunionallselect103UID,'2021-01-05'dtunionallselect104UID,'2021-01-02'dtunionallselect104UID,'2021-01-03'dtunionallselect104UID,'2021-01-04'dtunionallselect105UID,'2021-01-02'dtunionallselect105UID,'2021-01-03'dtunionallselect105UID,'2021-01-04'dtunionallselect105UID,'2021-01-05'dtunionallselect105UID,'2021-01-07'dtunionallselect106UID,'2021-01-02'dtunionallselect106UID,'2021-01-04'dt)selectuser.dt,count(distinctuser.uid)new_user,count(distinctif(datediff(active.dt,user.dt)=1,active.uid,null))retain1,count(distinctif(datediff(active.dt,user.dt)=2,active.uid,null))retain2,count(distinctif(datediff(active.dt,user.dt)=3,active.uid,null))retain3,count(distinctif(datediff(active.dt,user.dt)=4,active.uid,null))retain4,count(distinctif(datediff(active.dt,user.dt)=5,active.uid,null))retain5,count(distinctif(datediff(active.dt,user.dt)=6,active.uid,null))retain6,count(distinctif(datediff(active.dt,user.dt)=7,active.uid,null))retain7fromuserleftjoinactiveonuser.uid=active.uidgroupbyuser.dt

其结果如下：

这种方法可能比较麻烦一些，得把要求的每一个留存指标都要单独写一个字段。若想省事儿，可以单独求出每日的新增数量，再将新增表与活跃表连接而求出每个注册日期在后续每天的活跃数量，然后将新增数量与活跃数量再进行关联，从而求得任意周期的留存。

“计算最大连续活跃天的方法步骤”的内容就介绍到这里了，感谢大家的阅读。如果想了解更多行业相关的知识可以关注亿速云网站，小编将为大家输出更多高质量的实用文章！