Flowtas A2A Gateway 開発ガイド
ポータルへ戻る

A2A Gateway 実装・連携ガイド

A2A Gateway は、送信元の AI エージェントと受信側システムとの間に立ち、個人情報（PII）の自動伏字化や緊急遮断（キルスイッチ）を提供するセキュリティプロキシです。
既存プログラムの ①送信先URLの変更 と ②認証ヘッダーの追加 のみで、数分で安全な通信環境を構築できます。

基本設定の仕組み

1. 送信先URLの変更（リバースプロキシ化）

既存プログラムの API 呼び出し先（https://相手先ドメイン/...）を、Gateway が発行する代理URL（https://dev.a2agateway.flowtas.jp/v1/gateway/live/エージェント名）へ書き換えます。Gateway 側にあらかじめ「本来の転送先URL」が紐づけられているため、プログラム側に転送先を記述する必要はありません。

2. リクエストヘッダー（X-API-KEY）の追加

HTTPリクエストのヘッダー情報（Headers）に、Gateway 管理画面で発行した API キーを X-API-KEY: キー文字列 の形式で追加します。これにより、Gateway 側で正規の通信かを判別し、許可された通信のみを高速中継します。

コード実装サンプル (Python)

▼1. 既存のプログラム（修正前） 
import requests

# 既存の宛先URL
URL = "https://api.example.com/v1/orders"

headers = {
    "Content-Type": "application/json"
}

# 送信したいデータ（既存のもの）
data = {
    "order_id": "ORD-999",
    "customer": "山田太郎",
    "phone": "090-1234-5678"
}

# 既存の送信処理
response = requests.post(URL, json=data, headers=headers)
▼2. A2A Gateway導入後のプログラム（基本形）

※ 修正するのは URL と headers の追加部分（カンマ記号 , に注意） だけです。

import requests

# 【修正点1】宛先URLを A2A Gateway の専用エンドポイントに変更
URL = "https://dev.a2agateway.flowtas.jp/v1/gateway/live/agent_001"  # ← 専用エンドポイントURLに置き換え！

# 【修正点2】ヘッダーに Gateway の API キーを1行追加
headers = {
    "Content-Type": "application/json",  # ← 末尾にカンマ「,」を追加！
    "X-API-KEY": "a2a_live_abc123xyz..."  # ← 専用 API KEYに置き換え！
}

# 送信したいデータ（既存のまま変更なし！）
data = {
    "order_id": "ORD-999",
    "customer": "山田太郎",
    "phone": "090-1234-5678"
}

# 送信処理（既存のまま変更なし！）
response = requests.post(URL, json=data, headers=headers)
▼3. 推奨：エラーハンドリングと403遮断対策（推奨コード）

緊急キルスイッチ発動時やAPIキー無効時は 403 Forbidden が返ります。無駄なリトライをせず即座に例外処理を行うコードの実装を推奨します。 

import requests
import time

URL = "https://dev.a2agateway.flowtas.jp/v1/gateway/live/agent_001"
headers = {
    "Content-Type": "application/json",
    "X-API-KEY": "a2a_live_abc123xyz..."
}
data = {"customer": "山田太郎", "phone": "090-1234-5678"}

try:
    response = requests.post(URL, json=data, headers=headers, timeout=5)
    
    # 正常処理 (200 OK)
    if response.status_code == 200:
        print("送信成功:", response.json())
        
    # 通信遮断 (403 Forbidden) ※キルスイッチ発動時など
    elif response.status_code == 403:
        print("【警告】Gatewayにより通信が遮断されました(403)。リトライを中断しログを記録します。")
        # アラート通知等の例外処理を行う
        
    # 一時的なエラー (500系など)
    else:
        print(f"一時的なステータスエラー: {response.status_code}")

except requests.exceptions.RequestException as e:
    print(f"通信例外エラーが発生しました: {e}")

発信側・受信側でのよくある事前確認・調整事項

開発者向け テクニカルQ&A

Q. A2A Gateway を挟むことによる通信遅延（レイテンシ）はどのくらいですか？

ミリ秒（ms）単位の超高速インメモリ処理を行っているため、人間の体感や通常の Web API 通信においては実質影響を受けないレベルです。ポータル画面（index.html）の「LIVE LOGS」から各通信のレイテンシをリアルタイムで測定・検証可能です。

Q. PoC検証（導通テスト）時に、正しく伏字化（マスキング）が行われているか確認できますか？

ポータル画面（index.html）の「A2A COMMUNICATION LIVE LOGS」にて、「送信生データ（ビフォー）」と「Gateway通過後データ（アフター）」を横並びで比較・確認できます。特別なデバッグプログラムを記述することなく画面上で動作エビデンスを確認できます。

Q. 不要になった API キーの削除や一時停止は即時反映されますか？

はい、ポータル画面から「一時停止（緊急キル）」を行うと、ミリ秒単位で即座に反映されます。無効化された API キーでのリクエストはGatewayの入り口で即座に拒否（HTTP 403 Forbidden）されます。

Q. A2A Gateway 自体がデータを保管したり、非同期で転送したりするのですか？

いいえ、Gateway 自体が第三者へデータを独自蓄積・非同期受渡しするものではありません。送信元と受信側との間でリアルタイムに通信内容を検査・安全化してそのまま転送する透過型セキュリティプロキシ（土管）です。