PDE#2(ingesting)
製造業の IoT プラットフォームでは、毎秒 20 万件のセンサーメッセージが Pub/Sub に届きます。下流の Dataflow ジョブはまれにスキーマ不一致で個別メッセージの処理に失敗します。失敗したメッセージは廃棄せず、原因調査と再投入のために別の場所に保管したいと考えています。Google Cloud で推奨される構成はどれですか？
正解：C
正解の根拠
Pub/Sub の Dead Letter Topic を有効にすると、配信試行回数の上限を超えたメッセージは自動的に別トピックへ転送されます。これにより本流パイプラインを停止させずに障害メッセージを隔離でき、別ジョブで原因分析や再処理が可能です。Dataflow との組み合わせで運用負荷を最小化できます。
サービス比較
| 項目 | Dead Letter Topic (B) | 無限再試行 (C) |
|---|---|---|
| 処理影響 | 本流は継続 | 同一メッセージで詰まる |
| 調査性 | 別トピックで保管 | 蓄積で監視困難 |
| 運用 | Pub/Sub 機能で完結 | 手動介入が必要 |
不正解の理由
- A: ログ書き出しだけでは再投入経路がなく、メッセージ本体を保持できないため要件を満たしません。
- B: Ack 取消は同じ失敗メッセージで再試行ループに入り、本流のレイテンシが大きく悪化します。
- D: Pub/Sub は Cloud Storage を直接購読できず、構成自体が成立しません。
コメント