基于 Serverless +企业微信打造 nCoV 疫情监控小助手
作者：Serverless 发布时间：2023-11-20 21:42:02
标签：Serverless,企业微信,nCoV,疫情,监控
最近的一些疫情信息很让人揪心，为了方便大家掌握疫情信息，在空闲之余做了一个关于 nCoV 的疫情监控小助手。主要的功能是通过企业微信的 WebHook 来推送疫情信息。这里将使用 Serverless 的整体代码思路和架构方式分享给大家。本文作者：tabor
实现效果
我们想要实现的大致的效果是这样的：
首先，我们需要解决的是数据来源问题，这里我们可以使用 python 爬虫来做这件事情，但是由于个人比较懒所以直接用的 2019-nCoV-Crawler ，这个项目已经集成了现有的 API，所以我们直接调用即可。当然有能力的同学也可以自己部署 Python，我这边是自己部署的，但是这不是本次的重点，就不在赘述。
现在，我们有了数据，但是数据怎么打到服务器呢？又该如何触发？当然使用 CVM 也是可以的，但是似乎太笨拙，并且消耗量很大，需要自己搭好所有环境。所以，这里我们选用 Serverless 方式来部署。
核心逻辑
我们来看看整体业务的代码部分吧，毕竟这里是整个机器人的核心。我们来看代码（请求三次接口）：
<?php
function main_handler($event, $context) {
// 广东省情况
$curlsz = curl_init();
curl_setopt_array($curlsz, array(
CURLOPT_URL => "https://lab.isaaclin.cn/nCoV/api/area?latest=0&province=％E5％B9％BF％E4％B8％9C％E7％9C％81",
CURLOPT_RETURNTRANSFER => true,
CURLOPT_ENCODING => "",
CURLOPT_MAXREDIRS => 10,
CURLOPT_TIMEOUT => 3000,
CURLOPT_HTTP_VERSION => CURL_HTTP_VERSION_1_1,
CURLOPT_CUSTOMREQUEST => "GET",
CURLOPT_HTTPHEADER => array(
"Accept: */*",
"Cache-Control: no-cache",
"Connection: keep-alive",
"Host: lab.isaaclin.cn",
"Postman-Token: 680e5ea7-5c2e-4fb6-9295-7e336f2252c6,abd73e01-2a60-42b5-9bbe-92aa83805a7e",
"User-Agent: PostmanRuntime/7.15.0",
"accept-encoding: gzip, deflate",
"cache-control: no-cache"
),
));
$responsesz = curl_exec($curlsz);
$echo_responsesz = json_decode($responsesz, true);
$err = curl_error($curlsz);
curl_close($curlsz);
// 湖北省情况
$curlhb = curl_init();
curl_setopt_array($curlhb, array(
CURLOPT_URL => "https://lab.isaaclin.cn/nCoV/api/area?latest=0&province=％E6％B9％96％E5％8C％97％E7％9C％81",
CURLOPT_RETURNTRANSFER => true,
CURLOPT_ENCODING => "",
CURLOPT_MAXREDIRS => 10,
CURLOPT_TIMEOUT => 3000,
CURLOPT_HTTP_VERSION => CURL_HTTP_VERSION_1_1,
CURLOPT_CUSTOMREQUEST => "GET",
CURLOPT_HTTPHEADER => array(
"Accept: */*",
"Cache-Control: no-cache",
"Connection: keep-alive",
"Host: lab.isaaclin.cn",
"Postman-Token: 680e5ea7-5c2e-4fb6-9295-7e336f2252c6,abd73e01-2a60-42b5-9bbe-92aa83805a7e",
"User-Agent: PostmanRuntime/7.15.0",
"accept-encoding: gzip, deflate",
"cache-control: no-cache"
),
));
$responsehb = curl_exec($curlhb);
$echo_responsehb = json_decode($responsehb, true);
$err = curl_error($curlhb);
curl_close($curlhb);
// 全国总体情况
$curlall = curl_init();
curl_setopt_array($curlall, array(
CURLOPT_URL => "https://lab.isaaclin.cn/nCoV/api/overall",
CURLOPT_RETURNTRANSFER => true,
CURLOPT_ENCODING => "",
CURLOPT_MAXREDIRS => 10,
CURLOPT_TIMEOUT => 3000,
CURLOPT_HTTP_VERSION => CURL_HTTP_VERSION_1_1,
CURLOPT_CUSTOMREQUEST => "GET",
CURLOPT_HTTPHEADER => array(
"Accept: */*",
"Cache-Control: no-cache",
"Connection: keep-alive",
"Host: lab.isaaclin.cn",
"Postman-Token: 680e5ea7-5c2e-4fb6-9295-7e336f2252c6,abd73e01-2a60-42b5-9bbe-92aa83805a7e",
"User-Agent: PostmanRuntime/7.15.0",
"accept-encoding: gzip, deflate",
"cache-control: no-cache"
),
));
$responseall = curl_exec($curlall);
$echo_responseall = json_decode($responseall, true);
$err = curl_error($curlall);
curl_close($curlall);
//判断是否为深圳地域（这里逻辑写的比较简单，但是够用了）
if ($echo_responsesz['results'][0]['cities'][0]['cityName'] == '深圳') {
$echo_responseszqz = $echo_responsesz['results'][0]['cities'][0]['confirmedCount'];
$echo_responseszys = $echo_responsesz['results'][0]['cities'][0]['suspectedCount'];
$echo_responseszzy = $echo_responsesz['results'][0]['cities'][0]['curedCount'];
$echo_responseszsw = $echo_responsesz['results'][0]['cities'][0]['deadCount'];
} else {
$echo_responseszqz = $echo_responsesz['results'][0]['cities'][1]['confirmedCount'];
$echo_responseszys = $echo_responsesz['results'][0]['cities'][1]['suspectedCount'];
$echo_responseszzy = $echo_responsesz['results'][0]['cities'][1]['curedCount'];
$echo_responseszsw = $echo_responsesz['results'][0]['cities'][1]['deadCount'];
}
if ($err) {
echo "cURL Error #:" . $err;
} else {
//疫情监控告警机器人
$sc = $sc=" **2019-nCoV 疫情信息同步:** \n
> 全国疫情:
> 确诊人数<font color=\"info\">".$echo_responseall['results'][0]['confirmedCount']."</font>,疑似感染人数<font color=\"info\">".$echo_responseall['results'][0]['suspectedCount']."</font>,治愈人数<font color=\"info\">".$echo_responseall['results'][0]['curedCount']."</font>,死亡人数<font color=\"info\">".$echo_responseall['results'][0]['deadCount']."</font>\n
> 广东省:
> 确诊人数<font color=\"info\">".$echo_responsesz['results'][0]['confirmedCount']."</font>,疑似感染人数<font color=\"info\">".$echo_responsesz['results'][0]['suspectedCount']."</font>,治愈人数<font color=\"info\">".$echo_responsesz['results'][0]['curedCount']."</font>,死亡人数<font color=\"info\">".$echo_responsesz['results'][0]['deadCount']."</font>\n
> 湖北省:
> 确诊人数<font color=\"info\">".$echo_responsehb['results'][0]['confirmedCount']."</font>,疑似感染人数<font color=\"info\">".$echo_responsehb['results'][0]['suspectedCount']."</font>,治愈人数<font color=\"info\">".$echo_responsehb['results'][0]['curedCount']."</font>,死亡人数<font color=\"info\">".$echo_responsehb['results'][0]['deadCount']."</font>\n
> 深圳市:
> 确诊人数<font color=\"info\">".$echo_responseszqz."</font>,疑似感染人数<font color=\"info\">".$echo_responseszys."</font>,治愈人数<font color=\"info\">".$echo_responseszzy."</font>,死亡人数<font color=\"info\">".$echo_responseszsw."</font>\n
> <font color=\"info\">".$echo_responseall['results'][0]['note1']."</font>
> <font color=\"info\">".$echo_responseall['results'][0]['note2']."</font>
> <font color=\"info\">".$echo_responseall['results'][0]['note3']."</font>
> <font color=\"info\">".$echo_responseall['results'][0]['remark1']."</font>
> <font color=\"info\">".$echo_responseall['results'][0]['remark2']."</font>
> <font color=\"info\"> 信息出处:".$echo_responseall['results'][0]['generalRemark']."</font> \n
>[更多数据请查看](https://news.qq.com/zt2020/page/feiyan.htm) \n
";
$post = array('msgtype' => 'markdown', 'markdown' => array('content' => $sc));
$curl = curl_init();
curl_setopt_array($curl, array(
CURLOPT_URL => "https://qyapi.weixin.qq.com/cgi-bin/webhook/send?key=", //这里的地址填写为企业微信的HOOK路径，https://work.weixin.qq.com/api/doc/90000/90136/91770
CURLOPT_RETURNTRANSFER => true,
CURLOPT_ENCODING => "",
CURLOPT_MAXREDIRS => 10,
CURLOPT_TIMEOUT => 10,
CURLOPT_HTTP_VERSION => CURL_HTTP_VERSION_1_1,
CURLOPT_CUSTOMREQUEST => "POST",
CURLOPT_POSTFIELDS => json_encode($post,JSON_UNESCAPED_UNICODE),
CURLOPT_HTTPHEADER => array(
"Cache-Control: no-cache",
"Postman-Token: ab32082b-ce64-4832-b51f-8f2f1b3e98ef"
),
));
$response = curl_exec($curl);
$err = curl_error($curl);
curl_close($curl);
return "运行成功";
}
}
?>
是不是很简单呢？请求数据，发送数据。
那么我们接下了重点看下如何将我们的业务代码上传到云端呢？
这里的云端我用的是腾讯云 Serverless 服务 SCF云函数 。整个部署，使用过程都是免费的，对于开发者来讲小项目使用的话免费额度是完全够用的。无需担心额外付费。
Serverless 部署，选用的是比较流行的 Serverless Framework，使用和部署也是完全免费的，那么下面我就来介绍下具体的部署过程吧。
安装 Serverless 框架
首先，第一步，我们来安装一个 Serverless Framework 的开发框架：
$ npm install -g serverless
然后，我们创建一个函数目录：
$ mkdir nCov-function
$ cd nCov-function
相关函数目录的内容如下：
|- code
|- index.php // 这里就是上面的业务代码存放位置
|- serverless.yml //serverless 配置文件
配置 Yml 文件
接下来，是我们的重头戏，配置函数 yml 文件：
# serverless.yml
myFunction:
component: "@serverless/tencent-scf" //引用tencent-scf component
inputs:
name: nCoVFunction //函数名称
enableRoleAuth: true
codeUri: ./code //代码本地存放位置
handler: index.main_handler
runtime: Php5
region: ap-shanghai //函数运行地域
description: My Serverless nCoV Function.
memorySize: 128 //运行内存
timeout: 20 //超时时间
exclude:
- .gitignore
- .git/**
- node_modules/**
- .serverless
- .env
include:
- ./nCoVFunction.zip
environment:
variables:
TEST: vale
vpcConfig:
subnetId: ''
vpcId: ''
events:
- timer: // 定时触发器
name: timer
parameters:
cronExpression: '0 0 10,21 * * * *' //明天早上10点，晚上21点
enable: true
万事具备，我们就可以直接部署 SLS 了。
部署到云端
通过 sls 命令（serverless 的缩写）进行部署，并可以添加 –debug 参数查看部署过程中的信息：
taborchen$ sls --debug
DEBUG ─ Resolving the template's static variables.
DEBUG ─ Collecting components from the template.
DEBUG ─ Downloading any NPM components found in the template.
DEBUG ─ Analyzing the template's components dependencies.
DEBUG ─ Creating the template's components graph.
DEBUG ─ Syncing template state.
DEBUG ─ Executing the template's components graph.
DEBUG ─ Compressing function nCoVFunction file to /Users/taborchen/Desktop/工作/yiqing/.ser
verless/nCoVFunction.zip.
DEBUG ─ Compressed function nCoVFunction file successful
DEBUG ─ Uploading service package to cos[sls-cloudfunction-ap-shanghai-code]. sls-cloudfunc
tion-default-nCoVFunction-1580960644.zip
DEBUG ─ Uploaded package successful /Users/taborchen/Desktop/工作/yiqing/.serverless/nCoVFu
nction.zip
DEBUG ─ Creating function nCoVFunction
DEBUG ─ Created function nCoVFunction successful
DEBUG ─ Setting tags for function nCoVFunction
DEBUG ─ Creating trigger for function nCoVFunction
DEBUG ─ Created timer trigger timer for function nCoVFunction success.
DEBUG ─ Deployed function nCoVFunction successful
运行结果如下：
这样，我们就完成了一个 nCoV 的在线触发函数机器人～是不是很简单呢？快来开始动手吧～
传送门：
GitHub: github.com/serverless
官网：serverless.com
好了，就给大家介绍到这来，希望大家喜欢！
来源：https://www.cnblogs.com/serverlesscloud/p/12290602.html
0
投稿猜你喜欢
一、业务背景在金融风控领域，常常使用KS指标来衡量评估模型的区分度（discrimination），这也是风控模型最为追求的指标之一。下面将- 显示有限的接口到外部当发布python第三方package时，并不希望代码中所有的函数或者class可以被外部import，在__init_
- 还是网站在不同操作系统不同浏览器下兼容性的问题,但难度加了一层.如果是要检查用户登录后的页面的兼容性,该怎么办?现在一般的测试网站,都是提交
- 第一种，也是我最常用的,第一帧里加上这个比较灵活，想要自定义加入菜单，只要定义drMenu这个对象就可以了var drMenu&n
- 在学习接口测试的时候往往会因为没有实际操作的接口进行测试而烦恼，这里教大家自己编写两个接口用于学习接口测试1、编写一个登录的接口2、在pyc
- 本文实例为大家分享了python实现银行实战系统的具体代码，供大家参考，具体内容如下先附上源代码：│ admin.py
- 本文实例讲述了Python实现二分查找算法的方法。分享给大家供大家参考。具体实现方法如下：#!/usr/bin/env pythonimpo
- #coding=utf-8#对话框import sysfrom PyQt4 import QtGui, QtCoreclass Window
- 前言PyCharm是一种Python 的IDE工具（集成开发环境），带有一整套可以帮助用户在使用Python语言开发时提高其效率的工具，内部
- 说明相应的学习视频见链接，本文只对重点进行总结。多进程重点（只要看下面代码的main函数即可）1.创建2.如何开守护进程3.多进程，开销大，
- 本文为大家分享了pygame游戏之旅的第3篇，供大家参考，具体内容如下载入car图片（我自己画的），需要用到pygame.image模块，定
- Python内置模块logging管理不同级别log打印和存储，非常方便，从此告别了使用print打桩记录，我们来看下logging的魅力吧
- 快速入门In [1]: import time# 获取当前时间In [25]: time.strftime("％Y-％m-％d_％
- 编写ATM程序实现下述功能，数据来源于文件db.txt1、充值功能：用户输入充值钱数，db.txt中该账号钱数完成修改2、转账功能：用户A向
- 本文实例讲述了Python3.5内置模块之os模块、sys模块、shutil模块用法。分享给大家供大家参考，具体如下：1、os模块：提供对操
- pyecharts 是一个用于生成 Echarts 图表的类库。Echarts 是百度开源的一个数据可视化 JS 库。这篇文章重点给大家介绍
- 基本映射映射使用在根据不同URLs请求来产生相对应的返回内容.Bottle使用route() 修饰器来实现映射.from bottle im
- 百度AI功能还是很强大的，百度AI开放平台真的是测试接口的天堂，免费接口很多，当然有量的限制，但个人使用是完全够用的，什么人脸识别、MQTT
- 本文实例为大家分享了python使用tkinter实现简单计算器的具体代码，供大家参考，具体内容如下class Counter: #引入t
- 在客户端，Get方式在通过URL提交数据，数据在URL中可以看到；POST方式，数据放置在HTML HEADER内提交。GET方式提交的数据
