本篇文章給大家分享的是有關(guān)基于 Knative Serverless 技術(shù)怎樣實(shí)現(xiàn)天氣服務(wù),小編覺得挺實(shí)用的,因此分享給大家學(xué)習(xí),希望大家閱讀完這篇文章后可以有所收獲,話不多說,跟著小編一起來看看吧。
成都創(chuàng)新互聯(lián)專注于津市企業(yè)網(wǎng)站建設(shè),響應(yīng)式網(wǎng)站開發(fā),購物商城網(wǎng)站建設(shè)。津市網(wǎng)站建設(shè)公司,為津市等地區(qū)提供建站服務(wù)。全流程定制網(wǎng)站設(shè)計(jì),專業(yè)設(shè)計(jì),全程項(xiàng)目跟蹤,成都創(chuàng)新互聯(lián)專業(yè)和態(tài)度為您提供的服務(wù)
提到天氣預(yù)報(bào)服務(wù),我們第一反應(yīng)是很簡(jiǎn)單的一個(gè)服務(wù)啊,目前網(wǎng)上有大把的天氣預(yù)報(bào) API 可以直接使用,有必要去使用 Knative 搞一套嗎?殺雞用牛刀?先不要著急,我們先看一下實(shí)際的幾個(gè)場(chǎng)景需求:
場(chǎng)景需求 1:根據(jù)當(dāng)?shù)貧v年的天氣信息,預(yù)測(cè)明年大致的高溫到來的時(shí)間
場(chǎng)景需求 2:近來天氣多變,如果明天下雨,能否在早上上班前,給我一個(gè)帶傘提醒通知
場(chǎng)景需求 3:領(lǐng)導(dǎo)發(fā)話“最近經(jīng)濟(jì)不景氣,公司財(cái)務(wù)緊張,那個(gè)服務(wù)器,你們提供天氣、路況等服務(wù)的那幾個(gè)小程序一起用吧,但要保證正常提供服務(wù)”。
從上面的需求,我們其實(shí)發(fā)現(xiàn),要做好一個(gè)天氣預(yù)報(bào)的服務(wù),也面臨內(nèi)憂(資源緊缺)外患(需求增加),并不是那么簡(jiǎn)單的。不過現(xiàn)在更不要著急,我們可以使用 Knative 幫你解決上面的問題。
關(guān)鍵詞:天氣查詢、表格存儲(chǔ),通道服務(wù),事件通知
首先我們來描述一下我們要做的天氣服務(wù)場(chǎng)景需求:
根據(jù)城市、日期查詢(支持未來 3 天)國(guó)內(nèi)城市天氣信息
不限制查詢次數(shù),支持較大并發(fā)查詢(1000)
訂閱國(guó)內(nèi)城市天氣信息,根據(jù)實(shí)際訂閱城市區(qū)域,提醒明天下雨帶傘
使用釘釘進(jìn)行通知
有了需求,那我們就開始如何基于 Knative 實(shí)現(xiàn)天氣服務(wù)。我們先看一下整體架構(gòu):
通過 CronJob 事件源,每隔 3 個(gè)小時(shí)定時(shí)發(fā)送定時(shí)事件,將國(guó)內(nèi)城市未來 3 天的天氣信息,存儲(chǔ)更新到表格存儲(chǔ)
提供 RESTful API 查詢天氣信息
通過表格存儲(chǔ)提供的通道服務(wù),實(shí)現(xiàn) TableStore 事件源
通過 Borker/Trigger 事件驅(qū)動(dòng)模型,訂閱目標(biāo)城市天氣信息
根據(jù)訂閱收到的天氣信息進(jìn)行釘釘消息通知。如明天下雨,提示帶傘等
基于內(nèi)容較多,我們分上、下兩篇分別進(jìn)行介紹:
上篇我們會(huì)主要介紹如何對(duì)接第三方的天氣預(yù)報(bào) API、定時(shí)同步并更新天氣信息以及提供 RESTful API;
下篇我們會(huì)主要介紹如何實(shí)現(xiàn) TableStore 事件源、訂閱天氣信息并通過釘釘發(fā)送提醒通知;
查詢天氣的 API 有很多,這里我們選擇高德開放平臺(tái)提供的天氣查詢 API,使用簡(jiǎn)單、服務(wù)穩(wěn)定,并且該天氣預(yù)報(bào) API 每天提供 100000 免費(fèi)的調(diào)用量,支持國(guó)內(nèi) 3500 多個(gè)區(qū)域的天氣信息查詢。另外高德開放平臺(tái),除了天氣預(yù)報(bào),還可以提供 IP 定位、搜索服務(wù)、路徑規(guī)劃等,感興趣的也可以研究一下玩法。
登錄高德開放平臺(tái): https://lbs.amap.com, 創(chuàng)建應(yīng)用,獲取 Key 即可:
獲取Key之后,可以直接通過 url 訪問:https://restapi.amap.com/v3/weather/weatherInfo?city=110101&extensions=all&key=<用戶 key>,返回天氣信息數(shù)據(jù)如下:
{ "status":"1", "count":"1", "info":"OK", "infocode":"10000", "forecasts":[ { "city":"杭州市", "adcode":"330100", "province":"浙江", "reporttime":"2019-09-24 20:49:27", "casts":[ { "date":"2019-09-24", "week":"2", "dayweather":"晴", "nightweather":"多云", "daytemp":"29", "nighttemp":"17", "daywind":"無風(fēng)向", "nightwind":"無風(fēng)向", "daypower":"≤3", "nightpower":"≤3" }, ... ] } ] }
該功能主要實(shí)現(xiàn)對(duì)接高德開放平臺(tái)天氣預(yù)報(bào) API, 獲取天氣預(yù)報(bào)信息,同時(shí)對(duì)接阿里云表格存儲(chǔ)服務(wù)(TableStore),用于天氣預(yù)報(bào)數(shù)據(jù)存儲(chǔ)。具體操作如下:
接收 CloudEvent 定時(shí)事件
查詢各個(gè)區(qū)域天氣信息
將天氣信息存儲(chǔ)或者更新到表格存儲(chǔ)
在 Knative 中,我們可以直接創(chuàng)建服務(wù)如下:
apiVersion: serving.knative.dev/v1alpha1 kind: Service metadata: name: weather-store namespace: default spec: template: metadata: labels: app: weather-store annotations: autoscaling.knative.dev/maxScale: "20" autoscaling.knative.dev/target: "100" spec: containers: - image: registry.cn-hangzhou.aliyuncs.com/knative-sample/weather-store:1.2 ports: - name: http1 containerPort: 8080 env: - name: OTS_TEST_ENDPOINT value: http://xxx.cn-hangzhou.ots.aliyuncs.com - name: TABLE_NAME value: weather - name: OTS_TEST_INSTANCENAME value: ${xxx} - name: OTS_TEST_KEYID value: ${yyy} - name: OTS_TEST_SECRET value: ${Pxxx} - name: WEATHER_API_KEY value: xxx
關(guān)于服務(wù)具體實(shí)現(xiàn)參見 GitHub 源代碼:https://github.com/knative-sample/weather-store
這里或許有疑問:為什么不在服務(wù)中直接進(jìn)行定時(shí)輪詢,非要通過 Knative Eventing 搞一個(gè)定時(shí)事件觸發(fā)執(zhí)行調(diào)用?那我們要說明一下,Serverless 時(shí)代下就該這樣玩-按需使用。千萬不要在服務(wù)中按照傳統(tǒng)的方式空跑這些定時(shí)任務(wù),親,這是在持續(xù)浪費(fèi)計(jì)算資源。
言歸正傳,下面我們使用 Knative Eventing 自帶的定時(shí)任務(wù)數(shù)據(jù)源(CronJobSource),觸發(fā)定時(shí)同步事件。
創(chuàng)建 CronJobSource 資源,實(shí)現(xiàn)每 3 個(gè)小時(shí)定時(shí)觸發(fā)同步天氣服務(wù)(weather-store),WeatherCronJob.yaml 如下:
apiVersion: sources.eventing.knative.dev/v1alpha1 kind: CronJobSource metadata: name: weather-cronjob spec: schedule: "0 */3 * * *" data: '{"message": "sync"}' sink: apiVersion: serving.knative.dev/v1alpha1 kind: Service name: weather-store
執(zhí)行命令:
kubectl apply -f WeatherCronJob.yaml
現(xiàn)在我們登錄阿里云表格存儲(chǔ)服務(wù),可以看到天氣預(yù)報(bào)數(shù)據(jù)已經(jīng)按照城市、日期的格式同步進(jìn)來了。
有了這些天氣數(shù)據(jù),可以隨心所欲的提供屬于我們自己的天氣預(yù)報(bào)服務(wù)了(感覺像是承包了一塊地,我們來當(dāng)?shù)刂鳎?,這里沒什么難點(diǎn),從表格存儲(chǔ)中查詢對(duì)應(yīng)的天氣數(shù)據(jù),按照返回的數(shù)據(jù)格式進(jìn)行封裝即可。
在 Knative 中,我們可以部署 RESTful API 服務(wù)如下:
apiVersion: serving.knative.dev/v1alpha1 kind: Service metadata: name: weather-service namespace: default spec: template: metadata: labels: app: weather-service annotations: autoscaling.knative.dev/maxScale: "20" autoscaling.knative.dev/target: "100" spec: containers: - image: registry.cn-hangzhou.aliyuncs.com/knative-sample/weather-service:1.1 ports: - name: http1 containerPort: 8080 env: - name: OTS_TEST_ENDPOINT value: http://xxx.cn-hangzhou.ots.aliyuncs.com - name: TABLE_NAME value: weather - name: OTS_TEST_INSTANCENAME value: ${xxx} - name: OTS_TEST_KEYID value: ${yyy} - name: OTS_TEST_SECRET value: ${Pxxx}
具體實(shí)現(xiàn)源代碼 GitHub 地址:https://github.com/knative-sample/weather-service
查詢天氣 RESTful API:
請(qǐng)求 URL<br /> GET /api/weather/query
參數(shù): cityCode:城市區(qū)域代碼。如北京市區(qū)域代碼:110000 date:查詢?nèi)掌凇H绺袷剑?019-09-26
返回結(jié)果
{ "code":200, "message":"", "data":{ "adcode":"110000", "city":"北京市", "date":"2019-09-26", "daypower":"≤3", "daytemp":"30", "dayweather":"晴", "daywind":"東南", "nightpower":"≤3", "nighttemp":"15", "nightweather":"晴", "nightwind":"東南", "province":"北京", "reporttime":"2019-09-25 14:50:46", "week":"4" } }
查詢:杭州,2019-09-26 天氣預(yù)報(bào)信息示例
測(cè)試地址:http://weather-service.default.serverless.kuberun.com/api/weather/query?cityCode=330100&date=2019-09-26
以上就是基于 Knative Serverless 技術(shù)怎樣實(shí)現(xiàn)天氣服務(wù),小編相信有部分知識(shí)點(diǎn)可能是我們?nèi)粘9ぷ鲿?huì)見到或用到的。希望你能通過這篇文章學(xué)到更多知識(shí)。更多詳情敬請(qǐng)關(guān)注創(chuàng)新互聯(lián)行業(yè)資訊頻道。
新聞標(biāo)題:基于KnativeServerless技術(shù)怎樣實(shí)現(xiàn)天氣服務(wù)
文章來源:http://m.rwnh.cn/article26/gdiijg.html
成都網(wǎng)站建設(shè)公司_創(chuàng)新互聯(lián),為您提供標(biāo)簽優(yōu)化、網(wǎng)站營(yíng)銷、用戶體驗(yàn)、微信小程序、App開發(fā)、定制開發(fā)
聲明:本網(wǎng)站發(fā)布的內(nèi)容(圖片、視頻和文字)以用戶投稿、用戶轉(zhuǎn)載內(nèi)容為主,如果涉及侵權(quán)請(qǐng)盡快告知,我們將會(huì)在第一時(shí)間刪除。文章觀點(diǎn)不代表本網(wǎng)站立場(chǎng),如需處理請(qǐng)聯(lián)系客服。電話:028-86922220;郵箱:631063699@qq.com。內(nèi)容未經(jīng)允許不得轉(zhuǎn)載,或轉(zhuǎn)載時(shí)需注明來源: 創(chuàng)新互聯(lián)