External Invocation

pip install openai mcp

# -*- coding: utf-8 -*-
# Using OpenAI SDK + MCP SDK to invoke Bailian WebSearch MCP service
import os
import asyncio
import json
from openai import OpenAI
from mcp.client.streamable_http import streamablehttp_client
from mcp import ClientSession

async def main():
    api_key = os.getenv("DASHSCOPE_API_KEY")
    if not api_key:
        print("Error: Please set the DASHSCOPE_API_KEY environment variable")
        return
    mcp_url = "https://dashscope.aliyuncs.com/api/v1/mcps/WebSearch/mcp"
    headers = {"Authorization": f"Bearer {api_key}"}
    # 1. Connect to MCP Server and fetch available tools list
    async with streamablehttp_client(mcp_url, headers=headers) as (read, write, _):
        async with ClientSession(read, write) as session:
            await session.initialize()
            tools_result = await session.list_tools()
            # Convert to OpenAI function-calling format
            openai_tools = []
            for tool in tools_result.tools:
                openai_tools.append({
                    "type": "function",
                    "function": {
                        "name": tool.name,
                        "description": tool.description or "",
                        "parameters": tool.inputSchema or {"type": "object", "properties": {}},
                    },
                })
            # 2. Call DashScope (OpenAI-compatible endpoint)
            client = OpenAI(
                api_key=api_key,
                base_url="https://dashscope.aliyuncs.com/compatible-mode/v1",
            )
            messages = [{"role": "user", "content": "Search for the latest developments regarding Alibaba Cloud Bailian MCP"}]
            print("Performing web search...")
            print("=" * 50)
            # 3. Multi-turn tool-calling loop
            while True:
                response = client.chat.completions.create(
                    model="qwen-max",
                    messages=messages,
                    tools=openai_tools or None,
                )
                choice = response.choices[0]
                msg = choice.message
                if not msg.tool_calls:
                    print(msg.content)
                    break
                messages.append(msg)
                for tc in msg.tool_calls:
                    args = json.loads(tc.function.arguments)
                    result = await session.call_tool(tc.function.name, args)
                    tool_content = ""
                    for block in result.content:
                        if hasattr(block, "text"):
                            tool_content += block.text
                    messages.append({
                        "role": "tool",
                        "tool_call_id": tc.id,
                        "content": tool_content,
                    })

if __name__ == "__main__":
    asyncio.run(main())

Performing web search...
==================================================
Alibaba Cloud Bailian MCP (Model Context Protocol) is a newly launched service enabling unified access and management of MCP services on the Bailian platform. Recent updates include:
1. One-click enablement of multiple MCP services (e.g., Amap Maps, WebSearch) via the MCP Plaza.
2. Adoption of the Streamable HTTP protocol, enabling standard HTTP-based external invocations.
3. Native integrations with mainstream tools such as Cherry Studio and Cursor, supporting automatic configuration.
4. Flexible SDK-based integration for developers building custom applications.