非同期外部 APIs呼び出し

サードパーティーサービスへの長時間実行されるリクエストのライフサイクルを処理するように Step Functions を設定します。ワークフローを一時停止し、タスクトークンが続行するのを待つリクエストステップを追加します。コールバックが受信されない場合にワークフローが失敗するようにタイムアウトを設定します。

タスクトークンとリクエストペイロードを Amazon Simple Queue Service キューに送信します。Amazon CloudWatch を使用してキューの長さをモニタリングし、長さが制限を超えた場合は契約の調整を検討してください。

AWS Lambda を使用して Amazon SQSポーリングし、明示的な Step Functions ワークフローをトリガーします。ポーリングバッチサイズ、予約済み同時実行数、最大同時実行数を使用して、呼び出しレートを制御します。

システムが契約された RPS に準拠するためにより低い呼び出しレートを必要とする場合は、AWS AppConfig によって制御される Lambda 内に動的遅延を追加します。

Step Functions は、契約された RPS に準拠するようにレート制限が設定されている Amazon API Gateway HTTP プロキシ API を呼び出します。

リクエストキューから消費されたペイロードを送信する外部のサードパーティーの非同期サービス API を呼び出し、ジョブ ID を受け取ります。Amazon SQS を使用して、失敗したリクエストをデッドレターキュー (DLQ) に送信します。

ワークフローのタスクトークンと受信したジョブ ID を Amazon DynamoDB で実装されたトークンストアに保存します。

外部サービスが完了すると、API Gateway で実装されたコールバックウェブフックエンドポイントで、完了したジョブ ID を受け取ります。

API Gateway マッピングテンプレートを使用して外部コールバックを変換し、ペイロードとジョブ ID を Amazon SQS キューに追加して、発信者にすぐに応答します。

Lambda を使用してコールバック Amazon SQS キューをポーリングし、トークンストアをクエリし、トークンを使用して待機中のワークフローをブロック解除します。失敗したメッセージをコールバック DLQ に保存します。

ワークフローで、ジョブ ID を次のステップに渡し、Step Functions プロセッサを呼び出して、ジョブ ID で外部のサードパーティーの結果ストアから結果を取得します。外部サービスの結果を処理します。