Amazon AppFlow

解決する課題

• SaaS（Salesforce、ServiceNow、Slack など）と AWS の間でデータを連携したいが、API 連携のコードを書きたくない
• データ転送のたびに認証・ページング・リトライ・スロットリングを自前で実装するのが負担
• SaaS から取り込んだデータを S3 や Redshift に集約し、分析や機械学習に使いたい
• 連携処理を安全に（インターネットに出さず）実行したい

主要概念と用語

• フロー: 送信元から送信先へのデータ転送の単位。GUI で定義する設定
• コネクタ: SaaS や AWS サービスへの接続定義。SaaS 側は OAuth などで認証する
• 送信元 / 送信先: 転送の起点と終点。片方は SaaS、もう片方は AWS（S3、Redshift など）が一般的
• トリガー: フローの実行契機。手動 / スケジュール / イベント駆動の方式がある
• マッピング: 送信元フィールドと送信先フィールドの対応付け
• 変換・フィルタ: 転送中の値の加工や、条件に合うレコードだけを通す絞り込み
• コネクタプロファイル: 接続先ごとの認証情報をまとめた再利用可能な設定

仕様・制限・クォータ

• 50 を超える SaaS アプリケーション向けのビルトインコネクタを提供
• 1 アカウントあたり 1,000 フロー、同時実行 1,000、月間 1,000 万回が既定上限
• 送信先として Amazon S3 や Amazon Redshift などを選択でき、S3 ではファイル形式や集約方法を指定できる
• 1 回の実行は最長 48 時間。スケジュールは最短 1 分だが、コネクタ固有の制限が優先される

内部の仕組み

横にスクロール

AppFlow はユーザーが GUI で定義したフローに従い、送信元コネクタを通じて SaaS の API を呼び出してデータを取得し、必要に応じてフィールドマッピング・変換・フィルタを適用したうえで送信先へ書き込みます。認証情報はコネクタプロファイルとして安全に保持され、API のページングやリトライといった煩雑な処理はサービス側が肩代わりするため、利用者はコードを書く必要がありません。

トリガーは三方式あり、手動（オンデマンド実行）、スケジュール（一定間隔の定期実行）、イベント駆動（SaaS 側の変更イベントを契機とするほぼリアルタイムな転送）から選びます。転送はフルマネージドにスケールし、運用者がサーバーを管理する必要はありません。

実行単位の再試行や手動再実行では、追記型の送信先に同じレコードが重複する可能性があります。差分取得の基準列を固定し、業務キーで上書きまたは重複排除できる着地方式にします。SaaS 側のスキーマ変更と API 制限も利用者が監視します。

設計パターン / ベストプラクティス

• SaaS のデータを S3 に集約し、分析基盤（Athena、Redshift、QuickSight など）の入力にする
• 大量データはスケジュール転送＋差分取得で負荷とコストを抑える
• 重要な業務イベントはイベント駆動トリガーでほぼリアルタイムに反映する
• 転送中にフィルタで不要レコードを除外し、変換でフォーマットを整えることで後段の処理を簡素化する
• 認証情報はコネクタプロファイルとして再利用し、各フローへ散らさない

運用・監視

• 各フローの実行履歴で成功・失敗や転送レコード数を確認する
• 実行イベントは CloudWatch や CloudTrail と連携して監視・監査できる
• 失敗時は SaaS 側のスロットリングや認証期限切れ、マッピング不整合を確認する
• スケジュール転送では実行間隔と SaaS API の制限のバランスに注意する

コスト

• 課金は成功したフロー実行回数と処理データ量に基づく。新規データがなくても確認実行は回数に含まれる
• 自作の連携基盤（サーバーや Lambda の運用）と比べ、運用負荷を含めた総コストで評価する
• 不要に短い間隔のスケジュール実行は実行回数を増やすため、要件に見合う間隔にする
• 具体的な料金は変動するため、見積もりは公式の料金ページで確認する

セキュリティ

• 転送データは通信経路で暗号化され、保存時の暗号化には KMS を利用できる
• AWS PrivateLink に対応するコネクタに限り、トラフィックをインターネットに出さず転送できる
• SaaS への認証は OAuth などを用い、認証情報はサービスが安全に管理する
• アクセスは IAM で制御し、最小権限で運用する

Well-Architected の観点

• 運用上の優秀性: ノーコードでフローを定義でき、認証・リトライ・スケーリングをマネージドに任せられるため運用負荷が下がる
• セキュリティ: 暗号化と PrivateLink により安全な連携を実現できる

試験で問われるポイント

関連サービス・比較

ハンズオン / CLI例

# 定義済みのフローをオンデマンドで実行する
aws appflow start-flow --flow-name salesforce-to-s3

# フローの一覧と概要を確認する
aws appflow list-flows

# 特定フローの設定や直近の実行状況を確認する
aws appflow describe-flow --flow-name salesforce-to-s3