プラットフォームイベント開発者ガイド
j検出されなかった例外発生後のプラットフォームイベントトリガーの再開
処理するイベントメッセージ数が少ないほど、トリガーは Apex ガバナ制限に達する可能性が低くなります。プラットフォームイベントトリガーの最大バッチサイズは 2,000 で、Apex オブジェクトトリガーの最大バッチサイズは 200 です。そのため、プラットフォームイベントトリガーは制限に達する可能性がより高く、この機能によるメリットがあります。
トリガー再開のチェックポイントを設定するには、最後に正常に処理されたイベントメッセージの再実行 ID をこのメソッドのコールを使用して設定します。
トリガーの実行フローが意図的に、または未処理の例外 (制限の例外など) によって停止すると、新しいバッチ (Trigger.New の sObject リスト) を使用して、トリガーがもう一度起動します。新しいバッチは、設定した再実行 ID の後のイベントメッセージから開始します。イベントは、変化しない ReplayID 項目値に基づいて、最初の順番で再送信されます。トリガーにより、再送信されるイベントと以降のバッチが順次処理されます。setResumeCheckpoint(replayId) メソッドによってトリガー実行は停止しませんが、明示的に実行を終了することができます。たとえば、バッチサイズを制御するには、一部のイベントメッセージが処理されたら実行フローを終了するようにします。
指定された再生 ID が有効でない場合、このメソッドでは EventBus.InvalidReplayIdException が発生します。無効な再生 ID は、Trigger.new リストのイベントの現在のトリガーバッチにない再生 ID です。
例
このトリガー例では、各反復の最後に処理されたイベントメッセージの再実行 ID を設定します。制限の例外が発生すると、トリガーがもう一度起動し、設定された再実行 ID の後のイベントメッセージから処理が再開されます。
例
この例では、プラットフォームイベントトリガーのバッチサイズを制御し、Apex オブジェクトトリガーのバッチサイズ 200 に一致させます。このトリガーは、すでに処理済みのイベントメッセージの数を数えます。setResumeCheckpoint(replayId) は、正常に処理された各イベントメッセージの後でループの各反復でコールされます。イベント数が 200 件を超えるとループが終了し、トリガーの実行が停止されます。未処理のイベントメッセージがある場合、トリガーは再度起動します。新しいトリガー呼び出しに送信されたイベントメッセージのリストは、設定された再実行 ID のイベントメッセージの後のイベントメッセージで開始されます。
TestBatchSizeTriggerResumption テストクラスには ControlBatchSizeTrigger のテストが含まれます。クラスのテストメソッドは 201 件のイベントメッセージを公開します。次に、deliver() メソッドを 2 回コールしてトリガーを 2 回起動します。最初の呼び出しは、200 件のイベントメッセージを処理します。2 番目の呼び出しは、最後のイベントメッセージを処理します。このテストでは、最後に処理されたイベントメッセージの再実行 ID を保持する EventBusSubscriber.Position プロパティを調査してトリガーが呼び出されたことを検証します。