读取百度api存入csv

读取百度api存入csv

1、将获取到的json数据映射Java实体类如下

所用的依赖

<!--        Jackson--><dependency><groupId>com.fasterxml.jackson.core</groupId><artifactId>jackson-databind</artifactId><version>2.14.2</version></dependency>

  • //接收返回的百度api数据的总实体类
@Data
public class BaiduReturn {private int status;private String message;private String description;private Evaluation evaluation;private List<RoadTraffic> road_traffic;}

  • //拥堵数据
@Data
public class CongestionSection{private String congestion_distance;private String speed;private int status;private String congestion_trend;private String section_desc;
}

  • //拥堵状态
@Data
public class Evaluation {private int status;private String status_desc;}

  • //路况数据
@Data
public class RoadTraffic {private List<CongestionSection> congestion_sections;private String road_name;
}

  • /*** 将百度获取的json映射为对象* @param fileName* @return*/private static List<BaiduReturn> getBaiduReturn(String fileName) {try {List<String> nameList;List<BaiduReturn> resultList = new ArrayList<>();//获取道路数据nameList = getRoadName(fileName);for(int i = 0;i<nameList.size();i++){BaiduApi snCal = new BaiduApi();// 创建一个Map对象，用于存储请求参数Map params = new LinkedHashMap<String, String>();params.put("road_name",nameList.get(i));params.put("city", "成都市");//URL和AK都是可以在百度官网获取params.put("ak", AK);String result = snCal.requestGetAK(URL, params);ObjectMapper objectMapper = new ObjectMapper();// 使用 readValue 方法解析 JSON 字符串为 BaiduReturn 对象BaiduReturn baiduReturn = objectMapper.readValue(result, BaiduReturn.class);if (baiduReturn.getStatus() == 0) {resultList.add(baiduReturn);}}//将BaiduReturn对象返回用于写入return resultList;} catch (Exception e) {throw new RuntimeException(e);}}/*** 提取csv文件中的道路名称* @param fileName* @return List<String>*/private static List<String> getRoadName(String fileName) {try {BufferedReader reader = new BufferedReader(new FileReader(fileName));//换成你的文件名reader.readLine();//第一行信息，为标题信息，不用,如果需要，注释掉String line = null;String[] roadArray = null;List<String> roadList = new ArrayList<>();while((line=reader.readLine())!=null) {if (line.trim().isEmpty()) {continue; // 跳过空行}roadArray = line.split(",");//CSV格式文件为逗号分隔符文件，这里根据逗号切分roadList.add(roadArray[0]); //保存所有街道}return roadList;} catch (IOException e) {throw new RuntimeException(e);}}

2、将百度api对象写入csv

所用的依赖

        <!--        csv工具--><!-- https://mvnrepository.com/artifact/org.apache.commons/commons-csv --><dependency><groupId>org.apache.commons</groupId><artifactId>commons-csv</artifactId><version>1.9.0</version></dependency>

  •  /*** 将BaiduReturn对象写入csv文件* @param resultList* @param outputFileName*/private static void writeBaiduReturnToCsv(List<BaiduReturn> resultList, String outputFileName,boolean append) {try (BufferedWriter writer = new BufferedWriter(new FileWriter(outputFileName, append))) {// 如果是第一次写入，写入CSV文件的表头if (!append || new File(outputFileName).length() == 0) {writer.write("status,message,description,evaluation_status,evaluation_status_desc,");writer.write("road_name,congestion_distance,speed,congestion_status,");writer.write("congestion_trend,section_desc\n");}for (BaiduReturn baiduReturn : resultList) {writer.write(baiduReturn.getStatus() + ",");writer.write(baiduReturn.getMessage() + ",");writer.write(baiduReturn.getDescription() + ",");writer.write(baiduReturn.getEvaluation().getStatus() + ",");writer.write(baiduReturn.getEvaluation().getStatus_desc() + ",");for (RoadTraffic roadTraffic : baiduReturn.getRoad_traffic()) {writer.write(roadTraffic.getRoad_name() + ",");if (roadTraffic.getCongestion_sections() != null) {for (CongestionSection congestionSection : roadTraffic.getCongestion_sections()) {writer.write(congestionSection.getCongestion_distance() + ",");writer.write(congestionSection.getSpeed() + ",");writer.write(congestionSection.getStatus() + ",");writer.write(congestionSection.getCongestion_trend() + ",");writer.write(congestionSection.getSection_desc() + ",");}}writer.newLine(); // 每个RoadTraffic对象写完后换行}}} catch (IOException e) {throw new RuntimeException(e);}}

package xyz.zzj.traffic_zzj.service;import com.fasterxml.jackson.databind.ObjectMapper;
import org.springframework.scheduling.annotation.EnableScheduling;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Component;
import xyz.zzj.traffic_zzj.dao.domain.BaiduReturn;
import xyz.zzj.traffic_zzj.dao.domain.CongestionSection;
import xyz.zzj.traffic_zzj.dao.domain.RoadTraffic;
import xyz.zzj.traffic_zzj.utils.BaiduApi;import java.io.*;
import java.time.Instant;
import java.time.LocalDateTime;
import java.time.ZoneId;
import java.time.format.DateTimeFormatter;
import java.util.ArrayList;
import java.util.LinkedHashMap;
import java.util.List;
import java.util.Map;import static xyz.zzj.traffic_zzj.utils.BaiduApi.AK;
import static xyz.zzj.traffic_zzj.utils.BaiduApi.URL;/*** @BelongsPackage: xyz.zzj.traffic_zzj.service* @ClassName: BaiduCsv* @Author: zengz* @CreateTime: 2024/12/26 21:20* @Description: 将数据读取并写入csv文件* @Version: 1.0*/
@EnableScheduling
@Component
public class BaiduCsv {
//    public static void main(String[] args) throws Exception {@Scheduled(cron = "0 0/30 * * * ?")public void scheduledTask(){String fileName = "src\\main\\resources\\static\\cd_road_name.csv";String outputFileName = "src\\main\\resources\\static\\cd_road_traffic.csv";List<BaiduReturn> resultList = getBaiduReturn(fileName);writeBaiduReturnToCsv(resultList, outputFileName,true);}/*** 将百度获取的json映射为对象* @param fileName* @return*/private static List<BaiduReturn> getBaiduReturn(String fileName) {try {List<String> nameList;List<BaiduReturn> resultList = new ArrayList<>();nameList = getRoadName(fileName);for(int i = 0;i<nameList.size();i++){BaiduApi snCal = new BaiduApi();// 创建一个Map对象，用于存储请求参数Map params = new LinkedHashMap<String, String>();params.put("road_name",nameList.get(i));params.put("city", "成都市");params.put("ak", AK);String result = snCal.requestGetAK(URL, params);ObjectMapper objectMapper = new ObjectMapper();// 使用 readValue 方法解析 JSON 字符串为 BaiduReturn 对象BaiduReturn baiduReturn = objectMapper.readValue(result, BaiduReturn.class);if (baiduReturn.getStatus() == 0) {resultList.add(baiduReturn);}}//将BaiduReturn对象返回用于写入return resultList;} catch (Exception e) {throw new RuntimeException(e);}}/*** 提取csv文件中的道路名称* @param fileName* @return List<String>*/private static List<String> getRoadName(String fileName) {try {BufferedReader reader = new BufferedReader(new FileReader(fileName));//换成你的文件名reader.readLine();//第一行信息，为标题信息，不用,如果需要，注释掉String line = null;String[] roadArray = null;List<String> roadList = new ArrayList<>();while((line=reader.readLine())!=null) {if (line.trim().isEmpty()) {continue; // 跳过空行}roadArray = line.split(",");//CSV格式文件为逗号分隔符文件，这里根据逗号切分roadList.add(roadArray[0]); //保存所有街道}return roadList;} catch (IOException e) {throw new RuntimeException(e);}}/*** 将BaiduReturn对象写入csv文件* @param resultList* @param outputFileName*/private static void writeBaiduReturnToCsv(List<BaiduReturn> resultList, String outputFileName,boolean append) {try (BufferedWriter writer = new BufferedWriter(new FileWriter(outputFileName, append))) {// 如果是第一次写入，写入CSV文件的表头if (!append || new File(outputFileName).length() == 0) {writer.write("status,message,description,evaluation_status,evaluation_status_desc,");writer.write("road_name,congestion_distance,speed,congestion_status,");writer.write("congestion_trend,section_desc,createTime\n");}for (BaiduReturn baiduReturn : resultList) {writer.write(baiduReturn.getStatus() + ",");writer.write(baiduReturn.getMessage() + ",");writer.write(baiduReturn.getDescription() + ",");writer.write(baiduReturn.getEvaluation().getStatus() + ",");writer.write(baiduReturn.getEvaluation().getStatus_desc() + ",");for (RoadTraffic roadTraffic : baiduReturn.getRoad_traffic()) {writer.write(roadTraffic.getRoad_name() + ",");if (roadTraffic.getCongestion_sections() != null) {for (CongestionSection congestionSection : roadTraffic.getCongestion_sections()) {writer.write(congestionSection.getCongestion_distance() + ",");writer.write(congestionSection.getSpeed() + ",");writer.write(congestionSection.getStatus() + ",");writer.write(congestionSection.getCongestion_trend() + ",");writer.write(congestionSection.getSection_desc() + ",");}}else {writer.write("null" + ",");writer.write("null" + ",");writer.write("null" + ",");writer.write("null" + ",");writer.write("null" + ",");}// 获取当前时间戳long timestamp = System.currentTimeMillis();// 将时间戳转换为Instant对象Instant instant = Instant.ofEpochMilli(timestamp);// 转换为本地时间，指定时区LocalDateTime localDateTime = LocalDateTime.ofInstant(instant, ZoneId.systemDefault());// 定义日期时间格式DateTimeFormatter formatter = DateTimeFormatter.ofPattern("yyyy年MM月dd日 HH:mm:ss");// 格式化日期时间String formattedDateTime = localDateTime.format(formatter);writer.write(formattedDateTime+ ",");writer.newLine(); // 每个RoadTraffic对象写完后换行}}} catch (IOException e) {throw new RuntimeException(e);}}
}

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

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

相关文章

【数据结构与算法】排序算法(下)——计数排序与排序总结

【数据结构与算法】排序算法(下)——计数排序与排序总结

写在前面 书接上文&#xff1a;【数据结构与算法】排序算法(中)——交换排序之快速排序 文章主要讲解计数排序的细节与分析源码。之后进行四大排序的总结。 文章目录 写在前面一、计数排序(非比较排序)代码的实现&#xff1a; 二、排序总结 2.1、稳定性 3.2、排序算法复杂度及…
阅读更多...
Multi移动端开发

Multi移动端开发

Multi移动端开发 安装环境 安装功能 VS2022安装 【ASP.NET和Web开发】、【.NET Multi-platform App UI开发】、【.NET桌面开发】 配置程序源 【工具】–>【选项】–>【NuGet包管理器】–>【程序包源】&#xff0c;添加如下&#xff1a; 名称&#xff1a;MES_APP 源&…
阅读更多...
若依plus apifox导入接口显示为空

若依plus apifox导入接口显示为空

项目已经正常启动 访问接口有些没问题&#xff0c;有些有问题 其他模块都可以正常导入 解决&#xff1a;
阅读更多...
音视频入门基础：AAC专题（13）——FFmpeg源码中，获取ADTS格式的AAC裸流音频信息的实现

音视频入门基础：AAC专题（13）——FFmpeg源码中，获取ADTS格式的AAC裸流音频信息的实现

音视频入门基础&#xff1a;AAC专题系列文章&#xff1a; 音视频入门基础&#xff1a;AAC专题&#xff08;1&#xff09;——AAC官方文档下载 音视频入门基础&#xff1a;AAC专题&#xff08;2&#xff09;——使用FFmpeg命令生成AAC裸流文件 音视频入门基础&#xff1a;AAC…
阅读更多...
英文学术会议海报poster模板【可编辑】

英文学术会议海报poster模板【可编辑】

英文学术会议海报poster模板【可编辑】 下载链接&#xff1a;学术会议海报poster模板【可编辑】 横版海报 竖版海报 下载链接&#xff1a;学术会议海报poster模板【可编辑】 提供了一套学术海报的PPT模板&#xff0c;适用于学术会议、研讨会等场合。 竖版&#xff0c;包含11…
阅读更多...
机器学习之KNN算法预测数据和数据可视化

机器学习之KNN算法预测数据和数据可视化

机器学习及KNN算法 目录 机器学习及KNN算法机器学习基本概念概念理解步骤为什么要学习机器学习需要准备的库 KNN算法概念算法导入常用距离公式算法优缺点优点&#xff1a;缺点︰ 数据可视化二维界面三维界面 KNeighborsClassifier 和KNeighborsRegressor理解查看KNeighborsRegr…
阅读更多...
Jmeter自学【8】- 使用JMeter模拟设备通过MQTT发送数据

Jmeter自学【8】- 使用JMeter模拟设备通过MQTT发送数据

今天使用jmeter推送数据到MQTT&#xff0c;给大家分享一下操作流程。 一、安装JMeter 参考文档&#xff1a;Jmeter自学【1】- Jmeter安装、配置 二、安装MQTT插件 1、下载插件 我的Jmeter版本是5.6.3&#xff0c;用到的插件是&#xff1a;mqtt-xmeter-2.0.2-jar-with-depe…
阅读更多...
若依框架中的上传图片后如何实现回显到页面的

若依框架中的上传图片后如何实现回显到页面的

在日常开发中&#xff0c;总会遇到上传文件、图片等功能&#xff0c;然后本地开发的话&#xff0c;又没有像OSS、七牛等网络存储&#xff0c;这个时候通常将文件上传到本地&#xff0c;那么上传之后拿到的是本地的路径&#xff0c;存储到数据库中&#xff0c;查询的时候如何将本…
阅读更多...
Linux 文件 I/O 基础

Linux 文件 I/O 基础

目录 前言 一、文件描述符&#xff08;File Descriptor&#xff09; 二、打开文件&#xff08;open 函数&#xff09; 三、读取文件&#xff08;read 函数&#xff09; 四、写入文件&#xff08;write 函数&#xff09; 五、关闭文件&#xff08;close 函数&#xff09; …
阅读更多...
【CSS in Depth 2 精译_091】15.4：让 CSS 高度值过渡到自动高度 + 15.5：自定义属性的过渡设置（全新）+ 15.6：本章小结

【CSS in Depth 2 精译_091】15.4：让 CSS 高度值过渡到自动高度 + 15.5：自定义属性的过渡设置（全新）+ 15.6：本章小结

当前内容所在位置&#xff08;可进入专栏查看其他译好的章节内容&#xff09; 第五部分 添加动效 ✔️【第 15 章 过渡】 ✔️ 15.1 状态间的由此及彼15.2 定时函数 15.2.1 定制贝塞尔曲线15.2.2 阶跃 15.3 非动画属性 15.3.1 不可添加动画效果的属性15.3.2 淡入与淡出 15.4 过…
阅读更多...
路由器的原理

路由器的原理

✍作者&#xff1a;柒烨带你飞 &#x1f4aa;格言&#xff1a;生活的情况越艰难&#xff0c;我越感到自己更坚强&#xff1b;我这个人走得很慢&#xff0c;但我从不后退。 &#x1f4dc;系列专栏&#xff1a;网路安全入门系列 目录 路由器的原理一&#xff0c;路由器基础及相关…
阅读更多...
mui框架开发的手机app--餐饮类【无后端】

mui框架开发的手机app--餐饮类【无后端】

点击获取源码
阅读更多...
spring专题笔记（七）：spring如何引入外部属性文件？spring在xml配置bean时如何引入外部的properties属性文件内容？

spring专题笔记（七）：spring如何引入外部属性文件？spring在xml配置bean时如何引入外部的properties属性文件内容？

目录 1、spring在xml配置bean时引入外部的properties属性文件内容作用是什么&#xff1f; 2、引入配置文件步骤 2.1、首先创建一个java类MyDataSource&#xff0c;主要包含四个属性。 2.2、准备一个myDataConfig.properties属性文件&#xff0c;里面配置MyDataSource类中需…
阅读更多...
梳理你的思路(从OOP到架构设计)_认识框架(Framework) 01

梳理你的思路(从OOP到架构设计)_认识框架(Framework) 01

目录 1、 是框架的核心要素​编辑&i> 范例1&#xff1a; 范例2&#xff1a; 范例3&#xff1a; 1、 <E&I>是框架的核心要素 在特定领域(Domain)里&#xff0c;将EIT造形的<E&I>部份有意义地组合起来&#xff0c;就成为框架(Framework)了。基本…
阅读更多...
邮件白名单是什么？

邮件白名单是什么？

邮件白名单是一种电子邮件过滤规则&#xff0c;用于指定哪些发件人、域名或IP地址的邮件被允许通过过滤系统&#xff0c;不受任何限制地进入收件人的邮箱。与黑名单&#xff08;用于阻止特定发件人的邮件&#xff09;相反&#xff0c;白名单确保了来自受信任来源的邮件能够畅通…
阅读更多...
Maven项目中不修改 pom.xml 状况下直接运行OpenRewrite的配方

Maven项目中不修改 pom.xml 状况下直接运行OpenRewrite的配方

在Java 的Maven项目中&#xff0c;可以在pom.xml 中配置插件用来运行OpenRewrite的Recipe&#xff0c;但是有一些场景是希望不修改pom.xml 文件就可以运行Recipe&#xff0c;比如&#xff1a; 因为不需要经常运行 OpenRewrite&#xff0c;所以不想在pom.xml 加入不常使用的插件…
阅读更多...
JVM实战—2.JVM内存设置与对象分配流转

JVM实战—2.JVM内存设置与对象分配流转

大纲 1.JVM内存划分的原理细节 2.对象在JVM内存中如何分配如何流转 3.部署线上系统时如何设置JVM内存大小 4.如何设置JVM堆内存大小 5.如何设置JVM栈内存与永久代大小 6.问题汇总 1.JVM内存划分的原理细节 (1)背景引入 (2)大部分对象的存活周期都是极短的 (3)少数对象…
阅读更多...
kong网关使用pre-function插件，改写接口的返回数据

kong网关使用pre-function插件，改写接口的返回数据

一、背景 kong作为api网关&#xff0c;除了反向代理后端服务外&#xff0c;还可对接口进行预处理。 比如本文提及的一个小功能&#xff0c;根据http header某个字段的值&#xff0c;等于多少的时候&#xff0c;返回一个固定的报文。 使用到的kong插件是pre-function。 除了上…
阅读更多...
计算机网络：IP地址相关知识总结

计算机网络：IP地址相关知识总结

目录 一、IP地址的表现形式 1.1 十进制表示形式 1.2 二进制表示形式 1.3 转换示例介绍 二、IP地址的组成 2.1 网络ID 2.2 主机ID 2.3 示例 三、IP地址的分类 3.1 A类地址 3.2 B类地址 3.3 C类地址 3.4 D类地址 3.5 E类地址 四、常见的特殊IP地址 五、IP地址二进…
阅读更多...
群晖Cloud Sync一键同步让数据管理变得简单

群晖Cloud Sync一键同步让数据管理变得简单

前言&#xff1a;在这个数字化爆炸的时代&#xff0c;数据管理和备份已经变得不可或缺。无论是个人用户还是企业&#xff0c;都需要一种既高效又可靠的方式来管理和备份分散在各种设备和云存储中的文件。而群晖的 **Cloud Sync** 套件正是为了解决这个问题而生。 Cloud Sync 是…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023