智慧交通指标分析(各个区域车流量最多的10条道路与车流及对应卡口的车流)

各个区域各条道路的车流

SELECT area_id,road_id,COUNT(car) AS carNum1
FROM traffic.monitor_flow_action
GROUP BY area_id,road_id

各个区域top10车流的道路及车流

SELECT area_id,road_id,carNum1
FROM (
   SELECT area_id,road_id,carNum1,
       ROW_NUMBER() OVER (PARTITION BY area_id ORDER BY carNum1 DESC) AS rank
   FROM (
SELECT area_id,road_id,COUNT(car) AS carNum1
FROM traffic.monitor_flow_action
GROUP BY area_id,road_id
   ) A
) B
WHERE rank <= 10

各个区域各条道路各个卡口的车流

SELECT area_id,road_id,monitor_id,COUNT(car) AS carNum2
FROM traffic.monitor_flow_action GROUP BY area_id,road_id,monitor_id

各个区域top10车流的道路与车流及对应的各个卡口的车流

SELECT 1 as task_id, X.area_id,X.road_id,carNum1 as road_car_num,monitor_id,carNum2 as road_monitor_car_num
FROM (
   SELECT area_id,road_id,carNum1,rank
FROM (
   SELECT area_id,road_id,carNum1,
   ROW_NUMBER() OVER (PARTITION BY area_id ORDER BY carNum1 DESC) AS rank
FROM (
   SELECT area_id,road_id,COUNT(car) AS carNum1
FROM traffic.monitor_flow_action
GROUP BY area_id,road_id
) A
) B
WHERE rank <= 10
) X
INNER JOIN (
SELECT area_id,road_id,monitor_id,COUNT(car) AS carNum2
FROM traffic.monitor_flow_action
GROUP BY area_id,road_id,monitor_id
) Y
ON X.area_id = Y.area_id AND X.road_id = Y.road_id
ORDER BY area_id,road_car_num DESC,road_monitor_car_num DESC

object AreaTopNRoadFlowAnalyzer {
System.setProperty("hadoop.home.dir", "d://software/hadoop-2.9.2")
def main(args: Array[String]): Unit = {
val spark = SparkSession.builder()
.master("local")
.appName("AreaTopNRoadFlowAnalyzer")
.config("fs.defaultFS", "hdfs://hadoop-senior.test.com")
.config("spark.sql.warehouse.dir", "hdfs://hadoop-senior.test.com:8020/test")
.enableHiveSupport()
.getOrCreate()

spark.sparkContext.setLogLevel("WARN")

val sql =
"""SELECT """ + args(0) + """ as task_id, X.area_id,X.road_id,carNum1 as road_car_num,monitor_id,carNum2 as road_monitor_car_num FROM (
SELECT area_id,road_id,carNum1,rank
FROM (
SELECT area_id,road_id,carNum1,
ROW_NUMBER() OVER (PARTITION BY area_id ORDER BY carNum1 DESC) AS rank
FROM (
SELECT area_id,road_id,COUNT(car) AS carNum1
FROM traffic.monitor_flow_action
GROUP BY area_id,road_id
ORDER BY area_id,carNum1 DESC
) A
) B
WHERE rank <= 10
) X
INNER JOIN (
SELECT area_id,road_id,monitor_id,COUNT(car) AS carNum2
FROM traffic.monitor_flow_action GROUP BY area_id,road_id,monitor_id
) Y
ON X.area_id = Y.area_id AND X.road_id = Y.road_id
ORDER BY area_id,carNum1 DESC,carNum2 DESC"""

val df = spark.sql(sql)

df.write.format("jdbc")
.option("driver", "com.mysql.jdbc.Driver")
.option("url", "jdbc:mysql://hadoop-senior.test.com:3306/traffic1")
.option("dbtable", "topn_road_car_count")
.option("user", "root")
.option("password","123456")
.mode(SaveMode.Append)
.save()

spark.close()
}
}

智慧交通指标分析(各个区域车流量最多的10条道路与车流及对应卡口的车流)相关推荐

城市道路交通运行态势分析及决策系统设计
1. 概述与需求分析 1.1. 概述 1.1.1. 建设背景道路交通安全作为一个复杂的社会现象,既有其复杂的社会发展.文明程度.社会体制.社会风气和民族习惯等社会因素,也有法律.宣传.教育.管理.政 ...
Python分析《哈哈哈哈哈》47687条弹幕，看看大家都在说些啥！
图片来源:豆瓣最近由腾讯视频.爱奇艺联合出品综艺<哈哈哈哈哈>(又名五哈)话题不断,节目中由邓超.陈赫.鹿晗组成的兄弟旅行团,开启了一段由东到西穿越中国的真实旅行.作为首个双平台联播的超 ...
斑马线分析_中设设计集团：聚焦智慧交通助力城市发展｜集团设计和实施的“智慧斑马线”惊艳亮相南京市江北新区...
导读礼让斑马线是对生命的尊重,也是城市文明的标志-- 近日,由集团环智事业部智慧城市设计研究所设计并实施的"智慧斑马线"亮相江北新区.该技术通过LED灯光警示行人过马路走人行道 ...
智慧交通：基于PP-Vehicle的交通监控分析系统
智慧交通:基于PP-Vehicle的交通监控分析系统项目背景交通是兴国之要.强国之基.随着城市的快速发展.车辆和行人数量的日益增多,强依赖人力管控的传统交通治理模式在交通拥堵治理.信号调控.秩序改 ...
智慧交通落地关键：如何利用AI视频分析技术来改善交通？
随着城市交通流量的不断增长,道路的安全隐患也越来越多.交通更加拥堵,尤其是在城市地区.不仅仅是驾驶,而且在大城市停车对每个人来说都变得越来越具有挑战性. 结合智能物联网安防摄像头和AI视频分析的智能交 ...
城市智慧路灯综合管理平台、图监控、灯箱实时监控、策略管理、故障报警、灯具管理、数据统计、故障分析、开关灯记录分析、区域管理、分组管理、DIV+CSS布局设计、HTML/Bootstrp/jQuery
源码类别: 后台模板文件大小: 21.5 MB 源码内容:城市智慧路灯综合管理平台后台模板前端技术: HTML/CSS/Bootstrap/jQuery 模板语言: 简体中文 ...
闭环式数字孪生智慧交通管理系统平台应用及分析
2021年 8月份交通运输部和科学技术部印发的<关于科技创新驱动加快建设交通强国的意见>对交通强国建设提出了新的目标.为解决交通领域行车拥堵.停车难.行车乱等现象,保障人民的交通出行便利性 ...
智慧交通行业发展现状及竞争格局发展前景分析
1.行业发展现状 (1)市场规模稳步增长由于交通投资的逆周期调节属性,通过高速公路建设拉动经济增长的需求预计在短期内将持续存在,而智慧高速项目或者一般高速公路智慧交通系统建设又是"新基建& ...
未来十年智慧交通仍将持续引领城市建设高潮
深圳市人大常委经济工委委员.深圳市互联网金融商会会长向隽在接受采访时说"智慧交通是城市经济转型升级的时代契机,以雄安新区和粤港澳湾区为例,不难发现,二者都是以智慧交通创造新城市红利的典型,未 ...

智慧交通指标分析(各个区域车流量最多的10条道路与车流及对应卡口的车流)

智慧交通指标分析(各个区域车流量最多的10条道路与车流及对应卡口的车流)相关推荐

最新文章

热门文章