As traduções são geradas por tradução automática. Em caso de conflito entre o conteúdo da tradução e da versão original em inglês, a versão em inglês prevalecerá.

Gerencie agentes assíncronos e de longa execução com o Amazon Bedrock Runtime AgentCore

O Amazon Bedrock AgentCore Runtime pode lidar com processamento assíncrono e agentes de longa execução. As tarefas assíncronas permitem que seu agente continue processando depois de responder ao cliente e gerencie operações de longa duração sem bloquear as respostas. Com o processamento assíncrono, seu agente pode:

Principais conceitos

Modelo de processamento assíncrono

O Amazon Bedrock AgentCore SDK oferece suporte ao processamento síncrono e assíncrono por meio de uma API unificada. Isso cria um padrão de implementação flexível para clientes e desenvolvedores de agentes. Os clientes agentes podem trabalhar com a mesma API sem diferenciar entre síncrono e assíncrono no lado do cliente. Com a capacidade de invocar a mesma sessão em todas as invocações, os desenvolvedores de agentes podem reutilizar o contexto e desenvolver esse contexto de forma incremental sem implementar uma lógica complexa de gerenciamento de tarefas.

Gerenciamento do ciclo de vida da sessão em tempo de execução

O código do agente comunica seu status de processamento usando o status de integridade do endpoint “/ping”. O /ping endpoint deve retornar uma resposta HTTP 200 com a seguinte carga JSON:

{"status": "HealthyBusy"}

A resposta contém um campo obrigatório e um campo opcional:

Uma sessão em estado ocioso ("Healthy") por 15 minutos é automaticamente encerrada. O retorno de uma sessão "HealthyBusy" permanece ativa além do tempo limite de inatividade.

Implementação de tarefas assíncronas

Para começar, instale o bedrock-agentcore pacote:

pip install bedrock-agentcore

AgentCore O SDK fornece as seguintes opções para processamento assíncrono de integração.

Exemplo completo

Primeiro, instale o pacote necessário:

pip install strands-agents

Em seguida, crie um arquivo Python com o seguinte código:

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 = str(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()

Este exemplo demonstra:

Problemas e soluções comuns de

Long-running agente é demitido após 15 minutos

Isso pode acontecer quando o aplicativo tem um único thread e o thread de ping está bloqueado.