Skip to content

Latest commit

 

History

History
391 lines (298 loc) · 13.3 KB

File metadata and controls

391 lines (298 loc) · 13.3 KB

Integrasi Model Context Protocol (MCP) dengan Azure AI Foundry

Panduan ini menunjukkan cara mengintegrasikan pelayan Model Context Protocol (MCP) dengan ejen Azure AI Foundry, membolehkan orkestrasi alat yang berkuasa dan keupayaan AI perusahaan.

Pengenalan

Model Context Protocol (MCP) adalah piawaian terbuka yang membolehkan aplikasi AI berhubung dengan selamat ke sumber data dan alat luaran. Apabila digabungkan dengan Azure AI Foundry, MCP membolehkan ejen mengakses dan berinteraksi dengan pelbagai perkhidmatan, API, dan sumber data luaran secara berstandard.

Integrasi ini menggabungkan fleksibiliti ekosistem alat MCP dengan rangka kerja ejen Azure AI Foundry yang kukuh, menyediakan penyelesaian AI bertaraf perusahaan dengan keupayaan penyesuaian yang meluas.

Note: Jika anda ingin menggunakan MCP dalam Perkhidmatan Ejen Azure AI Foundry, buat masa ini hanya wilayah berikut yang disokong: westus, westus2, uaenorth, southindia dan switzerlandnorth

Objektif Pembelajaran

Menjelang akhir panduan ini, anda akan dapat:

  • Memahami Model Context Protocol dan manfaatnya
  • Menyediakan pelayan MCP untuk digunakan dengan ejen Azure AI Foundry
  • Mencipta dan mengkonfigurasi ejen dengan integrasi alat MCP
  • Melaksanakan contoh praktikal menggunakan pelayan MCP sebenar
  • Mengendalikan respons alat dan sitasi dalam perbualan ejen

Prasyarat

Sebelum bermula, pastikan anda mempunyai:

  • Langganan Azure dengan akses AI Foundry
  • Python 3.10+ atau .NET 8.0+
  • Azure CLI dipasang dan dikonfigurasi
  • Kebenaran yang sesuai untuk mencipta sumber AI

Apakah Model Context Protocol (MCP)?

Model Context Protocol adalah cara berstandard untuk aplikasi AI berhubung dengan sumber data dan alat luaran. Manfaat utama termasuk:

  • Integrasi Berstandard: Antara muka konsisten merentas pelbagai alat dan perkhidmatan
  • Keselamatan: Mekanisme pengesahan dan kebenaran yang selamat
  • Fleksibiliti: Menyokong pelbagai sumber data, API, dan alat tersuai
  • Kebolehluasan: Mudah menambah keupayaan dan integrasi baru

Menyediakan MCP dengan Azure AI Foundry

Konfigurasi Persekitaran

Pilih persekitaran pembangunan pilihan anda:


Implementasi Python

Note Anda boleh menjalankan notebook ini

1. Pasang Pakej Diperlukan

pip install azure-ai-projects -U
pip install azure-ai-agents==1.1.0b4 -U
pip install azure-identity -U
pip install mcp==1.11.0 -U

2. Import Kebergantungan

import os, time
from azure.ai.projects import AIProjectClient
from azure.identity import DefaultAzureCredential
from azure.ai.agents.models import McpTool, RequiredMcpToolCall, SubmitToolApprovalAction, ToolApproval

3. Konfigurasikan Tetapan MCP

mcp_server_url = os.environ.get("MCP_SERVER_URL", "https://learn.microsoft.com/api/mcp")
mcp_server_label = os.environ.get("MCP_SERVER_LABEL", "mslearn")

4. Inisialisasi Klien Projek

project_client = AIProjectClient(
    endpoint="https://your-project-endpoint.services.ai.azure.com/api/projects/your-project",
    credential=DefaultAzureCredential(),
)

5. Cipta Alat MCP

mcp_tool = McpTool(
    server_label=mcp_server_label,
    server_url=mcp_server_url,
    allowed_tools=[],  # Optional: specify allowed tools
)

6. Contoh Lengkap Python

with project_client:
    agents_client = project_client.agents

    # Create a new agent with MCP tools
    agent = agents_client.create_agent(
        model="Your AOAI Model Deployment",
        name="my-mcp-agent",
        instructions="You are a helpful agent that can use MCP tools to assist users. Use the available MCP tools to answer questions and perform tasks.",
        tools=mcp_tool.definitions,
    )
    print(f"Created agent, ID: {agent.id}")
    print(f"MCP Server: {mcp_tool.server_label} at {mcp_tool.server_url}")

    # Create thread for communication
    thread = agents_client.threads.create()
    print(f"Created thread, ID: {thread.id}")

    # Create message to thread
    message = agents_client.messages.create(
        thread_id=thread.id,
        role="user",
        content="What's difference between Azure OpenAI and OpenAI?",
    )
    print(f"Created message, ID: {message.id}")

    # Handle tool approvals and run agent
    mcp_tool.update_headers("SuperSecret", "123456")
    run = agents_client.runs.create(thread_id=thread.id, agent_id=agent.id, tool_resources=mcp_tool.resources)
    print(f"Created run, ID: {run.id}")

    while run.status in ["queued", "in_progress", "requires_action"]:
        time.sleep(1)
        run = agents_client.runs.get(thread_id=thread.id, run_id=run.id)

        if run.status == "requires_action" and isinstance(run.required_action, SubmitToolApprovalAction):
            tool_calls = run.required_action.submit_tool_approval.tool_calls
            if not tool_calls:
                print("No tool calls provided - cancelling run")
                agents_client.runs.cancel(thread_id=thread.id, run_id=run.id)
                break

            tool_approvals = []
            for tool_call in tool_calls:
                if isinstance(tool_call, RequiredMcpToolCall):
                    try:
                        print(f"Approving tool call: {tool_call}")
                        tool_approvals.append(
                            ToolApproval(
                                tool_call_id=tool_call.id,
                                approve=True,
                                headers=mcp_tool.headers,
                            )
                        )
                    except Exception as e:
                        print(f"Error approving tool_call {tool_call.id}: {e}")

            if tool_approvals:
                agents_client.runs.submit_tool_outputs(
                    thread_id=thread.id, run_id=run.id, tool_approvals=tool_approvals
                )

        print(f"Current run status: {run.status}")

    print(f"Run completed with status: {run.status}")

    # Display conversation
    messages = agents_client.messages.list(thread_id=thread.id)
    print("\nConversation:")
    print("-" * 50)
    for msg in messages:
        if msg.text_messages:
            last_text = msg.text_messages[-1]
            print(f"{msg.role.upper()}: {last_text.text.value}")
            print("-" * 50)

Implementasi .NET

Note Anda boleh menjalankan notebook ini

1. Pasang Pakej Diperlukan

#r "nuget: Azure.AI.Agents.Persistent, 1.1.0-beta.4"
#r "nuget: Azure.Identity, 1.14.2"

2. Import Kebergantungan

using Azure.AI.Agents.Persistent;
using Azure.Identity;

3. Konfigurasikan Tetapan

var projectEndpoint = "https://your-project-endpoint.services.ai.azure.com/api/projects/your-project";
var modelDeploymentName = "Your AOAI Model Deployment";
var mcpServerUrl = "https://learn.microsoft.com/api/mcp";
var mcpServerLabel = "mslearn";
PersistentAgentsClient agentClient = new(projectEndpoint, new DefaultAzureCredential());

4. Cipta Definisi Alat MCP

MCPToolDefinition mcpTool = new(mcpServerLabel, mcpServerUrl);

5. Cipta Ejen dengan Alat MCP

PersistentAgent agent = await agentClient.Administration.CreateAgentAsync(
   model: modelDeploymentName,
   name: "my-learn-agent",
   instructions: "You are a helpful agent that can use MCP tools to assist users. Use the available MCP tools to answer questions and perform tasks.",
   tools: [mcpTool]
   );

6. Contoh Lengkap .NET

// Create thread and message
PersistentAgentThread thread = await agentClient.Threads.CreateThreadAsync();

PersistentThreadMessage message = await agentClient.Messages.CreateMessageAsync(
    thread.Id,
    MessageRole.User,
    "What's difference between Azure OpenAI and OpenAI?");

// Configure tool resources with headers
MCPToolResource mcpToolResource = new(mcpServerLabel);
mcpToolResource.UpdateHeader("SuperSecret", "123456");
ToolResources toolResources = mcpToolResource.ToToolResources();

// Create and handle run
ThreadRun run = await agentClient.Runs.CreateRunAsync(thread, agent, toolResources);

while (run.Status == RunStatus.Queued || run.Status == RunStatus.InProgress || run.Status == RunStatus.RequiresAction)
{
    await Task.Delay(TimeSpan.FromMilliseconds(1000));
    run = await agentClient.Runs.GetRunAsync(thread.Id, run.Id);

    if (run.Status == RunStatus.RequiresAction && run.RequiredAction is SubmitToolApprovalAction toolApprovalAction)
    {
        var toolApprovals = new List<ToolApproval>();
        foreach (var toolCall in toolApprovalAction.SubmitToolApproval.ToolCalls)
        {
            if (toolCall is RequiredMcpToolCall mcpToolCall)
            {
                Console.WriteLine($"Approving MCP tool call: {mcpToolCall.Name}");
                toolApprovals.Add(new ToolApproval(mcpToolCall.Id, approve: true)
                {
                    Headers = { ["SuperSecret"] = "123456" }
                });
            }
        }

        if (toolApprovals.Count > 0)
        {
            run = await agentClient.Runs.SubmitToolOutputsToRunAsync(thread.Id, run.Id, toolApprovals: toolApprovals);
        }
    }
}

// Display messages
using Azure;

AsyncPageable<PersistentThreadMessage> messages = agentClient.Messages.GetMessagesAsync(
    threadId: thread.Id,
    order: ListSortOrder.Ascending
);

await foreach (PersistentThreadMessage threadMessage in messages)
{
    Console.Write($"{threadMessage.CreatedAt:yyyy-MM-dd HH:mm:ss} - {threadMessage.Role,10}: ");
    foreach (MessageContent contentItem in threadMessage.ContentItems)
    {
        if (contentItem is MessageTextContent textItem)
        {
            Console.Write(textItem.Text);
        }
        else if (contentItem is MessageImageFileContent imageFileItem)
        {
            Console.Write($"<image from ID: {imageFileItem.FileId}>");
        }
        Console.WriteLine();
    }
}

Pilihan Konfigurasi Alat MCP

Apabila mengkonfigurasi alat MCP untuk ejen anda, anda boleh menentukan beberapa parameter penting:

Konfigurasi Python

mcp_tool = McpTool(
    server_label="unique_server_name",      # Identifier for the MCP server
    server_url="https://api.example.com/mcp", # MCP server endpoint
    allowed_tools=[],                       # Optional: specify allowed tools
)

Konfigurasi .NET

MCPToolDefinition mcpTool = new(
    "unique_server_name",                   // Server label
    "https://api.example.com/mcp"          // MCP server URL
);

Pengesahan dan Header

Kedua-dua implementasi menyokong header tersuai untuk pengesahan:

Python

mcp_tool.update_headers("SuperSecret", "123456")

.NET

MCPToolResource mcpToolResource = new(mcpServerLabel);
mcpToolResource.UpdateHeader("SuperSecret", "123456");

Penyelesaian Masalah Biasa

1. Masalah Sambungan

  • Sahkan URL pelayan MCP boleh diakses
  • Semak kelayakan pengesahan
  • Pastikan sambungan rangkaian stabil

2. Kegagalan Panggilan Alat

  • Semak argumen dan format alat
  • Periksa keperluan khusus pelayan
  • Laksanakan pengendalian ralat yang betul

3. Masalah Prestasi

  • Optimumkan kekerapan panggilan alat
  • Gunakan caching jika sesuai
  • Pantau masa respons pelayan

Langkah Seterusnya

Untuk meningkatkan lagi integrasi MCP anda:

  1. Terokai Pelayan MCP Tersuai: Bina pelayan MCP anda sendiri untuk sumber data proprietari
  2. Laksanakan Keselamatan Lanjutan: Tambah OAuth2 atau mekanisme pengesahan tersuai
  3. Pantau dan Analitik: Laksanakan log dan pemantauan penggunaan alat
  4. Skalakan Penyelesaian Anda: Pertimbangkan pengimbangan beban dan seni bina pelayan MCP teragih

Sumber Tambahan

Sokongan

Untuk sokongan tambahan dan pertanyaan:

Apa seterusnya

Penafian:
Dokumen ini telah diterjemahkan menggunakan perkhidmatan terjemahan AI Co-op Translator. Walaupun kami berusaha untuk ketepatan, sila ambil perhatian bahawa terjemahan automatik mungkin mengandungi kesilapan atau ketidaktepatan. Dokumen asal dalam bahasa asalnya harus dianggap sebagai sumber yang sahih. Untuk maklumat penting, terjemahan profesional oleh manusia adalah disyorkan. Kami tidak bertanggungjawab atas sebarang salah faham atau salah tafsir yang timbul daripada penggunaan terjemahan ini.