Container Service for Kubernetes:MongoDB イベントソースに基づくイベント駆動型自動スケーリングの利用

1. サンプル用の名前空間を作成

本サンプルでは、データベースをデプロイするための mongodb 名前空間と、自動スケーリング設定を配置するための mongodb-test 名前空間を使用します。

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. MongoDB をデプロイします。

   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 名は: $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")'
   
   # コレクションの作成
   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                # クエリ対象のコレクション
              query: '{"type":"mp4","state":"waiting"}'  # mp4 ファイルで「waiting」状態のレコードに対してジョブを起動
              queryValue: "1"
            authenticationRef:
              name: mongodb-trigger

      query フィールドは、データの条件を定義します。ack-keda が MongoDB 内でこの条件に一致するドキュメントを検出すると、Job リソースが起動されます。

   2. ScaledJob をデプロイします。

      kubectl apply -f scaledJob.yaml