使用 Cloud Insight SDK 监控北京空气质量！

如今愈来愈多的 App 都开始有广告了。特别是空气质量监测，和天气类的 App，广告仍是蛮多的，眼花缭乱，真是够了。

最近恰好在用一款系统监控工具 Cloud Insight，它提供的 SDK 能够把任一数据上传到他们那作展现。

灵机一动，做为一个程序员，本身动手丰衣足食，没什么不能解决的。

pip install -i http://pypi.oneapm.com/simple --upgrade oneapm-ci-sdk
这就安装好了。

简单用 ipython 看了看接口文档， gauge 是主要的发数据的接口，好像 increment 也能够，可是不懂是搞啥的，貌似数据类型不同。

PM 2.5 API

首先得找一个 PM 2.5 API，参考了一下这个教程：Air Quality Widget - New Improved Feed。里面的资料显示，美国驻京使馆也用的是这里的数据，应该还算准确吧。

注意看教程里，他们请求的地址为：

http://feed.aqicn.org/feed/beijing/en/feed.v1.json

请求这个地址，就能够获得数据啦。

说到这个，其实国内不少 App 和网站都在用 PM25.in。用的人挺多的，就是发邮件速度有点慢，注册以后获取 Token 的邮件一直都没发给我！

接入 Cloud Insight

先介绍下 Cloud Insight 吧，就是一款系统监控工具，支持 Ubuntu、MySQL、Docker 的监控。可是他们提供 SDK 能够自定义上传数据，因此咱们就用它来承接 PM 2.5 的数据吧。

他们也提供任一指标的报警功能，因此也能够经过设置报警，来发邮件提醒给我。

Cloud Insight SDK 和 StatsD 原理很像，SDK 的详情能够参考文档。

源代码以下：

import requests

from oneapm_ci_sdk import statsd

PM25_API_URL = "http://feed.aqicn.org/feed/%s/en/feed.v1.json"

def get_city_data(city):
    try:
        res = requests.get(PM25_API_URL % city)
    except:
        return 0
    else:
        return res.json()['aqi']['val']

def using_sdk():
    statsd.gauge('airquality.beijing.pm25', float(get_city_data('beijing')))
    statsd.gauge('airquality.shanghai.pm25', float(get_city_data('shanghai')))
    statsd.gauge('airquality.guangzhou.pm25', float(get_city_data('guangzhou')))
    statsd.gauge('airquality.xuchang.pm25', float(get_city_data('xuchang'))) # 家里。。

if __name__ == '__main__':
    using_sdk()

首先经过 API 把数值取出来，而后经过 stats.gauge 对指标进行赋值，就能够了。呼~接下来是产品内部的使用了。

啦啦啦~自定义仪表盘开个 Air Quaility 仪表盘，数据选进来，就能够看各个城市的 PM 2.5 的实时数值了。

想随时随地知道北京空气质量是否超标，却又不想下载广告一大堆的空气质量 App。那我本身动手设一个报警策略吧。

大于或等于 100，就算超标好了。很简单就设置完成了。

大功告成，等着邮件提醒吧。顺便秀一下 Kickstarter 买来的 Pebble 手表。舒心啊：没有广告的北京空气质量监测。

本文参考一篇帖子 pm25，关爱老大，征求原做者赞成后改写。