Container Service for Kubernetes:RocketMQ メトリックに基づくイベント駆動型自動スケーリング (KEDA)

ApsaraMQ for RocketMQ コンソールにログインします。左側のナビゲーションウィンドウで、[インスタンス] をクリックします。

上部のナビゲーションバーで、[中国 (杭州)] などのリージョンを選択します。[インスタンス] ページで、管理対象のインスタンスの名前をクリックします。

左側のナビゲーションウィンドウで、[トピック] をクリックします。トピックの名前と右上に表示されるインスタンス ID (例：keda と mq-cn-uax33****) を記録します。

ARMS コンソールにログインします。

左側のナビゲーションウィンドウで、[Managed Service for Prometheus] > [インスタンス] を選択します。

Cloud Services-{{RegionId}} という名前のインスタンスを見つけて、その名前をクリックします。左側のペインで [設定] をクリックし、[HTTP API URL (Grafana 読み取り URL)] セクションからエンドポイントをコピーします。

次の内容で ScaledObject.yaml という名前のファイルを作成します：

apiVersion: keda.sh/v1alpha1
kind: ScaledObject
metadata:
  name: prometheus-scaledobject
  namespace: default
spec:
  scaleTargetRef:
    name: sample-app          # 必須。スケーリングする Deployment。
  maxReplicaCount: 10         # 必須。スケールアウト時の最大レプリカ数。
  minReplicaCount: 2          # 必須。スケールイン時の最小レプリカ数。
  triggers:
  - type: prometheus
    metadata:
      # 必須フィールド：
      serverAddress: http://cn-beijing.arms.aliyuncs.com:9090/api/v1/prometheus/8cba801fff65546a3012e9a684****/****538168824185/cloud-product-rocketmq/cn-beijing
      # serverAddress を ARMS コンソールからコピーしたエンドポイントに置き換えます。
      metricName: rocketmq_consumer_inflight_messages
      query: sum({__name__=~"rocketmq_consumer_ready_messages|rocketmq_consumer_inflight_messages",instance_id="rmq-cn-uax3xxxxxx",topic=~"keda"}) by (consumer_group)
      # instance_id と topic を実際のインスタンス ID とトピック名に置き換えます。
      threshold: '30'         # レプリカごとのターゲットメッセージバックログ (平均値)。
                              # 例：1 つの Pod が 30 メッセージを処理する場合、
                              # 90 メッセージが蓄積されると 3 レプリカにスケールアウトします。

次の表に、主要なパラメーターを示します：

ScaledObject を適用し、作成されたリソースを検証します：

# スケーリング設定を適用します。
kubectl apply -f ScaledObject.yaml

# ScaledObject が準備完了であることを確認します。
kubectl get ScaledObject

期待される出力：

NAME                      SCALETARGETKIND      SCALETARGETNAME   MIN   MAX   TRIGGERS     AUTHENTICATION   READY   ACTIVE   FALLBACK   AGE
prometheus-scaledobject   apps/v1.Deployment   sample-app        2     10    prometheus                    True    False    False      105s

KEDA は Deployment の HPA を自動的に作成します。それが存在することを確認します：

kubectl get hpa

期待される出力：

NAME                               REFERENCE               TARGETS      MINPODS   MAXPODS   REPLICAS   AGE
keda-hpa-prometheus-scaledobject   Deployment/sample-app   0/30 (avg)   2         10        2          28m

(オプション) Prometheus への読み取りアクセスを保護するには、トークンベースの認証を設定します。詳細な手順を表示するには展開してください

1. ページ上のプロンプトに従って Prometheus トークンを生成します。

2. customAuthHeader および customAuthValue フィールドの値を Base64 でエンコードした Secret を作成します：

   apiVersion: v1
   kind: Secret
   metadata:
     name: keda-prom-secret
     namespace: default
   data:
     customAuthHeader: "QXV0Xxxxxxxlvbg=="
     customAuthValue: "kR2tpT2lJeFpXSmxaVFV6WlMTxxxxxxxxRMVFE0TUdRdE9USXpaQzFqWkRZd09EZ3dOVFV5WWpZaWZRLjlDaFBYU0Q2dEhWc1dQaFlyMGh3ZU5FQjZQZWVETXFjTlYydVNqOU82TTQ="

3. Secret を参照する TriggerAuthentication リソースを作成します：

   apiVersion: keda.sh/v1alpha1
   kind: TriggerAuthentication
   metadata:
     name: keda-prom-creds
     namespace: default
   spec:
     secretTargetRef:
       - parameter: customAuthHeader
         name: keda-prom-secret
         key: customAuthHeader
       - parameter: customAuthValue
         name: keda-prom-secret
         key: customAuthValue

4. TriggerAuthentication を参照するように ScaledObject を更新します：

   apiVersion: keda.sh/v1alpha1
   kind: ScaledObject
   metadata:
     name: prometheus-scaledobject
     namespace: default
   spec:
     scaleTargetRef:
       name: sample-app
     maxReplicaCount: 10
     minReplicaCount: 2
     triggers:
     - type: prometheus
       metadata:
         serverAddress: http://cn-beijing.arms.aliyuncs.com:9090/api/v1/prometheus/8cba801fff65546a3012e9a684****/****538168824185/cloud-product-rocketmq/cn-beijing
         metricName: rocketmq_consumer_inflight_messages
         query: sum({__name__=~"rocketmq_consumer_ready_messages|rocketmq_consumer_inflight_messages",instance_id="rmq-cn-uax3xxxxxx",topic=~"keda"}) by (consumer_group)
         threshold: '30'
         authModes: "custom"
       authenticationRef:
         name: keda-prom-creds   # 上記で作成した TriggerAuthentication を参照します。

   注：この例ではカスタム認証を使用しています。Prometheus スケーラーでサポートされている他の認証方式については、「KEDA コミュニティドキュメント」をご参照ください。