Merge pull request #29 from ks6088ts-labs/copilot/fix-28

Agents サービスを FastAPI サーバに追加する

Author: ks6088ts

.env.template

@@ -18,6 +18,10 @@ AZURE_BLOB_STORAGE_CONTAINER_NAME="files"
 AZURE_AI_SPEECH_API_KEY="<YOUR_AZURE_AI_SPEECH_API_KEY>"
 AZURE_AI_SPEECH_ENDPOINT="https://<speech-api-name>.cognitiveservices.azure.com/"
 
+# Azure AI Foundry
+AZURE_AI_FOUNDRY_PROJECT_ENDPOINT="https://xxx.services.ai.azure.com/api/projects/yyy"
+AZURE_AI_FOUNDRY_API_KEY="<YOUR_API_KEY>"
+
 # Chats WebSocket
 # Azure Container Apps: `wss://yourcontainerapps.japaneast.azurecontainerapps.io`
 CHATS_WEBSOCKET_URL="ws://localhost:8000"

docs/index.md

@@ -194,3 +194,27 @@ az resource update \
 ### Azure AI Speech
 
 - [バッチ文字起こしとは](https://learn.microsoft.com/ja-jp/azure/ai-services/speech-service/batch-transcription)
+
+### Azure AI Foundry
+
+- [Quickstart: Create a new agent](https://learn.microsoft.com/en-us/azure/ai-foundry/agents/quickstart?pivots=programming-language-python-azure)
+- [Deep Research tool (preview)](https://learn.microsoft.com/en-us/azure/ai-foundry/agents/quickstart?pivots=programming-language-python-azure)
+
+#### CLI 実行例
+
+```bash
+# エージェントを作成
+python scripts/agents.py create-agent "研究アシスタント" --description "研究をサポートするAIアシスタント" --instructions "あなたは研究者をサポートするAIアシスタントです。質問に対して詳細で正確な回答を提供してください。"
+
+# エージェント一覧を取得
+python scripts/agents.py list-agents
+
+# エージェントの詳細を取得
+python scripts/agents.py get-agent <agent_id>
+
+# エージェントとチャット
+python scripts/agents.py chat <agent_id> "機械学習の最新トレンドについて教えてください"
+
+# エージェントを削除
+python scripts/agents.py delete-agent <agent_id>
+```

pyproject.toml

@@ -5,6 +5,7 @@ description = "A GitHub template repository for Python"
 readme = "README.md"
 requires-python = ">=3.10"
 dependencies = [
+    "azure-ai-projects>=1.0.0b12",
     "azure-cosmos>=4.9.0",
     "azure-functions>=1.23.0",
     "azure-identity>=1.23.0",
@@ -70,3 +71,4 @@ possibly-unbound-attribute = "ignore" # Ignore possibly unbound attributes in cl
 unknown-argument = "ignore" # Ignore unknown arguments in function calls
 invalid-assignment = "ignore" # Ignore invalid assignments
 invalid-argument-type = "ignore" # Ignore invalid argument types
+invalid-return-type = "ignore" # Ignore invalid return types

scripts/agents.py

@@ -0,0 +1,180 @@
+#!/usr/bin/env python
+# filepath: /home/runner/work/template-fastapi/template-fastapi/scripts/agents.py
+
+import json
+
+import typer
+from rich.console import Console
+from rich.table import Table
+
+from template_fastapi.models.agent import AgentRequest, ChatRequest
+from template_fastapi.repositories.agents import AgentRepository
+
+app = typer.Typer()
+console = Console()
+agent_repo = AgentRepository()
+
+
+@app.command()
+def create_agent(
+    name: str = typer.Argument(..., help="エージェント名"),
+    description: str | None = typer.Option(None, "--description", "-d", help="エージェントの説明"),
+    instructions: str | None = typer.Option(None, "--instructions", "-i", help="エージェントの指示"),
+    model: str = typer.Option("gpt-4o", "--model", "-m", help="使用するモデル"),
+):
+    """新しいエージェントを作成する"""
+    console.print("[bold green]新しいエージェントを作成します[/bold green]")
+    console.print(f"名前: {name}")
+    console.print(f"説明: {description or 'なし'}")
+    console.print(f"指示: {instructions or 'なし'}")
+    console.print(f"モデル: {model}")
+
+    try:
+        request = AgentRequest(
+            name=name,
+            description=description,
+            instructions=instructions,
+            model=model,
+        )
+
+        agent = agent_repo.create_agent(request)
+
+        console.print("\n[bold blue]エージェントが正常に作成されました[/bold blue]:")
+        console.print(f"ID: {agent.id}")
+        console.print(f"名前: {agent.name}")
+        console.print(f"説明: {agent.description}")
+        console.print(f"指示: {agent.instructions}")
+        console.print(f"モデル: {agent.model}")
+        console.print(f"ステータス: {agent.status}")
+        console.print(f"作成日時: {agent.created_at}")
+
+    except Exception as e:
+        console.print(f"❌ [bold red]エラー[/bold red]: {str(e)}")
+
+
+@app.command()
+def get_agent(
+    agent_id: str = typer.Argument(..., help="エージェントID"),
+):
+    """エージェントの情報を取得する"""
+    console.print("[bold green]エージェント情報を取得します[/bold green]")
+    console.print(f"エージェントID: {agent_id}")
+
+    try:
+        agent = agent_repo.get_agent(agent_id)
+
+        console.print("\n[bold blue]エージェント情報[/bold blue]:")
+        console.print(f"ID: {agent.id}")
+        console.print(f"名前: {agent.name}")
+        console.print(f"説明: {agent.description}")
+        console.print(f"指示: {agent.instructions}")
+        console.print(f"モデル: {agent.model}")
+        console.print(f"ステータス: {agent.status}")
+        console.print(f"作成日時: {agent.created_at}")
+        console.print(f"更新日時: {agent.updated_at}")
+
+        if agent.tools:
+            console.print(f"ツール: {json.dumps(agent.tools, indent=2, ensure_ascii=False)}")
+
+    except Exception as e:
+        console.print(f"❌ [bold red]エラー[/bold red]: {str(e)}")
+
+
+@app.command()
+def list_agents(
+    limit: int = typer.Option(10, "--limit", "-l", help="取得する件数"),
+):
+    """エージェントの一覧を取得する"""
+    console.print("[bold green]エージェント一覧を取得します[/bold green]")
+    console.print(f"取得件数: {limit}")
+
+    try:
+        agents_response = agent_repo.list_agents(limit=limit)
+
+        if not agents_response.agents:
+            console.print("[yellow]エージェントが見つかりません[/yellow]")
+            return
+
+        table = Table(title="エージェント一覧")
+        table.add_column("ID", style="cyan")
+        table.add_column("名前", style="magenta")
+        table.add_column("説明", style="green")
+        table.add_column("モデル", style="blue")
+        table.add_column("ステータス", style="yellow")
+        table.add_column("作成日時", style="dim")
+
+        for agent in agents_response.agents:
+            table.add_row(
+                agent.id,
+                agent.name,
+                agent.description or "なし",
+                agent.model,
+                agent.status,
+                agent.created_at,
+            )
+
+        console.print(table)
+        console.print(f"[bold blue]合計: {agents_response.total}件[/bold blue]")
+
+    except Exception as e:
+        console.print(f"❌ [bold red]エラー[/bold red]: {str(e)}")
+
+
+@app.command()
+def delete_agent(
+    agent_id: str = typer.Argument(..., help="エージェントID"),
+):
+    """エージェントを削除する"""
+    console.print("[bold red]エージェントを削除します[/bold red]")
+    console.print(f"エージェントID: {agent_id}")
+
+    confirm = typer.confirm("本当に削除しますか？")
+    if not confirm:
+        console.print("[yellow]削除をキャンセルしました[/yellow]")
+        return
+
+    try:
+        success = agent_repo.delete_agent(agent_id)
+
+        if success:
+            console.print("[bold green]エージェントが正常に削除されました[/bold green]")
+        else:
+            console.print("[bold red]エージェントの削除に失敗しました[/bold red]")
+
+    except Exception as e:
+        console.print(f"❌ [bold red]エラー[/bold red]: {str(e)}")
+
+
+@app.command()
+def chat(
+    agent_id: str = typer.Argument(..., help="エージェントID"),
+    message: str = typer.Argument(..., help="メッセージ"),
+    thread_id: str | None = typer.Option(None, "--thread-id", "-t", help="スレッドID"),
+):
+    """エージェントとチャットする"""
+    console.print("[bold green]エージェントとチャットします[/bold green]")
+    console.print(f"エージェントID: {agent_id}")
+    console.print(f"メッセージ: {message}")
+    console.print(f"スレッドID: {thread_id or '新規作成'}")
+
+    try:
+        request = ChatRequest(
+            message=message,
+            thread_id=thread_id,
+        )
+
+        response = agent_repo.chat_with_agent(agent_id, request)
+
+        console.print("\n[bold blue]チャット結果[/bold blue]:")
+        console.print(f"メッセージID: {response.id}")
+        console.print(f"スレッドID: {response.thread_id}")
+        console.print(f"あなた: {response.message}")
+        console.print(f"エージェント: {response.response}")
+        console.print(f"作成日時: {response.created_at}")
+
+    except Exception as e:
+        console.print(f"❌ [bold red]エラー[/bold red]: {str(e)}")
+
+
+if __name__ == "__main__":
+    app()

template_fastapi/app.py

@@ -11,7 +11,7 @@
 from opentelemetry.instrumentation.fastapi import FastAPIInstrumentor
 from opentelemetry.trace import Span
 
-from template_fastapi.routers import chats, demos, files, foodies, games, items, speeches
+from template_fastapi.routers import agents, chats, demos, files, foodies, games, items, speeches
 
 app = FastAPI()
 
@@ -43,3 +43,4 @@ def server_request_hook(span: Span, scope: dict):
 app.include_router(files.router)
 app.include_router(speeches.router)
 app.include_router(chats.router)
+app.include_router(agents.router)

template_fastapi/models/agent.py

@@ -0,0 +1,80 @@
+from enum import Enum
+from typing import Any
+
+from pydantic import BaseModel
+
+
+class AgentStatus(str, Enum):
+    """Agent status enumeration"""
+
+    ACTIVE = "active"
+    INACTIVE = "inactive"
+    DELETED = "deleted"
+
+
+class AgentRequest(BaseModel):
+    """Request model for creating an agent"""
+
+    name: str = "Default Agent"
+    description: str | None = "Hello Agent"
+    instructions: str | None = "You are a helpful assistant."
+    model: str = "gpt-4o"
+
+
+class AgentResponse(BaseModel):
+    """Response model for agent operations"""
+
+    id: str
+    name: str
+    description: str | None = None
+    instructions: str | None = None
+    model: str
+    tools: list[dict[str, Any]] | None = None
+    status: AgentStatus
+    created_at: str
+    updated_at: str
+
+
+class ThreadRequest(BaseModel):
+    """Request model for creating a chat thread"""
+
+    pass
+
+
+class ThreadResponse(BaseModel):
+    """Response model for chat thread"""
+
+    id: str
+    created_at: str
+
+
+class ChatRequest(BaseModel):
+    """Request model for chat with agent"""
+
+    message: str
+    thread_id: str | None = None
+
+
+class ChatResponse(BaseModel):
+    """Response model for chat with agent"""
+
+    id: str
+    agent_id: str
+    thread_id: str
+    message: str
+    response: str
+    created_at: str
+
+
+class AgentListResponse(BaseModel):
+    """Response model for listing agents"""
+
+    agents: list[AgentResponse]
+    total: int
+
+
+class ThreadListResponse(BaseModel):
+    """Response model for listing threads"""
+
+    threads: list[ThreadResponse]
+    total: int