AI-Native Insight Infrastructure with MCP

claude mcp add --transport http roxyapi-astrology-api https://roxyapi.com/mcp/astrology-api \
  --header "X-API-Key: your_api_key_here"

{
  "mcpServers": {
    "roxyapi-astrology-api": {
      "url": "https://roxyapi.com/mcp/astrology-api",
      "headers": {
        "X-API-Key": "your_api_key_here"
      }
    }
  }
}

from google.adk.agents import LlmAgent
from google.adk.tools.mcp_tool import McpToolset
from google.adk.tools.mcp_tool.mcp_session_manager import SseConnectionParams

# Connect to RoxyAPI MCP server via HTTP
agent = LlmAgent(
    model='gemini-2.0-flash',
    name='astrology_assistant',
    instruction='Use RoxyAPI tools to provide astrological insights',
    tools=[
        McpToolset(
            connection_params=SseConnectionParams(
                url="https://roxyapi.com/mcp/astrology-api",
                headers={"X-API-Key": "your_api_key_here"}
            )
        )
    ]
)

# Run the agent (requires ADK Runner setup)
# See: https://google.github.io/adk-docs/tools-custom/mcp-tools/

import asyncio
from agents import Agent, Runner
from agents.mcp import MCPServerStreamableHttp

async def main():
    async with MCPServerStreamableHttp(
        name="RoxyAPI",
        params={
            "url": "https://roxyapi.com/mcp/astrology-api",
            "headers": {"X-API-Key": "your_api_key_here"}
        },
        cache_tools_list=True
    ) as server:
        agent = Agent(
            name="Assistant",
            instructions="Use RoxyAPI tools to answer questions",
            mcp_servers=[server]
        )
        result = await Runner.run(agent, "Get today's horoscope for Aries")
        print(result.final_output)

asyncio.run(main())

// TypeScript example
import { Client } from '@modelcontextprotocol/sdk/client/index.js';

const client = new Client({ name: 'my-mcp-client', version: '1.0.0' });
await client.connect({
  url: 'https://roxyapi.com/mcp/astrology-api',
  headers: { 'X-API-Key': 'your_api_key_here' }
});

// Python example
from mcp import ClientSession, StdioServerParameters
from mcp.client.stdio import stdio_client

async with stdio_client(StdioServerParameters(
    command="npx",
    args=["-y", "@modelcontextprotocol/server-fetch"]
)) as (read, write):
    async with ClientSession(read, write) as session:
        await session.initialize()
        tools = await session.list_tools()