Atelier

Lesson 4 — Agents A2A avec ADK

Consommer un agent distant avec RemoteA2aAgent

5 min read

This content is not translated yet. Showing the original version.

Consommer un agent distant avec RemoteA2aAgent

Un agent distant qui ressemble à un agent local

RemoteA2aAgent (module google.adk.agents.remote_a2a_agent) est un agent ADK dont le « cerveau » est ailleurs : quand on l'exécute, il lit la carte distante, convertit la conversation en message A2A, appelle le serveur, puis reconvertit la tâche reçue en événements ADK.

Ses paramètres utiles dans ADK 2.10 (vérifiés dans le code installé) :

ParamètreRôle
nameidentifiant local (doit être un identifiant Python valide)
agent_cardURL de la carte, chemin d'un fichier JSON ou objet AgentCard
descriptionlue par le modèle de l'orchestrateur pour choisir ; reprise de la carte si vide
timeoutdélai HTTP en secondes (600 par défaut, beaucoup trop pour un devis)
auth_scheme, auth_credentialauthentification ajoutée à la lecture de la carte et aux messages

Délégation ou outil ?

sequenceDiagram
  participant C as "Client"
  participant O as "Orchestrateur"
  participant S as "stock_agent :8101"
  participant P as "pricing_agent :8102"
  C->>O: "Devis pour 12 CHAISE-ERGO"
  O->>S: "SendMessage : stock de CHAISE-ERGO ?"
  S-->>O: "tâche COMPLETED : 12 (Lyon 12, Lille 0)"
  O->>P: "SendMessage : prix de 12 CHAISE-ERGO ?"
  P-->>O: "tâche COMPLETED : 2 041,20 € HT"
  O-->>C: "réponse unique : stock + total HT"

Un devis a besoin des deux réponses dans un seul message. Avec sub_agents, l'orchestrateur transférerait la conversation au premier spécialiste, qui répondrait seul. On enveloppe donc chaque agent distant dans un AgentTool : l'orchestrateur l'appelle comme une fonction et garde la main.

sub_agents=[remote]tools=[AgentTool(agent=remote)]
Qui répond au clientle spécialistel'orchestrateur
Combiner deux résultatsnonoui
Ce que voit le spécialistel'historique de la conversationune demande autonome rédigée par l'orchestrateur

Le code de l'orchestrateur

files/orchestrator.py
def build_orchestrator(found: list[dict], missing: list[str], token: str) -> Agent:
    scheme, cred = bearer_auth(token)
    remotes = [RemoteA2aAgent(name=a["name"], description=a["description"], agent_card=a["card_url"],
                              timeout=CALL_TIMEOUT, auth_scheme=scheme, auth_credential=cred)
               for a in found]
    catalogue = "\n".join(f"- {a['name']} : {a['description']}" for a in found) or "- (aucun)"
    absent = ", ".join(missing) or "aucun"
    return Agent(
        name="orchestrator", model=MODEL,
        description="Répond aux demandes de devis en combinant stock et tarification.",
        instruction=(
            "Tu es l'orchestrateur des devis. Agents disponibles :\n" + catalogue +
            f"\nAgents indisponibles en ce moment : {absent}.\n"
            "Pour une demande de devis : interroge le stock ET le prix (outils séparés), puis rédige "
            "une réponse unique en français avec la disponibilité et le total HT. "
            "Transmets à chaque agent une demande autonome et précise (référence, quantité). "
            "Si un agent est indisponible ou renvoie une erreur, dis-le clairement et donne "
            "uniquement l'information obtenue. N'invente jamais un stock ni un prix."),
        tools=[AgentTool(agent=r) for r in remotes],
    )

L'orchestrateur est lui-même exposé en A2A sur le port 8100 : un autre système peut l'appeler exactement comme il appelle ses spécialistes. C'est ce qui rend l'architecture composable.

Pourquoi l'instruction demande-t-elle de transmettre « une demande autonome et précise » à chaque agent ?

Quel timeout donner à RemoteA2aAgent pour un devis interactif ?

Résultat obtenu

Scénario 1 de e2e_a2a.py, le 2026-10-15 : trois serveurs uvicorn réels, vrai modèle.

1) Devis complet en streaming
   états : TASK_STATE_SUBMITTED > TASK_STATE_WORKING > artifactUpdate > TASK_STATE_COMPLETED
   réponse : Voici votre devis pour **12 unités** de la référence **CHAISE-ERGO** :  * **Disponibilité en stock :** 12 unités disponibles au total (12 unités à l'entrepôt de Lyon, 0 à Lille). * **Tarification :**   * Prix unitaire HT : 189,00 €   * Remise sur volume : 10 %   * **Total HT : 2 041,20 €**

Le total est juste (12 × 189 € × 0,90 = 2 041,20 €) et le test le vérifie automatiquement : assert "204120" in digits(answer). Les journaux des deux spécialistes montrent chacun un POST / HTTP/1.1 200 OK authentifié.

Exercice : brancher l'agent livraison

Ajoutez l'agent livraison de la leçon précédente à l'orchestrateur sans modifier build_orchestrator, puis demandez « devis et délai pour 6 BUREAU-120 livrés à Lille ».

Voir la solution

Il suffit que l'agent apparaisse dans found, ce que fera la découverte (leçon suivante). Pour un test immédiat :

from orchestrator import build_orchestrator, discover
found, missing = discover()
found.append({"name": "delivery_agent", "description": "Estime le délai de livraison selon la ville.",
              "skills": [], "card_url": "http://localhost:8103/.well-known/agent-card.json"})
agent = build_orchestrator(found, missing, token)

Adaptez aussi l'instruction : « pour un délai, interroge delivery_agent ». La réponse attendue combine stock (8 unités), prix (6 × 329 € × 0,95 = 1 875,30 € HT) et délai (3 jours ouvrés).

Je sais faire

  • Déclarer un RemoteA2aAgent avec carte, timeout et authentification
  • Choisir entre sub_agents et AgentTool selon qui doit répondre
  • Écrire une instruction d'orchestrateur qui interdit d'inventer
  • Vérifier un résultat combiné par un test automatique
Next