Container Service for Kubernetes：基於MongoDB事件來源使用事件驅動伸縮

1. 建立樣本命名空間

本樣本將使用mongodb命名空間部署資料庫，使用mongodb-test命名空間部署Auto Scaling相關配置。

kubectl create ns mongodb
kubectl create ns mongodb-test

2. 部署MongoDB

如已有MongoDB服務，可跳過。

1. 建立mongoDB.yaml。

   重要

   此MongoDB服務僅用於功能示範，不具備高可用性，請勿用於生產環境。

   apiVersion: apps/v1
   kind: Deployment
   metadata:
     name: mongodb
     namespace: mongodb
   spec:
     replicas: 1
     selector:
       matchLabels:
         name: mongodb
     template:
       metadata:
         labels:
           name: mongodb
       spec:
         containers:
         - name: mongodb
           image: registry-cn-shanghai.ack.aliyuncs.com/acs/mongo:v5.0.0
           imagePullPolicy: IfNotPresent
           ports:
           - containerPort: 27017
             name: mongodb
             protocol: TCP
   ---
   kind: Service
   apiVersion: v1
   metadata:
     name: mongodb-svc
     namespace: mongodb
   spec:
     type: ClusterIP
     ports:
     - name: mongodb
       port: 27017
       targetPort: 27017
       protocol: TCP
     selector:
       name: mongodb

2. 部署Mongo DB。

   kubectl apply -f mongoDB.yaml

3. 初始化MongoDB資料庫

1. 擷取MongoDB Pod名稱。

   MONGO_POD_NAME=$(kubectl get pods -n mongodb -l name=mongodb -o jsonpath='{.items[0].metadata.name}')
   echo "MongoDB Pod name is: $MONGO_POD_NAME"

2. 在test資料庫中建立使用者test_user並建立test_collection。

   # 建立使用者
   kubectl exec -n mongodb ${MONGO_POD_NAME} -- mongo --eval 'db.createUser({ user:"test_user",pwd:"test_password",roles:[{ role:"readWrite", db: "test"}]})'
   
   # 驗證使用者
   kubectl exec -n mongodb ${MONGO_POD_NAME} -- mongo --eval 'db.auth("test_user","test_password")'
   
   # 建立Collection
   kubectl exec -n mongodb ${MONGO_POD_NAME} -- mongo test --eval 'db.createCollection("test_collection")'

4. 配置TriggerAuthentication和ScaledJob

ack-keda通過TriggerAuthentication資源來安全地管理事件來源的串連憑證。ScaledJob是ack-keda的核心資源，用於定義伸縮規則、輪詢間隔以及待執行的Job工作範本。

1. 建立auth.yaml，部署TriggerAuthentication。

   例如對於MongoDB事件來源，TriggerAuthentication中的secretTargetRef欄位會將指定Secret中的串連方式讀取到ack-keda中，完成對MongoDB的登入認證。

   apiVersion: keda.sh/v1alpha1
   kind: TriggerAuthentication
   metadata:
     name: mongodb-trigger
     namespace: mongodb-test
   spec:
     secretTargetRef:
       - parameter: connectionString
         name: mongodb-secret
         key: connect
   ---
   apiVersion: v1
   kind: Secret
   metadata:
     name: mongodb-secret
     namespace: mongodb-test
   type: Opaque
   data:
     connect: bW9uZ29kYjovL3Rlc3RfdXNlcjp0ZXN0X3Bhc3N3b3JkQG1vbmdvZGItc3ZjLm1vbmdvZGIuc3ZjLmNsdXN0ZXIubG9jYWw6MjcwMTcvdGVzdA==

2. 部署TriggerAuthentication。

   kubectl apply -f auth.yaml

3. 部署ScaledJob。

   ScaledJob主要用於配置Job模板以及指定查詢的資料庫及查詢運算式等。以下樣本配置的是從test資料庫中的test_collection中，查詢滿足{"type":"mp4","state":"waiting"}的待轉碼資料。

   1. 建立scaledJob.yaml。

      apiVersion: keda.sh/v1alpha1
      kind: ScaledJob
      metadata:
        name: mongodb-job
        namespace: mongodb-test
      spec:
        jobTargetRef:
          # Job模板配置
          template:
            spec:
              containers:
                - name: mongo-update
                  image: registry-cn-shanghai.ack.aliyuncs.com/acs/mongo-update:v6
                  args:
                    - --dataBase=test
                    - --collection=test_collection
                    - --operation=updateMany
                    - --update={"$set":{"state":"finished"}}
                  env:
                    - name: MONGODB_CONNECTION_STRING
                      value: mongodb://test_user:test_password@mongodb-svc.mongodb.svc.cluster.local:27017/test
                  imagePullPolicy: IfNotPresent
              restartPolicy: Never
          backoffLimit: 1
        pollingInterval: 15
        maxReplicaCount: 5
        successfulJobsHistoryLimit: 0
        failedJobsHistoryLimit: 10
        triggers:
          - type: mongodb
            metadata:
              dbName: test                               # 要查詢的資料庫
              collection: test_collection                # 要查詢的collection
              query: '{"type":"mp4","state":"waiting"}'  # 會對查詢轉碼類型為mp4且狀態是waiting的資料拉起job進行處理
              queryValue: "1"
            authenticationRef:
              name: mongodb-trigger

      query：配置資料條目。當ack-keda查詢到Mongo資料庫中有滿足該條件的資料條目時，將啟動Job資源。

   2. 部署ScaledJob。

      kubectl apply -f scaledJob.yaml