如何在Knative中自定義事件源并通過(guò)事件驅(qū)動(dòng)接收天氣變化信息，很多新手對(duì)此不是很清楚，為了幫助大家解決這個(gè)難題，下面小編將為大家詳細(xì)講解，有這方面需求的人可以來(lái)學(xué)習(xí)下，希望你能有所收獲。

網(wǎng)站建設(shè)哪家好，找創(chuàng)新互聯(lián)建站！專(zhuān)注于網(wǎng)頁(yè)設(shè)計(jì)、網(wǎng)站建設(shè)、微信開(kāi)發(fā)、微信平臺(tái)小程序開(kāi)發(fā)、集團(tuán)企業(yè)網(wǎng)站建設(shè)等服務(wù)項(xiàng)目。為回饋新老客戶(hù)創(chuàng)新互聯(lián)還提供了龍泉驛免費(fèi)建站歡迎大家使用！

接下來(lái)我們介紹如何通過(guò)表格存儲(chǔ)提供的通道服務(wù)，實(shí)現(xiàn) Knative 對(duì)接表格存儲(chǔ)事件源，訂閱并通過(guò)釘釘發(fā)送天氣提醒通知。

整體架構(gòu)

回顧一下整體架構(gòu)：

• 通過(guò) CronJob 事件源，每隔 3 個(gè)小時(shí)定時(shí)發(fā)送定時(shí)事件，將國(guó)內(nèi)城市未來(lái) 3 天的天氣信息，存儲(chǔ)更新到表格存儲(chǔ)

• 提供 RESTful API 查詢(xún)天氣信息

• 通過(guò)表格存儲(chǔ)提供的通道服務(wù)，實(shí)現(xiàn) TableStore 事件源

• 通過(guò) Borker/Trigger 事件驅(qū)動(dòng)模型，訂閱天氣信息

• 根據(jù)訂閱收到的天氣信息進(jìn)行釘釘消息通知。如明天下雨，提示帶傘等

基于 Knative 實(shí)現(xiàn)天氣服務(wù)-下篇

首先我們介紹一下表格存儲(chǔ)提供的通道服務(wù)。通道服務(wù)（Tunnel Service）是基于表格存儲(chǔ)數(shù)據(jù)接口之上的全增量一體化服務(wù)。通道服務(wù)為您提供了增量、全量、增量加全量三種類(lèi)型的分布式數(shù)據(jù)實(shí)時(shí)消費(fèi)通道。通過(guò)為數(shù)據(jù)表建立數(shù)據(jù)通道，您可以簡(jiǎn)單地實(shí)現(xiàn)對(duì)表中歷史存量和新增數(shù)據(jù)的消費(fèi)處理。通過(guò)數(shù)據(jù)通道可以進(jìn)行數(shù)據(jù)同步、事件驅(qū)動(dòng)、流式數(shù)據(jù)處理以及數(shù)據(jù)搬遷。這里事件驅(qū)動(dòng)正好契合我們的場(chǎng)景。

先看一下處理流程圖：

• 定義 TableStore 事件源，用于接收通道服務(wù)數(shù)據(jù)

• 通過(guò) Borker/Trigger 事件驅(qū)動(dòng)模型，訂閱天氣信息

• 訂閱接收到的天氣信息發(fā)送給天氣提醒服務(wù)，進(jìn)行釘釘消息通知

下面我們來(lái)詳細(xì)介紹一下。

自定義 TableStore 事件源

在 Knative 中自定義事件源其實(shí)很容易，可以參考官方提供的自定義事件源的實(shí)例：https://github.com/knative/docs/tree/master/docs/eventing/samples/writing-a-source。

我們這里定義數(shù)據(jù)源為 AliTablestoreSource。代碼實(shí)現(xiàn)主要分為兩部分：

1. 資源控制器-Controller：接收 AliTablestoreSource 資源，在通道服務(wù)中創(chuàng)建 Tunnel

2. 事件接收器-Receiver：通過(guò) Tunnel Client 監(jiān)聽(tīng)事件，并將接收到的事件發(fā)送到目標(biāo)服務(wù)( Broker）

關(guān)于自定義 TableStore 事件源實(shí)現(xiàn)參見(jiàn) GitHub 源代碼：https://github.com/knative-sample/tablestore-source

部署自定義事件源服務(wù)如下：

從 https://github.com/knative-sample/tablestore-source/tree/master/config 中可以獲取事件源部署文件，執(zhí)行下面的操作：

kubectl apply -f 200-serviceaccount.yaml -f 201-clusterrole.yaml -f 202-clusterrolebinding.yaml -f 300-alitablestoresource.yaml -f 400-controller-service.yaml -f 500-controller.yaml -f 600-istioegress.yaml

部署完成之后，我們可以看到資源控制器已經(jīng)開(kāi)始運(yùn)行：

[root@iZ8vb5wa3qv1gwrgb3lxqpZ config]# kubectl -n knative-sources get pods
NAME                                 READY   STATUS    RESTARTS   AGE
alitablestore-controller-manager-0   1/1     Running   0          4h22m

創(chuàng)建事件源

由于我們是通過(guò) Knative Eventing 中 Broker/Trigger 事件驅(qū)動(dòng)模型對(duì)天氣事件進(jìn)行處理。首先我們創(chuàng)建用于數(shù)據(jù)接收的 Broker 服務(wù)。

創(chuàng)建 Broker

apiVersion: eventing.knative.dev/v1alpha1
kind: Broker
metadata:
  name: weather
spec:
  channelTemplateSpec:
    apiVersion: messaging.knative.dev/v1alpha1
    kind: InMemoryChannel

創(chuàng)建事件源實(shí)例

這里需要說(shuō)明一下，創(chuàng)建事件源實(shí)例其實(shí)就是在表格存儲(chǔ)中創(chuàng)建通道服務(wù)，那么就需要配置訪(fǎng)問(wèn)通道服務(wù)的地址、accessKeyId 和 accessKeySecret，這里參照格式：{ "url":"https://xxx.cn-beijing.ots.aliyuncs.com/", "accessKeyId":"xxxx","accessKeySecret":"xxxx" } 設(shè)置并進(jìn)行 base64 編碼。將結(jié)果設(shè)置到如下 Secret 配置文件 alitablestore 屬性中：

apiVersion: v1
kind: Secret
metadata:
  name: alitablestore-secret
type: Opaque
data:
  # { "url":"https://xxx.cn-beijing.ots.aliyuncs.com/", "accessKeyId":"xxxx","accessKeySecret":"xxxx" }
  alitablestore: "<base64>"

創(chuàng)建 RBAC 權(quán)限：

apiVersion: rbac.authorization.k8s.io/v1
kind: ClusterRoleBinding
metadata:
  name: eventing-sources-alitablestore
subjects:
- kind: ServiceAccount
  name: alitablestore-sa
  namespace: default
roleRef:
  apiGroup: rbac.authorization.k8s.io
  kind: ClusterRole
  name: eventing-sources-alitablestore-controller

---
apiVersion: v1
kind: ServiceAccount
metadata:
  name: alitablestore-sa
secrets:
- name: alitablestore-secret

創(chuàng)建 AliTablestoreSource 實(shí)例，這里我們?cè)O(shè)置接收事件的 sink 為上面創(chuàng)建的 Broker 服務(wù)。

---
apiVersion: sources.eventing.knative.dev/v1alpha1
kind: AliTablestoreSource
metadata:
  labels:
    controller-tools.k8s.io: "1.0"
  name: alitablestoresource
spec:
  # Add fields here
  serviceAccountName: alitablestore-sa
  accessToken:
    secretKeyRef:
      name: alitablestore-secret
      key: alitablestore
  tableName: weather
  instance: knative-weather
  sink:
    apiVersion: eventing.knative.dev/v1alpha1
    kind: Broker
    name: weather

創(chuàng)建完成之后，我們可以看到運(yùn)行中的事件源：

[root@iZ8vb5wa3qv1gwrgb3lxqpZ config]# kubectl get pods
NAME                                                              READY   STATUS      RESTARTS   AGE
tablestore-alitablestoresource-9sjqx-656c5bf84b-pbhvw             1/1     Running     0          4h9m

訂閱事件和通知提醒

創(chuàng)建天氣提醒服務(wù)

如何進(jìn)行釘釘通知呢，我們可以創(chuàng)建一個(gè)釘釘?shù)娜航M（可以把家里人組成一個(gè)釘釘群，天氣異常時(shí)，給家人一個(gè)提醒），添加群機(jī)器人:

獲取 webhook :

這里我們假設(shè)北京 (110000)，日期：2019-10-13, 如果天氣有雨，就通過(guò)釘釘發(fā)送通知提醒，則服務(wù)配置如下：

apiVersion: serving.knative.dev/v1beta1
kind: Service
metadata:
  name: day-weather
spec:
  template:
    spec:
      containers:
      - args:
        - --dingtalkurl=https://oapi.dingtalk.com/robot/send?access_token=xxxxxx
        - --adcode=110000
        - --date=2019-10-13
        - --dayweather=雨
        image: registry.cn-hangzhou.aliyuncs.com/knative-sample/dingtalk-weather-service:1.2

關(guān)于釘釘提醒服務(wù)具體實(shí)現(xiàn)參見(jiàn) GitHub 源代碼：https://github.com/knative-sample/dingtalk-weather-service

創(chuàng)建訂閱

最后我們創(chuàng)建 Trigger訂閱天氣事件，并且觸發(fā)天氣提醒服務(wù)：

apiVersion: eventing.knative.dev/v1alpha1
kind: Trigger
metadata:
  name: weather-trigger
spec:
  broker: weather
  subscriber:
    ref:
      apiVersion: serving.knative.dev/v1alpha1
      kind: Service
      name: day-weather

訂閱之后，如果北京 (110000)，日期：2019-10-13, 天氣有雨，會(huì)收到如下的釘釘提醒：

這里其實(shí)還有待完善的地方：

• 是否可以基于城市進(jìn)行訂閱（只訂閱目標(biāo)城市）？

• 是否可以指定時(shí)間發(fā)送消息提醒（當(dāng)天晚上 8 點(diǎn)準(zhǔn)時(shí)推送第 2 天的天氣提醒信息）？

如何在Knative 中自定義事件源，并通過(guò)事件驅(qū)動(dòng)接收天氣變化信息，訂閱并通過(guò)釘釘推送通知提醒。這樣基于 Knative Serverless 技術(shù)實(shí)現(xiàn)天氣服務(wù)整體實(shí)現(xiàn)就介紹完了。有興趣的同學(xué)可以針對(duì)上面提到的不足繼續(xù)研究。還是那句話(huà)，做好天氣服務(wù)不容易，但還好我有 Knative。

看完上述內(nèi)容是否對(duì)您有幫助呢？如果還想對(duì)相關(guān)知識(shí)有進(jìn)一步的了解或閱讀更多相關(guān)文章，請(qǐng)關(guān)注創(chuàng)新互聯(lián)行業(yè)資訊頻道，感謝您對(duì)創(chuàng)新互聯(lián)的支持。

新聞名稱(chēng)：如何在Knative中自定義事件源并通過(guò)事件驅(qū)動(dòng)接收天氣變化信息
標(biāo)題鏈接：http://chinadenli.net/article44/gpdpee.html

成都網(wǎng)站建設(shè)公司_創(chuàng)新互聯(lián)，為您提供網(wǎng)頁(yè)設(shè)計(jì)公司、建站公司、小程序開(kāi)發(fā)、ChatGPT、網(wǎng)站設(shè)計(jì)公司、域名注冊(cè)

廣告

聲明：本網(wǎng)站發(fā)布的內(nèi)容（圖片、視頻和文字）以用戶(hù)投稿、用戶(hù)轉(zhuǎn)載內(nèi)容為主，如果涉及侵權(quán)請(qǐng)盡快告知，我們將會(huì)在第一時(shí)間刪除。文章觀(guān)點(diǎn)不代表本網(wǎng)站立場(chǎng)，如需處理請(qǐng)聯(lián)系客服。電話(huà)：028-86922220；郵箱：631063699@qq.com。內(nèi)容未經(jīng)允許不得轉(zhuǎn)載，或轉(zhuǎn)載時(shí)需注明來(lái)源： 創(chuàng)新互聯(lián)