Container Service for Kubernetes:Gunakan penskalaan berbasis peristiwa berdasarkan sumber peristiwa MongoDB

1. Buat namespace contoh

Contoh ini menggunakan namespace mongodb untuk deploy database dan namespace mongodb-test untuk konfigurasi penskalaan otomatis.

kubectl create ns mongodb
kubectl create ns mongodb-test

2. Deploy MongoDB

Jika Anda sudah memiliki layanan MongoDB, lewati langkah ini.

1. Buat mongoDB.yaml.

   Penting

   Layanan MongoDB ini hanya untuk demonstrasi dan tidak menyediakan ketersediaan tinggi. Jangan gunakan di lingkungan produksi.

   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. Deploy MongoDB.

   kubectl apply -f mongoDB.yaml

3. Inisialisasi database MongoDB

1. Ambil nama pod MongoDB.

   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. Di database test, buat pengguna test_user dan koleksi test_collection.

   # Create user
   kubectl exec -n mongodb ${MONGO_POD_NAME} -- mongo --eval 'db.createUser({ user:"test_user",pwd:"test_password",roles:[{ role:"readWrite", db: "test"}]})'
   
   # Authenticate user
   kubectl exec -n mongodb ${MONGO_POD_NAME} -- mongo --eval 'db.auth("test_user","test_password")'
   
   # Create collection
   kubectl exec -n mongodb ${MONGO_POD_NAME} -- mongo test --eval 'db.createCollection("test_collection")'

4. Konfigurasi TriggerAuthentication dan ScaledJob

ack-keda menggunakan resource TriggerAuthentication untuk mengelola kredensial secara aman saat terhubung ke sumber peristiwa. ScaledJob adalah resource inti ack-keda yang mendefinisikan aturan penskalaan, interval polling, dan templat Job yang akan dijalankan.

1. Buat auth.yaml dan deploy TriggerAuthentication.

   Untuk sumber peristiwa MongoDB, bidang secretTargetRef dalam TriggerAuthentication membaca string koneksi dari Secret yang ditentukan ke ack-keda untuk melakukan otentikasi dengan 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. Deploy TriggerAuthentication.

   kubectl apply -f auth.yaml

3. Deploy ScaledJob.

   ScaledJob mengonfigurasi templat Job dan menentukan database serta ekspresi kueri yang digunakan. Contoh berikut mengkueri test_collection di database test untuk dokumen yang sesuai dengan {"type":"mp4","state":"waiting"}—ini merepresentasikan tugas transkoding yang tertunda.

   1. Buat scaledJob.yaml.

      apiVersion: keda.sh/v1alpha1
      kind: ScaledJob
      metadata:
        name: mongodb-job
        namespace: mongodb-test
      spec:
        jobTargetRef:
          # Job template configuration
          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                               # Database to query
              collection: test_collection                # Collection to query
              query: '{"type":"mp4","state":"waiting"}'  # Launch jobs for mp4 files with "waiting" status
              queryValue: "1"
            authenticationRef:
              name: mongodb-trigger

      Bidang query mendefinisikan kondisi data. Ketika ack-keda menemukan dokumen di MongoDB yang sesuai dengan kondisi ini, ia akan membuat resource Job.

   2. Deploy ScaledJob.

      kubectl apply -f scaledJob.yaml