Gérez les agents asynchrones et de longue durée avec Amazon Bedrock Runtime AgentCore

Amazon Bedrock AgentCore Runtime peut gérer le traitement asynchrone et les agents de longue durée. Les tâches asynchrones permettent à votre agent de poursuivre le traitement après avoir répondu au client et de gérer les opérations de longue durée sans bloquer les réponses. Grâce au traitement asynchrone, votre agent peut :

Concepts clés

Modèle de traitement asynchrone

Le AgentCore SDK Amazon Bedrock prend en charge le traitement synchrone et asynchrone via une API unifiée. Cela crée un modèle d'implémentation flexible à la fois pour les clients et les développeurs d'agents. Les clients agents peuvent travailler avec la même API sans faire la différence entre synchrone et asynchrone côté client. Grâce à la possibilité d'invoquer la même session entre les invocations, les développeurs d'agents peuvent réutiliser le contexte et s'appuyer sur ce contexte de manière incrémentielle sans mettre en œuvre une logique de gestion des tâches complexe.

Gestion du cycle de vie des sessions d'exécution

Le code de l'agent communique son état de traitement à l'aide de l'état de santé du point de terminaison « /ping ». Le /ping point de terminaison doit renvoyer une réponse HTTP 200 avec la charge utile JSON suivante :

{"status": "HealthyBusy"}

La réponse contient un champ obligatoire et un champ facultatif :

Une session inactive ("Healthy") pendant 15 minutes est automatiquement interrompue. Une session qui revient "HealthyBusy" reste active au-delà du délai d'inactivité.

Implémentation de tâches asynchrones

Pour commencer, installez le bedrock-agentcore package :

pip install bedrock-agentcore

AgentCore Le SDK fournit les options suivantes pour le traitement asynchrone d'intégration.

Exemple complet

Tout d'abord, installez le package requis :

pip install strands-agents

Créez ensuite un fichier Python avec le code suivant :

import threading
import time
from strands import Agent, tool
from bedrock_agentcore.runtime import BedrockAgentCoreApp

# Initialize app with debug mode for task management
app = BedrockAgentCoreApp()

@tool
def start_background_task(duration: int = 5) -> str:
    """Start a simple background task that runs for specified duration."""
    # Start tracking the async task
    task_id = app.add_async_task("background_processing", {"duration": duration})

    # Run task in background thread
    def background_work():
        time.sleep(duration)  # Simulate work
        app.complete_async_task(task_id)  # Mark as complete

    threading.Thread(target=background_work, daemon=True).start()
    return f"Started background task (ID: {task_id}) for {duration} seconds. Agent status is now BUSY."

# Create agent with the tool
agent = Agent(tools=[start_background_task])

@app.entrypoint
def main(payload):
    """Main entrypoint - handles user messages."""
    user_message = payload.get("prompt", "Try: start_background_task(3)")
    return {"message": agent(user_message).message}

if __name__ == "__main__":
    print("🚀 Simple Async Strands Example")
    print("Test: curl -X POST http://localhost:8080/invocations -H 'Content-Type: application/json' -d '{\"prompt\": \"start a 3 second task\"}'")
    app.run()

Cet exemple montre :

Problèmes courants et solutions correspondantes

Long-running l'agent est résilié au bout de 15 minutes

Cela peut se produire lorsque l'application est mono-thread et que le thread ping est bloqué.