Async Processing Best Practices

async-processing-best-practices

Webアプリケーションにおける非同期処理を実現するための実装ガイドです。

いつ利用するか

次の場合にこのガイドラインを参照してください。

• 特定の処理を非同期で実現するかどうかを設計する場合
• 非同期処理を行うインフラを選定・設計する場合
• 非同期処理が必要なバックエンド処理を実装する場合
• 非同期処理のUIをフロントエンドで実装する場合

リファレンス

非同期処理を利用するべきかどうかの判断

HTTPレスポンを返す際に処理が完了している必要がないものについては非同期処理で実現することを検討します。主に以下の観点で非同期処理の採用を考えます。

• ユーザー体験(UX)
  • 処理に1秒以上かかり、UIから実行する際に画面が操作不能になるケースを避けたい場合
• 外部依存
  • 外部APIやサービスなど、自分たちでコントロールできないものを呼び出す際に、相手側のシステムの障害や遅延に性能低下やユーザー体験の低下が発生することが懸念される場合
• 即時性の低さ
  • ユーザーが処理の結果を即座に知らなくてもいい場合
• リソースの保護
  • APIのコネクション数を長い処理によって占有して、接続リソースを不要に消費してしまうことが懸念される場合

非同期処理の実現手法

以下の要素から実現手法を選択します

• Webアプリケーションをホスティングするインフラ環境
• Webアプリケーション実装に利用するフレームワーク・ミドルウェア
• 利用するクラウドサービス(AWS/Google Cloud)
• 実現したいサービスの規模感や求められる堅牢性、予算など

主に以下のパターンによって構築します。

• Ruby on RailsのActiveJob + ActionCableによる実装
  • SidekiqもしくはSolidQueue
  • Railsを利用した非同期処理の実現手法については @references/01_infrastructure.md を参照してください
• TypeScript BullMQによる実装
  • Redisベースの高性能ジョブキュー
  • Node.js/TypeScriptでバックエンドを構築する場合に最適
  • 詳細は @references/02_typescript_bullmq.md を参照してください
• AWS SQSによるタスクキューイングとAWS AppSync Eventsによるイベント送信、DynamoDBによる状態管理
  • AWSのサーバーレスアーキテクチャで実現
  • Lambda + SQS + AppSync Events + DynamoDBの組み合わせ
  • 詳細は @references/03_aws_serverless.md を参照してください
• Google CloudのCloud Tasksを利用したタスク管理とFirestoreによる通知・状態管理
  • Google Cloudのサーバーレスアーキテクチャで実現
  • Cloud Run + Cloud Tasks + Firestoreの組み合わせ
  • 詳細は @references/04_gcp_serverless.md を参照してください

実現手法の比較

非同期処理のバックエンド実装

バックエンド実装時には、以下の観点について各実現手法ごとのベストプラクティスを参照してください。

共通の実装観点

• パラメータの受け取り方

  • シリアライズ可能なデータのみを渡す
  • パラメータサイズの制限を考慮（大きなデータは外部ストレージを使用）
  • IDベースの参照を推奨
  • バリデーションの実装

• エラー発生時の処理と通知

  • リトライ可能なエラーと不可能なエラーの分類
  • リトライ設定（回数、バックオフ戦略）
  • Dead Letter Queue（DLQ）の処理
  • エラー通知（構造化ログ、外部サービス連携）

• 進捗の状態管理

  • 状態管理用データモデルの設計
  • 進捗率の計算と更新
  • リアルタイム通知（WebSocket、SSE、ポーリング）
  • キャンセル処理

• その他

  • 冪等性の確保
  • タイムアウト対策
  • ジョブの分割とチェーン
  • テスト戦略

実現手法別リファレンス

非同期処理のUIを実現するフロントエンド実装

フロントエンド実装時には、以下の観点について各フレームワークごとのベストプラクティスを参照してください。

共通の実装観点

• 非同期処理の呼び出し方

  • フォーム送信による非同期タスクの開始
  • カスタムフックやComposableによる呼び出し管理
  • 二重送信の防止

• 状態管理と表示

  • 進捗状況のリアルタイム表示
  • ポーリングによる状態更新
  • WebSocket/SSEによるプッシュ通知
  • Optimistic Updates（楽観的更新）

• 接続復帰処理

  • WebSocket/SSE接続の自動再接続
  • ページ非表示時の接続管理
  • Visibility APIを使用した状態同期
  • オフライン/オンライン状態の監視

• エラーハンドリング

  • Error Boundaryによるエラー捕捉
  • グローバルエラーハンドリング
  • リトライ機能（Exponential Backoff）
  • ユーザーへのエラー通知

フレームワーク別リファレンス

本番環境へのデプロイ

本番環境にデプロイする際の設定やベストプラクティスは以下を参照してください。

• 本番環境デプロイガイド: @references/13_deployment.md
  • Pumaプラグイン設定
  • ECS/Fargate環境
  • Kubernetes環境
  • CI/CD設定

Solid Cable（ActionCableの代替）

Redis不要でActionCableを使用したい場合は、Solid Cableを利用できます。

• Solid Cableリファレンス: @references/14_solid_cable.md
  • セットアップ方法
  • ActionCableとの違い
  • 設定オプション

トラブルシューティング

問題が発生した場合は以下を参照してください。

• トラブルシューティングガイド: @references/15_troubleshooting.md
  • ジョブが実行されない場合
  • ステータスが更新されない場合
  • WebSocket接続の問題
  • デバッグ方法

環境分離（DB共有時の注意）

ステージング環境と本番環境で同じデータベースを共有している場合、以下の設定が必要です。

Solid Queueのキュー名分離

# config/solid_queue.yml
staging:
  workers:
    - queues:
        - <%= ENV.fetch('QUEUE_PREFIX', 'staging') %>_default

production:
  workers:
    - queues:
        - <%= ENV.fetch('QUEUE_PREFIX', 'production') %>_default

# app/jobs/application_job.rb
class ApplicationJob < ActiveJob::Base
  queue_as do
    prefix = ENV.fetch('QUEUE_PREFIX', Rails.env)
    "#{prefix}_default"
  end
end

Solid Cableのチャンネル分離

# config/cable.yml
staging:
  adapter: solid_cable
  channel_prefix: <%= ENV.fetch('CABLE_PREFIX', 'staging') %>

production:
  adapter: solid_cable
  channel_prefix: <%= ENV.fetch('CABLE_PREFIX', 'production') %>

詳細は @references/13_deployment.md の「環境分離設定」を参照してください。