主頁(yè) > 知識(shí)庫(kù) > 基于 Serverless +企業(yè)微信打造 nCoV 疫情監(jiān)控小助手

基于 Serverless +企業(yè)微信打造 nCoV 疫情監(jiān)控小助手

熱門標(biāo)簽:承德地圖標(biāo)注公司收費(fèi) 高德地圖標(biāo)注常顯 外呼系統(tǒng)號(hào)顯示星號(hào)怎么看 suitecrm 地圖標(biāo)注 揭陽(yáng)電腦外呼系統(tǒng)公司 鶴壁外呼系統(tǒng)公司 銀川語(yǔ)音外呼系統(tǒng)中心 臨沂ai電銷機(jī)器人招商 華創(chuàng)e路航彩票銷售點(diǎn)地圖標(biāo)注

最近的一些疫情信息很讓人揪心,為了方便大家掌握疫情信息,在空閑之余做了一個(gè)關(guān)于 nCoV 的疫情監(jiān)控小助手。主要的功能是通過(guò)企業(yè)微信的 WebHook 來(lái)推送疫情信息。這里將使用 Serverless 的整體代碼思路和架構(gòu)方式分享給大家。本文作者:tabor

實(shí)現(xiàn)效果

我們想要實(shí)現(xiàn)的大致的效果是這樣的:

首先,我們需要解決的是數(shù)據(jù)來(lái)源問題,這里我們可以使用 python 爬蟲來(lái)做這件事情,但是由于個(gè)人比較懶所以直接用的 2019-nCoV-Crawler  ,這個(gè)項(xiàng)目已經(jīng)集成了現(xiàn)有的 API,所以我們直接調(diào)用即可。當(dāng)然有能力的同學(xué)也可以自己部署 Python,我這邊是自己部署的,但是這不是本次的重點(diǎn),就不在贅述。

現(xiàn)在,我們有了數(shù)據(jù),但是數(shù)據(jù)怎么打到服務(wù)器呢?又該如何觸發(fā)?當(dāng)然使用 CVM 也是可以的,但是似乎太笨拙,并且消耗量很大,需要自己搭好所有環(huán)境。所以,這里我們選用 Serverless 方式來(lái)部署。

核心邏輯

我們來(lái)看看整體業(yè)務(wù)的代碼部分吧,畢竟這里是整個(gè)機(jī)器人的核心。我們來(lái)看代碼(請(qǐng)求三次接口):

?php
function main_handler($event, $context) {
// 廣東省情況
$curlsz = curl_init();
curl_setopt_array($curlsz, array(
 CURLOPT_URL => "https://lab.isaaclin.cn/nCoV/api/area?latest=0province=%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=0province=%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);
// 全國(guó)總體情況
$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);
//判斷是否為深圳地域(這里邏輯寫的比較簡(jiǎn)單,但是夠用了)
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 {
//疫情監(jiān)控告警機(jī)器人
$sc = $sc=" **2019-nCoV 疫情信息同步:** \n
> 全國(guó)疫情: 
> 確診人數(shù)font color=\"info\">".$echo_responseall['results'][0]['confirmedCount']."/font>,疑似感染人數(shù)font color=\"info\">".$echo_responseall['results'][0]['suspectedCount']."/font>,治愈人數(shù)font color=\"info\">".$echo_responseall['results'][0]['curedCount']."/font>,死亡人數(shù)font color=\"info\">".$echo_responseall['results'][0]['deadCount']."/font>\n
> 廣東省: 
> 確診人數(shù)font color=\"info\">".$echo_responsesz['results'][0]['confirmedCount']."/font>,疑似感染人數(shù)font color=\"info\">".$echo_responsesz['results'][0]['suspectedCount']."/font>,治愈人數(shù)font color=\"info\">".$echo_responsesz['results'][0]['curedCount']."/font>,死亡人數(shù)font color=\"info\">".$echo_responsesz['results'][0]['deadCount']."/font>\n
> 湖北省: 
> 確診人數(shù)font color=\"info\">".$echo_responsehb['results'][0]['confirmedCount']."/font>,疑似感染人數(shù)font color=\"info\">".$echo_responsehb['results'][0]['suspectedCount']."/font>,治愈人數(shù)font color=\"info\">".$echo_responsehb['results'][0]['curedCount']."/font>,死亡人數(shù)font color=\"info\">".$echo_responsehb['results'][0]['deadCount']."/font>\n
> 深圳市: 
> 確診人數(shù)font color=\"info\">".$echo_responseszqz."/font>,疑似感染人數(shù)font color=\"info\">".$echo_responseszys."/font>,治愈人數(shù)font color=\"info\">".$echo_responseszzy."/font>,死亡人數(shù)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
>[更多數(shù)據(jù)請(qǐng)查看](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=", //這里的地址填寫為企業(yè)微信的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 "運(yùn)行成功"; 
}
}
?>

是不是很簡(jiǎn)單呢?請(qǐng)求數(shù)據(jù),發(fā)送數(shù)據(jù)。

那么我們接下了重點(diǎn)看下如何將我們的業(yè)務(wù)代碼上傳到云端呢?
這里的云端我用的是騰訊云 Serverless 服務(wù) SCF云函數(shù) 。整個(gè)部署,使用過(guò)程都是免費(fèi)的,對(duì)于開發(fā)者來(lái)講小項(xiàng)目使用的話免費(fèi)額度是完全夠用的。無(wú)需擔(dān)心額外付費(fèi)。

Serverless 部署,選用的是比較流行的 Serverless Framework,使用和部署也是完全免費(fèi)的,那么下面我就來(lái)介紹下具體的部署過(guò)程吧。

安裝 Serverless 框架

首先,第一步,我們來(lái)安裝一個(gè) Serverless Framework 的開發(fā)框架:

$ npm install -g serverless

然后,我們創(chuàng)建一個(gè)函數(shù)目錄:

$ mkdir nCov-function
$ cd nCov-function

相關(guān)函數(shù)目錄的內(nèi)容如下:

|- code
 |- index.php // 這里就是上面的業(yè)務(wù)代碼存放位置
|- serverless.yml //serverless 配置文件

配置 Yml 文件

接下來(lái),是我們的重頭戲,配置函數(shù) yml 文件:

# serverless.yml
myFunction:
 component: "@serverless/tencent-scf" //引用tencent-scf component
 inputs:
 name: nCoVFunction //函數(shù)名稱
 enableRoleAuth: true
 codeUri: ./code //代碼本地存放位置
 handler: index.main_handler
 runtime: Php5
 region: ap-shanghai //函數(shù)運(yùn)行地域
 description: My Serverless nCoV Function.
 memorySize: 128 //運(yùn)行內(nèi)存
 timeout: 20 //超時(shí)時(shí)間
 exclude:
 - .gitignore
 - .git/**
 - node_modules/**
 - .serverless
 - .env
 include:
 - ./nCoVFunction.zip
 environment:
 variables:
 TEST: vale
 vpcConfig:
 subnetId: ''
 vpcId: ''
 events:
 - timer: // 定時(shí)觸發(fā)器
  name: timer
  parameters:
  cronExpression: '0 0 10,21 * * * *' //明天早上10點(diǎn),晚上21點(diǎn)
  enable: true

萬(wàn)事具備,我們就可以直接部署 SLS 了。

部署到云端

通過(guò) sls 命令(serverless 的縮寫)進(jìn)行部署,并可以添加 –debug 參數(shù)查看部署過(guò)程中的信息:

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

運(yùn)行結(jié)果如下:

這樣,我們就完成了一個(gè) nCoV 的在線觸發(fā)函數(shù)機(jī)器人~是不是很簡(jiǎn)單呢?快來(lái)開始動(dòng)手吧~

傳送門:

GitHub: github.com/serverless

官網(wǎng):serverless.com

好了,就給大家介紹到這來(lái),希望大家喜歡!

您可能感興趣的文章:
  • Serverless 架構(gòu)如何演進(jìn)詳細(xì)介紹
  • 什么是OpenStack 開源的云計(jì)算管理平臺(tái)項(xiàng)目
  • OpenStack云計(jì)算快速入門教程(1)之OpenStack及其構(gòu)成簡(jiǎn)介
  • 虛擬化和云計(jì)算的區(qū)別分析
  • CentOS 6.4下安裝部署OpenStack云計(jì)算平臺(tái)的方法
  • 解讀Serverless架構(gòu)的前世今生

標(biāo)簽:忻州 咸寧 萊蕪 七臺(tái)河 三沙 許昌 棗莊 汕尾

巨人網(wǎng)絡(luò)通訊聲明:本文標(biāo)題《基于 Serverless +企業(yè)微信打造 nCoV 疫情監(jiān)控小助手》,本文關(guān)鍵詞  基于,Serverless,企業(yè),微信,;如發(fā)現(xiàn)本文內(nèi)容存在版權(quán)問題,煩請(qǐng)?zhí)峁┫嚓P(guān)信息告之我們,我們將及時(shí)溝通與處理。本站內(nèi)容系統(tǒng)采集于網(wǎng)絡(luò),涉及言論、版權(quán)與本站無(wú)關(guān)。
  • 相關(guān)文章
  • 下面列出與本文章《基于 Serverless +企業(yè)微信打造 nCoV 疫情監(jiān)控小助手》相關(guān)的同類信息!
  • 本頁(yè)收集關(guān)于基于 Serverless +企業(yè)微信打造 nCoV 疫情監(jiān)控小助手的相關(guān)信息資訊供網(wǎng)民參考!
  • 推薦文章