zoukankan      html  css  js  c++  java
  • 使用 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,关爱老大,征求原作者同意后改写。

  • 相关阅读:
    eslint 屏蔽html的检查
    css 自定义悬浮窗写法
    echarts象形图图例显示问题
    win10上rocketMQ的部署过程
    死锁以及如何避免死锁
    volatile的一个例子-通俗易懂
    Java四种引用类型
    记录下:安全|API接口安全性设计(防篡改和重复调用)
    了解聚集索引,非聚集索引,联合索引,索引覆盖
    mybatis 查询树形结构
  • 原文地址:https://www.cnblogs.com/oneapm/p/5069653.html
Copyright © 2011-2022 走看看