使用SQL实现车流量的计算的示例代码

本文主要介绍了使用SQL实现车流量的计算的示例代码,文中通过示例代码介绍的非常详细,具有一定的参考价值,感兴趣的小伙伴们可以参考一下

目录

  • 卡口转换率
  • 1、查出每个地区下每个路段下的车流量
  • 2、通过错位连接获取每辆车的行车记录
  • 3、获取行车过程中的车辆数
  • 4、获取每个卡口的总车辆数
  • 5、求出卡口之间的转换率

卡口转换率

将数据导入hive,通过SparkSql编写sql,实现不同业务的数据计算实现,主要讲述车辆卡口转换率,卡口转化率:主要计算不同卡口下车辆之间的流向,求出之间的转换率。

使用SQL实现车流量的计算的示例代码

1、查出每个地区下每个路段下的车流量
select
car,
monitor_id,
action_time,
ROW_NUMBER () OVER (PARTITION by car
ORDER by
action_time) as n1
FROM
traffic.hive_flow_action

此结果做为表1,方便后面错位连接使用

使用SQL实现车流量的计算的示例代码

2、通过错位连接获取每辆车的行车记录

通过表1的结果,与自身进行错位链接,并以车牌为分区,拼接经过卡口的过程

(select
t1.car,
t1.monitor_id,
concat(t1.monitor_id,
\”->\”,
t2.monitor_id) as way
from
(
select
car,
monitor_id,
action_time,
ROW_NUMBER () OVER (PARTITION by car
ORDER by
action_time) as n1
FROM
traffic.hive_flow_action) t1
left join (
select
car,
monitor_id,
action_time,
ROW_NUMBER () OVER (PARTITION by car
ORDER by
action_time) as n1
FROM
traffic.hive_flow_action) t2 on
t1.car = t2.car
and t1.n1 = t2.n1-1
where
t2.action_time is not null)

使用SQL实现车流量的计算的示例代码

获取到每辆车的一个行车记录,经过的卡口

3、获取行车过程中的车辆数

获取卡口1~卡口2,…等的车辆数有哪些,即拿上面的行车记录字段进行分区在进行统计

(select
s1.way,
COUNT(1) sumCar
from
–行车过程
(select
t1.car,
t1.monitor_id,
concat(t1.monitor_id,
\”->\”,
t2.monitor_id) as way
from
(
select
car,
monitor_id,
action_time,
ROW_NUMBER () OVER (PARTITION by car
ORDER by
action_time) as n1
FROM
traffic.hive_flow_action) t1
left join (
select
car,
monitor_id,
action_time,
ROW_NUMBER () OVER (PARTITION by car
ORDER by
action_time) as n1
FROM
traffic.hive_flow_action) t2 on
t1.car = t2.car
and t1.n1 = t2.n1-1
where
t2.action_time is not null)s1
group by way)

使用SQL实现车流量的计算的示例代码

4、获取每个卡口的总车辆数

获取每个卡口最初的车辆数,方便后面拿行车轨迹车辆数/总车辆数,得出卡口之间的转换率

select
monitor_id ,
COUNT(1) sumall
from
traffic.hive_flow_action
group by
monitor_id

使用SQL实现车流量的计算的示例代码

5、求出卡口之间的转换率
select
s2.way,
s2.sumCar / s3.sumall zhl
from
(
select
s1.way,
COUNT(1) sumCar
from
–行车过程
(
select
t1.car,
t1.monitor_id,
concat(t1.monitor_id,
\”->\”,
t2.monitor_id) as way
from
(
select
car,
monitor_id,
action_time,
ROW_NUMBER () OVER (PARTITION by car
ORDER by
action_time) as n1
FROM
traffic.hive_flow_action) t1
left join (
select
car,
monitor_id,
action_time,
ROW_NUMBER () OVER (PARTITION by car
ORDER by
action_time) as n1
FROM
traffic.hive_flow_action) t2 on
t1.car = t2.car
and t1.n1 = t2.n1-1
where
t2.action_time is not null)s1
group by
way)s2
left join
–每个卡口总车数
(
select
monitor_id ,
COUNT(1) sumall
from
traffic.hive_flow_action
group by
monitor_id) s3 on
split(s2.way,
\”->\”)[0]= s3.monitor_id

使用SQL实现车流量的计算的示例代码

到此这篇关于使用SQL实现车流量的计算的示例代码的文章就介绍到这了,更多相关SQL 车流量内容请搜索钦钦技术栈以前的文章或继续浏览下面的相关文章希望大家以后多多支持钦钦技术栈!

原文地址:https://blog.csdn.net/llAl_lAll/article/details/123134334

版权声明:本文(即:原文链接:https://www.qin1qin.com/catagory/20272/)内容由互联网用户自发投稿贡献,该文观点仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌抄袭侵权/违法违规的内容, 请发送邮件至 630367839@qq.com 举报,一经查实,本站将立刻删除。

(0)
上一篇 2022-09-10 11:47:32
下一篇 2022-09-10 11:47:42

软件定制开发公司

相关阅读

发表回复

登录后才能评论
通知:禁止投稿所有关于虚拟货币,币圈类相关文章,发现立即永久封锁账户ID!