Knative 實戰：基於 Knative Serverless 技術實現天氣服務-下篇

上一期咱們介紹瞭如何基於 Knative Serverless 技術實現天氣服務-上篇，首先咱們先來回顧一下上篇介紹的內容：

• 經過高德天氣 API 接口，每隔 3 個小時定時發送定時事件，將國內城市將來 3 天的天氣信息，存儲更新到表格存儲
• 提供 RESTful API 查詢天氣信息

接下來咱們介紹如何經過表格存儲提供的通道服務，實現 Knative 對接表格存儲事件源，訂閱並經過釘釘發送天氣提醒通知。

總體架構

回顧一下總體架構：

• 經過 CronJob 事件源，每隔 3 個小時定時發送定時事件，將國內城市將來 3 天的天氣信息，存儲更新到表格存儲
• 提供 RESTful API 查詢天氣信息
• 經過表格存儲提供的通道服務，實現 TableStore 事件源
• 經過 Borker/Trigger 事件驅動模型，訂閱天氣信息
• 根據訂閱收到的天氣信息進行釘釘消息通知。如明天下雨，提示帶傘等

基於 Knative 實現天氣服務-下篇

首先咱們介紹一下表格存儲提供的通道服務。通道服務（Tunnel Service）是基於表格存儲數據接口之上的全增量一體化服務。通道服務爲您提供了增量、全量、增量加全量三種類型的分佈式數據實時消費通道。經過爲數據表創建數據通道，您能夠簡單地實現對錶中歷史存量和新增數據的消費處理。經過數據通道能夠進行數據同步、事件驅動、流式數據處理以及數據搬遷。這裏事件驅動正好契合咱們的場景。

先看一下處理流程圖：

• 定義 TableStore 事件源，用於接收通道服務數據
• 經過 Borker/Trigger 事件驅動模型，訂閱天氣信息
• 訂閱接收到的天氣信息發送給天氣提醒服務，進行釘釘消息通知

下面咱們來詳細介紹一下。

自定義 TableStore 事件源

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

咱們這裏定義數據源爲 AliTablestoreSource。代碼實現主要分爲兩部分：

1. 資源控制器-Controller：接收 AliTablestoreSource 資源，在通道服務中建立 Tunnel
2. 事件接收器-Receiver：經過 Tunnel Client 監聽事件，並將接收到的事件發送到目標服務( Broker）

關於自定義 TableStore 事件源實現參見 GitHub 源代碼：https://github.com/knative-sample/tablestore-source

部署自定義事件源服務以下：

從 https://github.com/knative-sample/tablestore-source/tree/master/config 中能夠獲取事件源部署文件，執行下面的操做：

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

部署完成以後，咱們能夠看到資源控制器已經開始運行：

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

建立事件源

因爲咱們是經過 Knative Eventing 中 Broker/Trigger 事件驅動模型對天氣事件進行處理。首先咱們建立用於數據接收的 Broker 服務。

建立 Broker

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

建立事件源實例

這裏須要說明一下，建立事件源實例其實就是在表格存儲中建立通道服務，那麼就須要配置訪問通道服務的地址、accessKeyId 和 accessKeySecret，這裏參照格式：{ "url":"https://xxx.cn-beijing.ots.aliyuncs.com/", "accessKeyId":"xxxx","accessKeySecret":"xxxx" } 設置並進行 base64 編碼。將結果設置到以下 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>"

建立 RBAC 權限：

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

建立 AliTablestoreSource 實例，這裏咱們設置接收事件的 sink 爲上面建立的 Broker 服務。

---
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

建立完成以後，咱們能夠看到運行中的事件源：

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

訂閱事件和通知提醒

建立天氣提醒服務

如何進行釘釘通知呢，咱們能夠建立一個釘釘的羣組（能夠把家裏人組成一個釘釘羣，天氣異常時，給家人一個提醒），添加羣機器人:

獲取 webhook :

這裏咱們假設北京 (110000)，日期：2019-10-13, 若是天氣有雨，就經過釘釘發送通知提醒，則服務配置以下：

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

關於釘釘提醒服務具體實現參見 GitHub 源代碼：https://github.com/knative-sample/dingtalk-weather-service

建立訂閱

最後咱們建立 Trigger訂閱天氣事件，而且觸發天氣提醒服務：

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, 天氣有雨，會收到以下的釘釘提醒：

這裏其實還有待完善的地方：

• 是否能夠基於城市進行訂閱（只訂閱目標城市）？
• 是否能夠指定時間發送消息提醒（當天晚上 8 點準時推送第 2 天的天氣提醒信息）？

有興趣的能夠繼續完善當前的天氣服務功能。

小結

本文介紹瞭如何在 Knative 中自定義事件源，並經過事件驅動接收天氣變化信息，訂閱並經過釘釘推送通知提醒。這樣基於 Knative Serverless 技術實現天氣服務總體實現就介紹完了。有興趣的同窗能夠針對上面提到的不足繼續研究。仍是那句話，作好天氣服務不容易，但還好我有 Knative。

歡迎加入 Knative 交流羣

「 阿里巴巴雲原生微信公衆號（ID：Alicloudnative）關注微服務、Serverless、容器、Service Mesh等技術領域、聚焦雲原生流行技術趨勢、雲原生大規模的落地實踐，作最懂雲原生開發者的技術公衆號。」

原文出處：https://www.cnblogs.com/alisystemsoftware/p/11661185.html