本篇文章給大家分享的是有關(guān)基于 Knative Serverless 技術(shù)怎樣實現(xiàn)天氣服務，小編覺得挺實用的，因此分享給大家學習，希望大家閱讀完這篇文章后可以有所收獲，話不多說，跟著小編一起來看看吧。
成都創(chuàng)新互聯(lián)專注于津市企業(yè)網(wǎng)站建設,響應式網(wǎng)站開發(fā),購物商城網(wǎng)站建設。津市網(wǎng)站建設公司,為津市等地區(qū)提供建站服務。全流程定制網(wǎng)站設計，專業(yè)設計，全程項目跟蹤，成都創(chuàng)新互聯(lián)專業(yè)和態(tài)度為您提供的服務
提到天氣預報服務，我們第一反應是很簡單的一個服務啊，目前網(wǎng)上有大把的天氣預報 API 可以直接使用，有必要去使用 Knative 搞一套嗎？殺雞用牛刀？先不要著急，我們先看一下實際的幾個場景需求：
場景需求 1：根據(jù)當?shù)貧v年的天氣信息，預測明年大致的高溫到來的時間
場景需求 2：近來天氣多變，如果明天下雨，能否在早上上班前，給我一個帶傘提醒通知
場景需求 3：領(lǐng)導發(fā)話“最近經(jīng)濟不景氣，公司財務緊張，那個服務器，你們提供天氣、路況等服務的那幾個小程序一起用吧，但要保證正常提供服務”。
從上面的需求，我們其實發(fā)現(xiàn)，要做好一個天氣預報的服務，也面臨內(nèi)憂（資源緊缺）外患（需求增加），并不是那么簡單的。不過現(xiàn)在更不要著急，我們可以使用 Knative 幫你解決上面的問題。
關(guān)鍵詞：天氣查詢、表格存儲，通道服務，事件通知
首先我們來描述一下我們要做的天氣服務場景需求：
根據(jù)城市、日期查詢（支持未來 3 天）國內(nèi)城市天氣信息
不限制查詢次數(shù)，支持較大并發(fā)查詢（1000）
訂閱國內(nèi)城市天氣信息，根據(jù)實際訂閱城市區(qū)域，提醒明天下雨帶傘
使用釘釘進行通知
有了需求，那我們就開始如何基于 Knative 實現(xiàn)天氣服務。我們先看一下整體架構(gòu)：
通過 CronJob 事件源，每隔 3 個小時定時發(fā)送定時事件，將國內(nèi)城市未來 3 天的天氣信息，存儲更新到表格存儲
提供 RESTful API 查詢天氣信息
通過表格存儲提供的通道服務，實現(xiàn) TableStore 事件源
通過 Borker/Trigger 事件驅(qū)動模型，訂閱目標城市天氣信息
根據(jù)訂閱收到的天氣信息進行釘釘消息通知。如明天下雨，提示帶傘等
基于內(nèi)容較多，我們分上、下兩篇分別進行介紹：
上篇我們會主要介紹如何對接第三方的天氣預報 API、定時同步并更新天氣信息以及提供 RESTful API；
下篇我們會主要介紹如何實現(xiàn) TableStore 事件源、訂閱天氣信息并通過釘釘發(fā)送提醒通知；
查詢天氣的 API 有很多，這里我們選擇高德開放平臺提供的天氣查詢 API，使用簡單、服務穩(wěn)定，并且該天氣預報 API 每天提供 100000 免費的調(diào)用量，支持國內(nèi) 3500 多個區(qū)域的天氣信息查詢。另外高德開放平臺，除了天氣預報，還可以提供 IP 定位、搜索服務、路徑規(guī)劃等，感興趣的也可以研究一下玩法。
登錄高德開放平臺: https://lbs.amap.com， 創(chuà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":"無風向",
"nightwind":"無風向",
"daypower":"≤3",
"nightpower":"≤3"
},
...
]
}
]
}該功能主要實現(xiàn)對接高德開放平臺天氣預報 API， 獲取天氣預報信息，同時對接阿里云表格存儲服務（TableStore），用于天氣預報數(shù)據(jù)存儲。具體操作如下：
接收 CloudEvent 定時事件
查詢各個區(qū)域天氣信息
將天氣信息存儲或者更新到表格存儲
在 Knative 中，我們可以直接創(chuàng)建服務如下：
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)于服務具體實現(xiàn)參見 GitHub 源代碼：https://github.com/knative-sample/weather-store
這里或許有疑問：為什么不在服務中直接進行定時輪詢，非要通過 Knative Eventing 搞一個定時事件觸發(fā)執(zhí)行調(diào)用？那我們要說明一下，Serverless 時代下就該這樣玩-按需使用。千萬不要在服務中按照傳統(tǒng)的方式空跑這些定時任務，親，這是在持續(xù)浪費計算資源。
言歸正傳，下面我們使用 Knative Eventing 自帶的定時任務數(shù)據(jù)源（CronJobSource），觸發(fā)定時同步事件。
創(chuàng)建 CronJobSource 資源，實現(xiàn)每 3 個小時定時觸發(fā)同步天氣服務（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)在我們登錄阿里云表格存儲服務，可以看到天氣預報數(shù)據(jù)已經(jīng)按照城市、日期的格式同步進來了。
有了這些天氣數(shù)據(jù)，可以隨心所欲的提供屬于我們自己的天氣預報服務了（感覺像是承包了一塊地，我們來當?shù)刂鳎@里沒什么難點，從表格存儲中查詢對應的天氣數(shù)據(jù)，按照返回的數(shù)據(jù)格式進行封裝即可。
在 Knative 中，我們可以部署 RESTful API 服務如下：
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}具體實現(xiàn)源代碼 GitHub 地址：https://github.com/knative-sample/weather-service
查詢天氣 RESTful API:
請求 URL
GET /api/weather/query
參數(shù): cityCode：城市區(qū)域代碼。如北京市區(qū)域代碼：110000 date：查詢?nèi)掌?。如格式?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 天氣預報信息示例
測試地址：http://weather-service.default.serverless.kuberun.com/api/weather/query?cityCode=330100&date=2019-09-26
以上就是基于 Knative Serverless 技術(shù)怎樣實現(xiàn)天氣服務，小編相信有部分知識點可能是我們?nèi)粘９ぷ鲿姷交蛴玫降摹ＯＭ隳芡ㄟ^這篇文章學到更多知識。更多詳情敬請關(guān)注創(chuàng)新互聯(lián)行業(yè)資訊頻道。
