基于 Serverless +企业微信打造 nCoV 疫情监控小助手
最近的一些疫情信息很让人揪心，为了方便大家掌握疫情信息，在空闲之余做了一个关于nCoV的疫情监控小助手。主要的功能是通过企业微信的WebHook来推送疫情信息。这里将使用Serverless的整体代码思路和架构方式分享给大家。本文作者：tabor
实现效果
我们想要实现的大致的效果是这样的：
首先，我们需要解决的是数据来源问题，这里我们可以使用python爬虫来做这件事情，但是由于个人比较懒所以直接用的2019-nCoV-Crawler ，这个项目已经集成了现有的API，所以我们直接调用即可。当然有能力的同学也可以自己部署Python，我这边是自己部署的，但是这不是本次的重点，就不在赘述。
现在，我们有了数据，但是数据怎么打到服务器呢？又该如何触发？当然使用CVM也是可以的，但是似乎太笨拙，并且消耗量很大，需要自己搭好所有环境。所以，这里我们选用Serverless方式来部署。
核心逻辑
我们来看看整体业务的代码部分吧，毕竟这里是整个机器人的核心。我们来看代码（请求三次接口）：
"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"cURLError#:".$err;
}else{
//疫情监控告警机器人
$sc=$sc="**2019-nCoV疫情信息同步:**\n
>全国疫情:
>确诊人数".$echo_responseall['results'][0]['confirmedCount'].",疑似感染人数".$echo_responseall['results'][0]['suspectedCount'].",治愈人数".$echo_responseall['results'][0]['curedCount'].",死亡人数".$echo_responseall['results'][0]['deadCount']."\n
>广东省:
>确诊人数".$echo_responsesz['results'][0]['confirmedCount'].",疑似感染人数".$echo_responsesz['results'][0]['suspectedCount'].",治愈人数".$echo_responsesz['results'][0]['curedCount'].",死亡人数".$echo_responsesz['results'][0]['deadCount']."\n
>湖北省:
>确诊人数".$echo_responsehb['results'][0]['confirmedCount'].",疑似感染人数".$echo_responsehb['results'][0]['suspectedCount'].",治愈人数".$echo_responsehb['results'][0]['curedCount'].",死亡人数".$echo_responsehb['results'][0]['deadCount']."\n
>深圳市:
>确诊人数".$echo_responseszqz.",疑似感染人数".$echo_responseszys.",治愈人数".$echo_responseszzy.",死亡人数".$echo_responseszsw."\n
>".$echo_responseall['results'][0]['note1']."
>".$echo_responseall['results'][0]['note2']."
>".$echo_responseall['results'][0]['note3']."
>".$echo_responseall['results'][0]['remark1']."
>".$echo_responseall['results'][0]['remark2']."
>信息出处:".$echo_responseall['results'][0]['generalRemark']."\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部署，选用的是比较流行的ServerlessFramework，使用和部署也是完全免费的，那么下面我就来介绍下具体的部署过程吧。
安装Serverless框架
首先，第一步，我们来安装一个ServerlessFramework的开发框架：
$npminstall-gserverless
然后，我们创建一个函数目录：
$mkdirnCov-function $cdnCov-function
相关函数目录的内容如下：
|-code |-index.php//这里就是上面的业务代码存放位置 |-serverless.yml//serverless配置文件
配置Yml文件
接下来，是我们的重头戏，配置函数yml文件：
#serverless.yml myFunction: component:"@serverless/tencent-scf"//引用tencent-scfcomponent inputs: name:nCoVFunction//函数名称 enableRoleAuth:true codeUri:./code//代码本地存放位置 handler:index.main_handler runtime:Php5 region:ap-shanghai//函数运行地域 description:MyServerlessnCoVFunction. 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:'0010,21****'//明天早上10点，晚上21点 enable:true
万事具备，我们就可以直接部署SLS了。
部署到云端
通过sls命令（serverless的缩写）进行部署，并可以添加–debug参数查看部署过程中的信息：
taborchen$sls--debug DEBUG─Resolvingthetemplate'sstaticvariables. DEBUG─Collectingcomponentsfromthetemplate. DEBUG─DownloadinganyNPMcomponentsfoundinthetemplate. DEBUG─Analyzingthetemplate'scomponentsdependencies. DEBUG─Creatingthetemplate'scomponentsgraph. DEBUG─Syncingtemplatestate. DEBUG─Executingthetemplate'scomponentsgraph. DEBUG─CompressingfunctionnCoVFunctionfileto/Users/taborchen/Desktop/工作/yiqing/.ser verless/nCoVFunction.zip. DEBUG─CompressedfunctionnCoVFunctionfilesuccessful DEBUG─Uploadingservicepackagetocos[sls-cloudfunction-ap-shanghai-code].sls-cloudfunc tion-default-nCoVFunction-1580960644.zip DEBUG─Uploadedpackagesuccessful/Users/taborchen/Desktop/工作/yiqing/.serverless/nCoVFu nction.zip DEBUG─CreatingfunctionnCoVFunction DEBUG─CreatedfunctionnCoVFunctionsuccessful DEBUG─SettingtagsforfunctionnCoVFunction DEBUG─CreatingtriggerforfunctionnCoVFunction DEBUG─CreatedtimertriggertimerforfunctionnCoVFunctionsuccess. DEBUG─DeployedfunctionnCoVFunctionsuccessful
运行结果如下：
这样，我们就完成了一个nCoV的在线触发函数机器人～是不是很简单呢？快来开始动手吧～
传送门：
GitHub:github.com/serverless
官网：serverless.com
好了，就给大家介绍到这来，希望大家喜欢！
声明：本文内容来源于网络，版权归原作者所有，内容由互联网用户自发贡献自行上传，本网站不拥有所有权，未作人工编辑处理，也不承担相关法律责任。如果您发现有涉嫌版权的内容，欢迎发送邮件至：czq8825#qq.com（发邮件时，请将#更换为@）进行举报，并提供相关证据，一经查实，本站将立刻删除涉嫌侵权内容。