AirNet 是一个环境污染物数据分析与预测平台，采用微服务架构，基于 Spring Cloud (Finchley.SR2) 开发，监测数据来自上海市环境监测中心。
| 服务 | 端口 | 描述 |
|---|---|---|
| spring-cloud-consul | 8500 | 服务注册中心 |
| airnet-config-service | 8888 | 服务配置中心 |
| airnet-zuul-gateway | 9000 | 服务网关 |
| airnet-main-service | 8080 | 前端展示服务(未完全前后端分离) |
| airnet-data-service | 8081 | 数据服务(包括污染物数据与用户数据) |
| airnet-mail-service | 8082 | 邮件服务 |
| airnet-export-service | 8083 | 数据导出服务 |
| airnet-forecast-service | 8084 | PM2.5 预测服务(Flask&Keras) |
| airnet-api-service | 8085 | API 服务 |
主要功能包括数据可视化、空气质量排行、PM2.5 预测、污染物预警、历史数据导出、API(注：未登陆用户仅可使用部分数据可视化与部分空气质量排行功能)、后台管理。
首页展示采用百度地图，监测站详细数据来自本地污染物数据库，实时温度、风向与空气污染扩散条件数据来自和风天气 API，PM2.5 浓度一周趋势采用本地数据的 24 小时均值。
由于首页数据都是热点数据（首页内未做个性化），因此全部采用 Redis 作为缓存，默认半小时失效。
前三项可视化来自第三方，其余基于 Echarts 实现本地污染物数据可视化分析。
- 上海市高空气流图
- 全国空气质量指数(AQI)地图
- 全球污染物分布图
- 标准折线图
- 标准散点图
- 标准饼图
- 标准雷达图
- 标准漏斗图
- 南丁格尔玫瑰图
基于 Redis Zset 实现，默认一小时失效，其中全国空气质量实时排行数据来自腾讯天气 API。
- 上海市空气质量实时 / 历史排行
- 全国空气质量实时排行
上海市 PM2.5 浓度预测基于 Flask 与 Keras，后两项数据来自南京大学国际地球系统科学研究所区域空气质量预报系统（JAirFS）。
- 上海市PM2.5浓度预测
- 全国空气质量预报地图
- 长三角空气质量预报地图
采用异步方式处理模型训练请求，Spring Cloud 端会将用户的训练请求发至 Kafka，Flask 端从 Kafka 中拉出请求并训练模型完成预测。
通过 Spring 的 @Scheduled 注解实现定时任务，若监测站的最新一条数据超过用户设置的预警阈值，则会发送站内信与邮件通知用户。
- 站内信通知
- 邮件通知
- 支持 Excel 导出
只有注册用户在 “API 说明” 页面中主动申请 API Key 并经过管理员同意下发 Key 后，用户才可使用 API Key 调用 API。AirNet API 提供以下三个接口，所有接口对于不同的用户都实现了可自定义化的限流策略（包括 QPS 限制与每月最多请求次数限制）。
- 历史 / 实时污染物数据 API
- 历史 / 实时空气质量排行 API
- 上海市 PM2.5 预测数据 API
URL：
api/v1/history?site={site}&pollutant={pollutant}&start={start_time}&end={end_time}&key={api_key}
参数含义如下：
| URL/参数 | 含义 |
|---|---|
| site | 监测点，为拼音代号，如jingan、hongkou |
| pollutant | 污染物，如so2、pm25，当为all时将返回全部污染物数据 |
| start | 开始时间，如2018-01-01 01:00:00 |
| end | 结束时间，如2018-01-01 01:00:00 |
| key | API Key |
返回 JSON 字段含义如下：
| 字段 | 内容 |
|---|---|
| site | 监测点，如jingan、yangpusipiao,pudongxinqu等 |
| time | 污染物监测时间 |
| city | 监测点所属城市 |
| aqi | 空气质量指数(AQI)，即Air Quality Index，是定量描述空气质量状况的无纲量指数 |
| level | 空气质量指数类别，有“优、良、轻度污染、中度污染、重度污染、严重污染”6类 |
| primaryPollutant | 首要污染物 |
| pm25 | 颗粒物（粒径小于等于2.5μm）1小时平均 |
| pm10 | 颗粒物（粒径小于等于10μm）1小时平均 |
| co | 一氧化碳1小时平均 |
| no2 | 二氧化氮1小时平均 |
| oZone | 臭氧1小时平均 |
| so2 | 二氧化硫1小时平均 |
# 示例
api/v1/history?site=jingan&pollutant=all&start=2019-03-15 20:00:00&end=2019-03-16 00:00:00&key=FBC2FD19931DE2665E64F7F1659E0075
# 返回JSON
{
"code": 0,
"msg": "success",
"data": {
"name": "all pollutant",
"result": [
{
"no2": "86",
"site": "静安监测站",
"pm25": "37",
"city": "上海",
"level": "良",
"so2": "9",
"aqi": 73,
"pm10": "96",
"primaryPollutant": "PM10",
"time": "2019-03-15 20:00:00",
"co": "0.9",
"oZone": "68"
},
...
{
"no2": "42",
"site": "静安监测站",
"pm25": "23",
"city": "上海",
"level": "良",
"so2": "7",
"aqi": 59,
"pm10": "67",
"primaryPollutant": "PM10",
"time": "2019-03-16 00:00:00",
"co": "0.8",
"oZone": "82"
}
]
}
}
URL：
api/v1/rank?area={area}&time={time}&order={order}}&key={api_key}
参数含义如下：
| URL/参数 | 含义 |
|---|---|
| area | 地区，目前仅支持sh(上海地区)、cn(全国) |
| pollutant | 污染物，如so2、pm25，当为all时将返回全部污染物数据 |
| time | 时间，如2019-01-01 01:00:00 |
| order | 排行顺序，如default顺序、reverse逆序 |
| key | API Key |
# 示例
/api/v1/rank?area=cn&time=2019-03-16 12:00:00&order=reverse&key=FBC2FD19931DE2665E64F7F1659E0075
# 返回JSON
{
"code": 0,
"msg": "success",
"data": {
"name": "air quality rank",
"result": [
{
"aqi": 245,
"level": "重度污染",
"pm25": "194",
"time": "2019-03-16 12:00:00",
"city": "五家渠"
},
...
{
"aqi": 18,
"level": "优",
"pm25": "4",
"time": "2019-03-16 12:00:00",
"city": "林芝地区"
}
]
}
}
URL：
api/v1/forecast?site={site}&start={start_time}&end={end_time}&key={api_key}
参数含义如下：
| URL/参数 | 含义 |
|---|---|
| site | 监测点，如jingan、yangpusipiao,pudongxinqu等 |
| start | 预测开始时间，如2018-01-01 01:00:00 |
| end | 预测结束时间，如2018-01-01 01:00:00 |
| key | API Key |
# 示例
api/v1/forecast?site=yangpusipiao&start=2019-12-01 12:00:00&end=2019-12-20 12:00:00&key=api_key=FBC2FD19931DE2665E64F7F1659E0075
# 返回JSON
TODO
考虑到分布式环境下采用 UUID 直接生成 Key 可能会导致 Key 重复的问题，最终的 Key 生成策略采用 Twitter Snowflake 算法生成唯一 ID， 再使用 HmacMD5 算法对 ID 加密生成 API Key。
基于 Zuul 与 Guava RateLimiter 实现，若用户的每秒请求次数超过 QPS 限制，或当月累计请求次数达到每月最大请求次数，则会触发限流。
- 用户管理
- API Key 管理
- 访问日志
基于 Spring AOP 与反射实现 Controller 层的统一日志打印，只需要在打印日志的方法前加上自定义的注解 @MyLogger 即可，日志内容包括：
- 请求时间
- Headers
- 请求 URL
- 用户 IP
- 用户 ID
- 用户名
- 类名
- 方法名
- 参数
- 返回类型
- FrontEnd: BootStrap / Echarts / FreeMarker
- BackEnd: Spring Cloud Config / Zuul / Ribbon / Feign / Hystrix / Spring Boot / Mybatis
- DB: MySQL / Redis
- MQ: Kafka
