通过Node.js获取高德的省市区数据并插入数据库

通过Node.js获取高德的省市区数据并插入数据库

  • 1 创建秘钥
    • 1.1 登录高德地图开放平台
    • 1.2 创建应用
    • 1.3 绑定服务创建秘钥
  • 2 获取数据并插入
    • 2.1 创建数据库连接工具
    • 2.2 请求数据
    • 2.3 数据处理
    • 2.4 全部代码
  • 3 还可以打印文件到本地

1 创建秘钥

1.1 登录高德地图开放平台

打开开放平台地址

注册账号 或 申请账后

1.2 创建应用

在这里插入图片描述

1.3 绑定服务创建秘钥

在这里插入图片描述
在这里插入图片描述

2 获取数据并插入

将使用高德地图API https://restapi.amap.com/v3/config/district?parameters进行行政区域查询,API详细文档可看官方说明

2.1 创建数据库连接工具

const mysql = require('mysql');const pool = mysql.createPool({host: 'XXX',port: '3306',database: 'XXX',user: 'user',password: 'password',
});
function query(sql, data = {}) {return new Promise((resolve, reject) => {pool.getConnection(function (err1, connection) {if (err1) {reject(err1);}connection.query(sql, data, function (err2, rows) {connection.release();if (err2) {reject(err2);} else {resolve(rows);}});});});
}

2.2 请求数据

const requestUrl = "https://restapi.amap.com/v3/config/district"
const secretKey = "高德地图上的秘钥"
// 仅获取到区级const url = `${requestUrl}?keywords=中国&subdistrict=3&key=${secretKey}`let { data } = await axios.get(encodeURI(url))if (!data.districts ||data.districts.length !== 1 ||data.districts[0].name !== "中华人民共和国")throw Error("数据获取失败")

2.3 数据处理

for (const province of data.districts[0].districts) {// 排除香港、台湾、澳门。台湾、香港、澳门的数据具有一定的问题,台湾省下无具体市区(县)等行政单位,香港和澳门特别行政区仅有两级行政单位。if(["810000", "710000", "820000"].includes(province.adcode)) continue;let provinceData:Line = {address_code: province.adcode,address_name: province.name,parent_address_code: "0",create_time:new Date().getTime().toString(),}await sqlCommand('insert into t_address set ?', provinceData);for (const city of province.districts) {let cityData:Line = {address_code: city.adcode,address_name: city.name,parent_address_code: province.adcode,create_time:new Date().getTime().toString()}await sqlCommand('insert into t_address set ?', cityData);for (const area of city.districts) {let areaData:Line = {address_code: area.adcode,address_name: area.name,parent_address_code: city.adcode,create_time:new Date().getTime().toString()}await sqlCommand('insert into t_address set ?', areaData);}}console.log(`${province.name}数据插入完成`)
}

2.4 全部代码

import axios from "axios"
import mysql from "mysql"
export type Line = {address_code: stringaddress_name: stringparent_address_code: stringcreate_time: string
}
const requestUrl = "https://restapi.amap.com/v3/config/district"
const secretKey = "获取到的秘钥"
const pool = mysql.createPool({host: "XXX",port: "3306",database: "XXX",user: "user",password: "password",
});function sqlCommand(sql, data = {}) {return new Promise((resolve, reject) => {pool.getConnection(function (err1, connection) {if (err1) {reject(err1);}connection.query(sql, data, function (err2, rows) {connection.release();if (err2) {reject(err2);} else {resolve(rows);}});});});
}
async function main() {// 仅获取到:1.省级,2.市级,3.区级const url = `${requestUrl}?keywords=中国&subdistrict=3&key=${secretKey}`let { data } = await axios.get(encodeURI(url))if (!data.districts ||data.districts.length !== 1 ||data.districts[0].name !== "中华人民共和国")throw Error("数据获取失败")for (const province of data.districts[0].districts) {// 排除香港、台湾、澳门。台湾、香港、澳门的数据具有一定的问题,台湾省下无具体市区(县)等行政单位,香港和澳门特别行政区仅有两级行政单位。console.time(province.name)if(["810000", "710000", "820000"].includes(province.adcode)) continue;let provinceData:Line = {address_code: province.adcode,address_name: province.name,parent_address_code: "0",create_time:new Date().getTime().toString(),}await sqlCommand('insert into t_address set ?', provinceData);for (const city of province.districts) {let cityData:Line = {address_code: city.adcode,address_name: city.name,parent_address_code: province.adcode,create_time:new Date().getTime().toString()}await sqlCommand('insert into t_address set ?', cityData);for (const area of city.districts) {let areaData:Line = {address_code: area.adcode,address_name: area.name,parent_address_code: city.adcode,create_time:new Date().getTime().toString()}await sqlCommand('insert into t_address set ?', areaData);}}console.timeEnd(province.name)}console.log("所有数据处理完毕")
}
main()

3 还可以打印文件到本地

import axios from "axios"
import mysql from "mysql"
export type Line = {address_code: stringaddress_name: stringparent_address_code: stringcreate_time: string
}
const requestUrl = "https://restapi.amap.com/v3/config/district"
const secretKey = "获取到的秘钥"
const pool = mysql.createPool({host: "XXX",port: "3306",database: "XXX",user: "user",password: "password",
});
function sqlCommand(sql, data = {}) {return new Promise((resolve, reject) => {pool.getConnection(function (err1, connection) {if (err1) {reject(err1);}connection.query(sql, data, function (err2, rows) {connection.release();if (err2) {reject(err2);} else {resolve(rows);}});});});
}
// 打印JSON到根目录
function writeToJson(fileName: string, data: any) {if (!fs.existsSync(resolve(process.cwd(), "dist"))) {fs.mkdirSync(resolve(process.cwd(), "dist"));}const path = resolve(process.cwd(), "dist", fileName);return fs.writeFileSync(path, JSON.stringify(data));
}
async function main() {// 仅获取到:1.省级,2.市级,3.区级const url = `${requestUrl}?keywords=中国&subdistrict=3&key=${secretKey}`;let { data } = await axios.get(encodeURI(url));const datas = [];if (!data.districts ||data.districts.length !== 1 ||data.districts[0].name !== "中华人民共和国")throw Error("数据获取失败");for (const province of data.districts[0].districts) {// 排除香港、台湾、澳门。台湾、香港、澳门的数据具有一定的问题,台湾省下无具体市区(县)等行政单位,香港和澳门特别行政区仅有两级行政单位。console.time(province.name);if (["810000", "710000", "820000"].includes(province.adcode)) continue;let provinceData: Line = {address_code: province.adcode,address_name: province.name,parent_address_code: "0",create_time: new Date().getTime().toString(),};await sqlCommand("insert into t_address set ?", provinceData);datas.push(provinceData);for (const city of province.districts) {let cityData: Line = {address_code: city.adcode,address_name: city.name,parent_address_code: province.adcode,create_time: new Date().getTime().toString(),};await sqlCommand("insert into t_address set ?", cityData);datas.push(cityData);for (const area of city.districts) {let areaData: Line = {address_code: area.adcode,address_name: area.name,parent_address_code: city.adcode,create_time: new Date().getTime().toString(),};await sqlCommand("insert into t_address set ?", areaData);datas.push(areaData);}}console.timeEnd(province.name);}writeToJson("mapData", datas);console.log("所有数据处理完毕");
}
main();

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

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

相关文章

11面向对象编程例子 月饼可以访问模子 模子不能访问月饼

类就好比是一个模子,然后各种对象就是月饼,印的月饼太多了,于是找不到月饼了,但是月饼只有一个模子,所以可以向上找到自己的模子 先上代码: class Person:age 0def shilifangfa(self):print(self)print(…

多列等高实现

预期效果 多列等高,左右两列高度自适应且一样,分别设置不同背景色效果预览: 分别由6种方法实现 1、使用padding + margin + overflow 实现多列等高效果,具有良好的兼容性; 2、border实现多列等高,左边框宽度为200px,左列浮动,伪元素清除浮动; 3、父元素线性渐变背景色…

基于web的酒店客房管理系统

目录 前言 一、技术栈 二、系统功能介绍 用户信息管理 会员信息管理 客房信息管理 收藏客房管理 用户入住管理 客房清扫管理 三、核心代码 1、登录模块 2、文件上传模块 3、代码封装 前言 随着信息技术在管理上越来越深入而广泛的应用,管理信息系统的实施…

【数据结构】算法效率的度量方法

🦄个人主页:修修修也 🎏所属专栏:数据结构 ⚙️操作环境:Visual Studio 2022 目录 🎏事后统计方法 🎏事前分析估算方法 🎏函数的渐进式增长 结语 在上篇文章中我们提到了算法的设计要求中我们要尽量满足时间效率高…

Tomcat和HPPT协议

1.介绍 1.Java EE 规范 JavaEE(java Enterprise Edition):java企业版 JavaEE 规范是很多的java开发技术的总称。这些技术规范都是沿用自J2EE的。一共包括了13个技术规范 2.WEB概述 WEB在计算机领域中代表的是网络 像我们之前所用的WWW&…

Excel往Word复制表格时删除空格

1.背景 在编写文档,经常需要从Excel往Word里复制表格 但是复制过去的表格前面会出现空格(缩进) 再WPS中试了很多方法,终于摆脱了挨个删除的困扰 2. WPS排版中删除 选择表格菜单栏-选在【开始】-【排版】选择【更多段落处理】-【段…

ai语音机器人OKCC的空号检测

一、空号检测模块介绍 空号检测的原理:空号检测是利用现代通信技术和互联网技术结合而成,采用批量拨电话号码的方式,过滤空号、停机、无效号码。业内又称空号筛选、空号过滤。空号检测技术的成果是去除号码中的无效号码,包括…

二、BurpSuite Proxy代理

一、配置与基础 配置:配置代理的端口 Forward:将拦截的请求正常发往服务器 Drop:直接将请求丢弃 intercept:开启后才能进行请求拦截 Open brower:在2021版本之后,点击该选项即可开启BurpSuite自带的浏览器…

2023版 STM32实战9 RTC实时时钟/闹钟

RTC简介 实时时钟是一个独立的定时器。RTC模块拥有一组连续计数的计数器,在相应软件配置下,可提供时钟日历的功能。修改计数器的值可以重新设置系统当前的时间和日期。 注意事项 -1- 要手动配置中断寄存器 -2- 需要等待写操作完成 -3- 时钟闹钟中段…

webpack不同环境下使用CSS分离插件mini-css-extract-plugin

1.背景描述 使用mini-css-extract-plugin插件来打包css文件(从css文件中提取css代码到单独的文件中,对css代码进行代码压缩等)。 本次采用三个配置文件: 公共配置文件:webpack.common.jsdev开发环境配置文件&#x…

视频编解码(七)之FOURCC和YUV关系简介

FOURCC是4字节代码,是一个codec中对压缩格式、颜色、像素格式等的标识。按一个字节8bit,FOURCC通常占4字节32bit。 FOURCC is short for “four character code” - an identifier for a video codec, compression format, color or pixel format used i…

react–antd 实现TreeSelect树形选择组件,实现点开一层调一次接口

效果图: 注意: 当选择“否”,开始调接口,不要把点击调接口写在TreeSelect组件上,这样会导致问题出现,没有层级了 部分代码:

MYSQL的事务原理

事务基础 事务概念 事务是一组操作的集合,它是一个不可分割的工作单位,事务会把所有的操作作为一个整体一起向系统提交或撤销操作请求,即这些操作要么同时成功,要么同时失败。 事务特性 原子性(Atomicity&#xff09…

实际开发中常用的Git操作

文章目录 前言基础知识集中式版本控制 - SVN分布式版本控制 - Git常用的Linux命令Git工作区域 Git 常用命令获取Git仓库添加/提交/推送/删除/回退文件查看信息Git分支Git标签Gitk:一个排查Git问题的工具 前言 git是用C语言开发的,以追求最高的性能。git…

mysql面试题44:MySQL数据库cpu飙升的话,要怎么处理?

该文章专注于面试,面试只要回答关键点即可,不需要对框架有非常深入的回答,如果你想应付面试,是足够了,抓住关键点 面试官:MySQL数据库cpu飙升的话,要怎么处理呢? 当MySQL数据库的CPU使用率飙升时,可能表示数据库负载过重或存在性能问题。以下是处理MySQL数据库CPU飙…

TongWeb8的启、停功能场景说明

前言: TongWeb8除了正常的startserver.sh、stopserver.sh启停功能外,还有开机自启、宕机重启、定时重启、内存溢出重启、禁止非法退出等功能,以适应不同场景,保证应用系统的可靠性。 场景一:开机自启 前提条件&#…

Linux友人帐之网络配置与网络传输

一、相关概念 IP地址 IP地址(Internet Protocol Address)是用于唯一标识和定位计算机网络中设备(如计算机、服务器、路由器等)的数字标识。在互联网中,IP地址是用来进行网络通信和数据传输的基础。 IP地址由32位或128…

Kotlin函数作为参数指向不同逻辑

Kotlin函数作为参数指向不同逻辑 fun sum(): (Int, Int) -> Int {return { a, b -> (a b) } }fun multiplication(): (Int, Int) -> Int {return { a, b -> (a * b) } }fun main(args: Array<String>) {var math: (Int, Int) -> Intmath sum()println(m…

正点原子嵌入式linux驱动开发——Linux内核顶层Makefile详解

之前的几篇学习笔记重点讲解了如何移植uboot到STM32MP157开发板上&#xff0c;从本章就开始学习如何移植Linux内核。 同uboot一样&#xff0c;在具体移植之前&#xff0c;先来学习一下Linux内核的顶层Makefile文件&#xff0c;因为顶层 Makefile控制着Linux内核的编译流程。 L…

JRebel在IDEA中实现热部署 (JRebel实用版)

JRebel简介&#xff1a; JRebel是与应用程序服务器集成的JVM Java代理&#xff0c;可使用现有的类加载器重新加载类。只有更改的类会重新编译并立即重新加载到正在运行的应用程序中&#xff0c;JRebel特别不依赖任何IDE或开发工具&#xff08;除编译器外&#xff09;。但是&…