Atlas Stream Processing バーティカル自動スケーリング

スケールアップの動作

Atlas Stream Processing では、プロセッサのリソース使用量が継続的な期間、次のいずれかのスケールアップしきい値を超えると、プロセッサが 1 つ上の階層にスケールアップされます。

• CPU 使用率が 90% を超えて 60 分になりました

• メモリ使用量が 60 分の場合は 80% を超え、または 30 秒の場合は 90% を超えています

プロセッサーのメモリが不足した場合にも、Atlas Stream Processing はプロセッサーを増やします。オートスケーリングが有効になっている場合、メモリ不足の状態では、プロセッサーが失敗するのではなく、次の高い階層へスケールアップします。

スケールアップは、持続的なリソース負荷に迅速に対応し、プロセッサの可用性を保護します。

Atlas Stream Processing では、次の高い階層が設定された maxTiger 以下の場合にのみプロセッサがスケールアップされます。

スケールダウンの動作

Atlas Stream Processing は、プロセッサーの CPU とメモリ使用量がスケールダウンしきい値を 2 日以上下回ったままの場合、プロセッサーを次の低い階層にスケールダウンします。増やすダウンしきい値は、1 つ下の階層の増やすアップしきい値から、プロセッサーがすぐに増やすアップするのを防止する 10% のバッファを引いた値です。この2日間の安定化期間により、階層間の頻繁な拡大を防ぐため、拡大が意図的に遅くなります。

Atlas Stream Processing では、次の下位階層が設定された最小階層以上の場合にのみプロセッサがスケールダウンされます。

階層と実効階層

オートスケーリングが有効になっている場合、Atlas Stream Processing はプロセッサの 2 つの階層値を追跡します。

• tier: 設定したベースライン階層。Atlas Stream Processing は、オートスケーリングによってこの値を変更しません。新しいベースラインを設定した場合にのみ変更され、それはプロセッサーを次回起動したときに適用されます。

• effectiveTier: プロセッサが実際に実行中いる階層を示す読み取り専用の値。オートスケーリングが有効になっている場合、Atlas Stream Processing は、minTier と maxTier で設定された範囲内で effectiveTier を調整します。オートスケーリングが無効になっている場合、effectiveTier は tier と一致します。

オートスケーリングによってプロセッサの effectiveTier が変更された後にプロセッサを停止すると、Atlas Stream Processing は最初に起動した tier ではなく、最後の effectiveTier でプロセッサを再起動します。この動作により、プロセッサは再度オートスケールを待たずに以前のワークロードを再開できます。

プロセッサのオートスケーリング構成と現在の階層を表示するには、sp.processor.stats() メソッドを使用します。出力には、tier ベースライン、読み取り専用のeffectiveTier autoscaling、minTier と を持つ オブジェクトが含まれます。maxTier

sp.processor.stats()
{
  ok: 1,
  name: 'sampleProc',
  state: 'STARTED',
  tier: 'SP10',
  effectiveTier: 'SP10',
  autoscaling: { minTier: 'SP2', maxTier: 'SP50' },
  stats: {
    ...
  },
  ...
}

階層アライメント

構成されたオートスケーリング範囲外の tier 値（minTier 未満または maxTier を超える値）でプロセッサを起動すると、プロセッサはエラーを返し、起動しません。

最大階層でのリソース使用量

プロセッサが構成された maxTier でリソースを使い果たした場合、Atlas Stream Processing は次のように動作します。

• メモリの消耗: プロセッサーはメモリ不足エラーにより失敗します。

• CPU 消耗: プロセッサは動作を続けます。

プロセッサーが maxTier に達し、ワークロードを処理しきれない場合は、パイプラインのロジックを最適化するか、maxTier を増やすことを検討してください。

オートスケーリング イベントの監視

Atlas Stream Processing は、各増やす（スケールアップ）および増やす（スケールダウン）イベントをレコードします。各レコードには、プロセッサおよび Stream Processing ワークスペース、イベントがスケールアップかスケールダウンか、プロセッサが移動した元の階層と移動先の階層、およびイベントをトリガーしたメトリクスが識別されています。拡大イベントの表示方法とアラートの設定方法を学ぶには、モニター Stream Processors。を参照してください。