# How to integrate Polygon io MCP with LlamaIndex

```json
{
  "title": "How to integrate Polygon io MCP with LlamaIndex",
  "toolkit": "Polygon io",
  "toolkit_slug": "polygon_io",
  "framework": "LlamaIndex",
  "framework_slug": "llama-index",
  "url": "https://composio.dev/toolkits/polygon_io/framework/llama-index",
  "markdown_url": "https://composio.dev/toolkits/polygon_io/framework/llama-index.md",
  "updated_at": "2026-05-12T10:22:24.962Z"
}
```

## Introduction

This guide walks you through connecting Polygon io to LlamaIndex using the Composio tool router. By the end, you'll have a working Polygon io agent that can get daily summary for aapl stock, retrieve latest news on tsla ticker, check if nyse market is open now through natural language commands.
This guide will help you understand how to give your LlamaIndex agent real control over a Polygon io account through Composio's Polygon io MCP server.
Before we dive in, let's take a quick look at the key ideas and tools involved.

## Also integrate Polygon io with

- [OpenAI Agents SDK](https://composio.dev/toolkits/polygon_io/framework/open-ai-agents-sdk)
- [Claude Agent SDK](https://composio.dev/toolkits/polygon_io/framework/claude-agents-sdk)
- [Claude Code](https://composio.dev/toolkits/polygon_io/framework/claude-code)
- [Claude Cowork](https://composio.dev/toolkits/polygon_io/framework/claude-cowork)
- [Codex](https://composio.dev/toolkits/polygon_io/framework/codex)
- [OpenClaw](https://composio.dev/toolkits/polygon_io/framework/openclaw)
- [Hermes](https://composio.dev/toolkits/polygon_io/framework/hermes-agent)
- [CLI](https://composio.dev/toolkits/polygon_io/framework/cli)
- [Google ADK](https://composio.dev/toolkits/polygon_io/framework/google-adk)
- [LangChain](https://composio.dev/toolkits/polygon_io/framework/langchain)
- [Vercel AI SDK](https://composio.dev/toolkits/polygon_io/framework/ai-sdk)
- [Mastra AI](https://composio.dev/toolkits/polygon_io/framework/mastra-ai)
- [CrewAI](https://composio.dev/toolkits/polygon_io/framework/crew-ai)

## TL;DR

Here's what you'll learn:
- Set your OpenAI and Composio API keys
- Install LlamaIndex and Composio packages
- Create a Composio Tool Router session for Polygon io
- Connect LlamaIndex to the Polygon io MCP server
- Build a Polygon io-powered agent using LlamaIndex
- Interact with Polygon io through natural language

## What is LlamaIndex?

LlamaIndex is a data framework for building LLM applications. It provides tools for connecting LLMs to external data sources and services through agents and tools.
Key features include:
- ReAct Agent: Reasoning and acting pattern for tool-using agents
- MCP Tools: Native support for Model Context Protocol
- Context Management: Maintain conversation context across interactions
- Async Support: Built for async/await patterns

## What is the Polygon io MCP server, and what's possible with it?

The Polygon io MCP server is an implementation of the Model Context Protocol that connects your AI agent and assistants like Claude, Cursor, etc directly to your Polygon io account. It provides structured and secure access to real-time and historical financial market data, so your agent can pull ticker lists, fetch stock summaries, analyze technical indicators, and surface news updates on your behalf.
- Comprehensive ticker discovery and lookup: Instantly retrieve detailed lists of supported stock, forex, crypto, and option tickers to power your trading dashboards or research tools.
- Daily summary and technical analysis: Ask your agent to fetch daily price summaries, calculate exponential moving averages, MACD, or RSI for any supported ticker and timeframe.
- Financial events and dividend insights: Pull up historical dividend distributions, keep tabs on scheduled market holidays, and plan trading activities around real exchange calendars.
- Up-to-date market status monitoring: Have your agent check real-time market open/close statuses and trading conditions across multiple exchanges and asset classes.
- Automated news aggregation for securities: Let your agent gather the latest news articles, sentiment analysis, and headlines for specific tickers, helping you stay informed with minimal effort.

## Supported Tools

| Tool slug | Name | Description |
|---|---|---|
| `POLYGON_IO_GET_ALL_TICKERS` | Get All Tickers | Tool to retrieve a comprehensive list of supported ticker symbols across all asset classes. Use when you need to list all tickers with details like symbol, name, market, and status. |
| `POLYGON_IO_GET_CONDITION_CODES` | Get Condition Codes | Tool to retrieve a unified list of trade and quote condition codes and their definitions. Use when needing to decode condition identifiers after fetching market data. |
| `POLYGON_IO_GET_CRYPTO_EMA` | Get Crypto EMA | Tool to calculate Exponential Moving Average (EMA) technical indicator for a crypto ticker. Use when you need trend analysis or moving average calculations for cryptocurrency pairs. |
| `POLYGON_IO_GET_CRYPTO_MACD` | Get Crypto MACD | Tool to calculate Moving Average Convergence/Divergence (MACD) technical indicator for a crypto ticker. Use when you need momentum analysis, trend identification, or trading signal generation for cryptocurrency pairs. |
| `POLYGON_IO_GET_CRYPTO_OPEN_CLOSE` | Get Crypto Open/Close | Tool to get the open, close, high, low, and volume for a cryptocurrency pair on a specific date. Use when you need historical daily OHLC data for crypto pairs. |
| `POLYGON_IO_GET_CRYPTO_RSI` | Get Crypto RSI | Tool to calculate the Relative Strength Index (RSI) for a cryptocurrency ticker. Use when you need to analyze momentum or identify overbought/oversold conditions for crypto assets. |
| `POLYGON_IO_GET_CRYPTO_SMA` | Get Crypto SMA | Tool to calculate Simple Moving Average (SMA) technical indicator for a cryptocurrency ticker. Use when you need trend analysis, support/resistance levels, or trading signal generation for crypto pairs. |
| `POLYGON_IO_GET_DAILY_OPEN_CLOSE` | Get Daily Open/Close | Tool to get the daily open, close, after-hours, and pre-market prices for a stock on a specific date. Use when you need historical OHLC data for a specific trading day, including pre-market and after-hours information. |
| `POLYGON_IO_GET_DIVIDENDS` | Get Dividends | Tool to retrieve a historical record of cash dividend distributions for a given ticker. Use when analyzing dividend payments by date, amount, and frequency. |
| `POLYGON_IO_GET_ECONOMY_INFLATION2` | Get Economy Inflation Indicators (Enhanced) | Tool to retrieve key indicators of realized inflation including CPI and PCE price indexes with comprehensive date filtering. Use when analyzing inflation trends with specific date ranges, economic conditions, or historical price changes going back to 1947. |
| `POLYGON_IO_GET_EMA` | Get Exponential Moving Average | Tool to retrieve the Exponential Moving Average for a stock ticker. Use when you need EMA values across a specific timespan with optional underlying data. |
| `POLYGON_IO_GET_FILING` | Get SEC Filing | Tool to retrieve detailed information about a specific SEC filing by filing ID. Use when you need to access full filing details including accession number, filing type, dates, source URLs, and associated entities. |
| `POLYGON_IO_GET_FILING_FILE` | Get SEC Filing File | Tool to download a specific file from an SEC filing. Use when you need to access individual documents from a company's SEC filings, such as 10-Q, 10-K, or other submission files. Returns the raw file content (HTML, XML, XBRL, etc.). |
| `POLYGON_IO_GET_FOREX_EMA` | Get Forex EMA | Tool to calculate Exponential Moving Average (EMA) technical indicator for a forex pair. Use when you need trend analysis or moving average calculations for currency pairs. |
| `POLYGON_IO_GET_FOREX_MACD` | Get Forex MACD | Tool to calculate Moving Average Convergence/Divergence (MACD) technical indicator for a forex pair. Use when you need momentum analysis, trend identification, or trading signal generation for currency pairs. |
| `POLYGON_IO_GET_FOREX_REAL_TIME_CURRENCY_CONVERSION` | Get Forex Real-Time Currency Conversion | Tool to convert amounts between currency pairs using real-time forex rates. Use when you need to perform currency conversions with the latest market rates. |
| `POLYGON_IO_GET_FOREX_RSI` | Get Forex RSI | Tool to calculate the Relative Strength Index (RSI) technical indicator for a forex pair. Use when you need momentum analysis or want to identify overbought/oversold conditions for currency pairs. |
| `POLYGON_IO_GET_FOREX_SMA` | Get Forex SMA | Tool to calculate Simple Moving Average (SMA) technical indicator for a forex pair. Use when you need trend analysis or moving average calculations for currency pairs. |
| `POLYGON_IO_GET_FUTURES_QUOTES` | Get Futures Quotes | Tool to get real-time quote information for futures contracts with bid/ask prices, sizes, and timestamps. Use when you need to analyze current or historical quote data for futures trading decisions. |
| `POLYGON_IO_GET_GROUPED_DAILY` | Get Grouped Daily Market Summary | Tool to retrieve daily OHLCV data for the entire market for a given date. Use when you need grouped daily aggregate bars for all tickers in a specific market (stocks, crypto, or fx) and locale. |
| `POLYGON_IO_GET_HISTORIC_FOREX_TICKS` | Get Historic Forex Ticks | Tool to get historic ticks for a currency pair on a specific date. Use when you need historical forex tick-level data (ask/bid prices with timestamps) for a given day. |
| `POLYGON_IO_GET_INFLATION_EXPECTATIONS` | Get Inflation Expectations | Tool to retrieve inflation expectations data from the Federal Reserve, including market-based rates and Cleveland Fed model estimates. Use when analyzing inflation forecasts across different time horizons (1, 5, 10, and 30 years). |
| `POLYGON_IO_GET_IPO_DATA` | Get IPO Data | Tool to retrieve comprehensive information on Initial Public Offerings (IPOs), including upcoming and historical events. Use when analyzing IPO listing data by date range, ticker, or identifier. |
| `POLYGON_IO_GET_LABOR_MARKET` | Get Labor Market Data | Tool to retrieve labor market data including unemployment rate, labor force participation rate, average hourly earnings, and job openings. Use when analyzing employment trends, economic conditions, or workforce statistics. |
| `POLYGON_IO_GET_MACD` | Get MACD | Tool to retrieve the Moving Average Convergence/Divergence (MACD) for a stock ticker. Use when you need momentum analysis or signal generation over a specified timeframe. |
| `POLYGON_IO_GET_MARKET_HOLIDAYS` | Get Market Holidays | Tool to retrieve upcoming market holidays and their corresponding open/close times. Use when planning around market schedules before trading. |
| `POLYGON_IO_GET_MARKET_STATUS` | Get Market Status | Tool to retrieve the current trading status across major exchanges and currency markets. Use for real-time monitoring, scheduling, or UI updates. |
| `POLYGON_IO_GET_NEWS` | Get News | Tool to retrieve the most recent news articles for a specified ticker. Use when you need summaries, source details, and sentiment analysis for market news. |
| `POLYGON_IO_GET_OPTIONS_CONTRACT_OVERVIEW` | Get Options Contract Overview | Tool to retrieve comprehensive details about a specific options contract including contract type, exercise style, expiration date, strike price, and underlying ticker. Use when you need specifications for options contract analysis or strategy development. |
| `POLYGON_IO_GET_OPTIONS_EMA` | Get Options EMA | Tool to calculate Exponential Moving Average (EMA) technical indicator for an options ticker. Use when you need trend analysis or moving average calculations for options contracts. |
| `POLYGON_IO_GET_OPTIONS_MACD` | Get Options MACD | Tool to calculate Moving Average Convergence/Divergence (MACD) technical indicator for an options ticker. Use when you need momentum analysis, trend identification, or trading signal generation for options contracts. |
| `POLYGON_IO_GET_OPTIONS_RSI` | Get Options RSI | Tool to calculate Relative Strength Index (RSI) technical indicator for an options ticker. Use when you need momentum analysis or want to identify overbought/oversold conditions for options contracts. |
| `POLYGON_IO_GET_OPTIONS_SMA` | Get Options SMA | Tool to calculate Simple Moving Average (SMA) technical indicator for an options ticker. Use when you need trend analysis or smoothed price data for options contracts. |
| `POLYGON_IO_GET_RELATED_COMPANIES` | Get Related Companies | Tool to retrieve tickers related to a given ticker based on similar business or market characteristics. Use when you need to find companies similar to a specific ticker. |
| `POLYGON_IO_GET_RSI` | Get RSI | Tool to retrieve the Relative Strength Index (RSI) for a stock ticker. Use after confirming ticker symbol and timespan to analyze momentum over a period. |
| `POLYGON_IO_GET_SMA` | Get Simple Moving Average | Tool to retrieve the Simple Moving Average (SMA) for any ticker (stocks, forex, crypto). Use when you need SMA values over a specified timespan with optional underlying data. |
| `POLYGON_IO_GET_SPLITS` | Get Splits | Tool to retrieve historical stock split events for a given ticker. Use after identifying the ticker to fetch split history including ratio, ex-date, and record dates. |
| `POLYGON_IO_GET_STOCKS_CUSTOM_BARS` | Get Stocks Custom Bars | Tool to retrieve aggregated historical OHLC and volume data for a stock over custom date ranges with configurable time windows. Use when you need aggregate bars for stock price analysis, backtesting, or charting. |
| `POLYGON_IO_GET_STOCKS_DAILY_MARKET_SUMMARY` | Get Stocks Daily Market Summary | Tool to retrieve daily OHLC, volume, and VWAP data for all U.S. stocks on a specified trading date. Use when you need to get grouped daily aggregate bars for all US stocks for a specific date. |
| `POLYGON_IO_GET_STOCKS_FILINGS_RISK_FACTORS` | Get Stocks Filings Risk Factors | Tool to retrieve risk factors identified in companies' 10K filings. Use when analyzing company risks, regulatory disclosures, or compliance requirements. |
| `POLYGON_IO_GET_STOCKS_FILINGS_SECTIONS` | Get Stocks Filings Sections | Tool to retrieve raw text content from specific sections of SEC filings (10-K, 10-Q, etc.). Use when you need detailed textual information from SEC documents like business descriptions or risk factors. |
| `POLYGON_IO_GET_STOCKS_FREE_FLOAT` | Get Stocks Free Float | Tool to retrieve free float data for US-listed securities showing the most recent available number of shares available for public trading and the percentage of total shares outstanding. Use when analyzing stock liquidity, ownership structure, or available trading shares. |
| `POLYGON_IO_GET_STOCKS_FULL_MARKET_SNAPSHOT` | Get Stocks Full Market Snapshot | Tool to retrieve a comprehensive snapshot of the entire U.S. stock market covering 10,000+ actively traded tickers. Use when you need current market-wide data including pricing, volume, and trade activity. Data is cleared daily at 3:30 AM EST and repopulates as exchanges report new data starting around 4:00 AM EST. |
| `POLYGON_IO_GET_STOCKS_INCOME_STATEMENTS` | Get Stocks Income Statements | Tool to retrieve comprehensive income statement data including revenue, expenses, and net income from company SEC filings. Use when analyzing profitability, revenue trends, or operational performance. |
| `POLYGON_IO_GET_STOCKS_PREVIOUS_DAY_BAR` | Get Stocks Previous Day Bar | Tool to retrieve the previous trading day's open, high, low, close (OHLC), and volume data for a stock ticker. Use when you need the most recent completed trading day's aggregate data. |
| `POLYGON_IO_GET_STOCKS_RISK_FACTOR_TAXONOMIES` | Get Stocks Risk Factor Taxonomies | Tool to retrieve the complete list of risk factor classifications used in the risk factors endpoint. Use when you need to understand available risk categories or filter by specific risk classifications. |
| `POLYGON_IO_GET_STOCKS_V1_DIVIDENDS` | Get Stocks V1 Dividends | Tool to retrieve historical dividend payment records for US stocks with split-adjusted amounts and historical adjustment factors. Use when analyzing dividend history with price normalization data. |
| `POLYGON_IO_GET_STOCKS_V1_SHORT_INTEREST` | Get Short Interest Data | Tool to retrieve comprehensive FINRA short interest data that tracks the short selling metrics for securities on a specific settlement date. Use when analyzing short positions, days to cover, and average daily volume for stocks. |
| `POLYGON_IO_GET_STOCKS_V1_SHORT_VOLUME` | Get Short Volume Data | Tool to retrieve short selling volume data for stock tickers. Use when analyzing short sale activity including total trading volume, short sale details, and breakdown by different trading platforms. |
| `POLYGON_IO_GET_STOCKS_V1_SPLITS` | Get Stocks V1 Splits | Tool to retrieve historical stock split and reverse split events for US equities with historical adjustment factors for price normalization. Use when analyzing stock split history including forward splits, reverse splits, and stock dividends. |
| `POLYGON_IO_GET_TICKER_EVENTS` | Get Ticker Events | Tool to retrieve timeline of ticker change events such as symbol renaming or rebranding. Use when tracking ticker history to maintain continuity in records and analyses. This is an experimental endpoint. |
| `POLYGON_IO_GET_TICKER_OVERVIEW` | Get Ticker Overview | Tool to retrieve comprehensive details for a single ticker, including identifiers, industry, and branding assets. Use after confirming the exact ticker symbol. |
| `POLYGON_IO_GET_TICKER_TYPES` | Get Ticker Types | Tool to retrieve a list of all ticker types supported by Polygon.io. Use when you need to enumerate valid ticker types for filtering or validation. |
| `POLYGON_IO_GET_TREASURY_YIELDS` | Get Treasury Yields | Tool to retrieve daily market yields for US Treasury securities across standard maturities (1-month to 30-year). Use when analyzing interest rate trends, yield curve analysis, or economic indicators. |
| `POLYGON_IO_LIST_EXCHANGES` | List Exchanges | Tool to retrieve all exchanges supported by Polygon.io with details about asset class and locale. Use when you need to list available exchanges for filtering market data or understanding trading venues. |
| `POLYGON_IO_LIST_FILING_FILES` | List Filing Files | Tool to retrieve files associated with an SEC filing by filing ID. Use when you need to list all documents, exhibits, and data files included in a specific SEC filing. |
| `POLYGON_IO_LIST_FILINGS` | List SEC Filings | Tool to retrieve SEC filings from the Polygon.io reference data API. Use when you need to search for 10-K, 10-Q, and other SEC filings by date, company, or filing type. |
| `POLYGON_IO_LIST_OPTIONS_CONTRACTS` | List Options Contracts | Tool to list and filter options contracts by underlying ticker, type, expiration, strike, and more. Use when you need to enumerate an options chain or find specific contracts matching criteria. |
| `POLYGON_IO_POLYGON_LAST_QUOTE_FOR_A_SYMBOL` | Last Quote for a Symbol | Tool to retrieve the last quote tick for a given stock symbol. Use when you need the most recent bid/ask prices, sizes, and exchange information for a stock. |
| `POLYGON_IO_POLYGON_LAST_TRADE_FOR_A_CURRENCY_PAIR` | Last Trade for a Currency Pair | Tool to retrieve the last trade tick for a currency pair in the forex market. Use when you need the most recent trade price, exchange, and timestamp for a specific currency pair. |

## Supported Triggers

None listed.

## Creating MCP Server - Stand-alone vs Composio SDK

The Polygon io MCP server is an implementation of the Model Context Protocol that connects your AI agent to Polygon io. It provides structured and secure access so your agent can perform Polygon io operations on your behalf through a secure, permission-based interface.
With Composio's managed implementation, you don't have to create your own developer app. For production, if you're building an end product, we recommend using your own credentials. The managed server helps you prototype fast and go from 0-1 faster.

## Step-by-step Guide

### 1. Prerequisites

Before you begin, make sure you have:
- Python 3.8/Node 16 or higher installed
- A Composio account with the API key
- An OpenAI API key
- A Polygon io account and project
- Basic familiarity with async Python/Typescript

### 1. Getting API Keys for OpenAI, Composio, and Polygon io

No description provided.

### 2. Installing dependencies

No description provided.
```python
pip install composio-llamaindex llama-index llama-index-llms-openai llama-index-tools-mcp python-dotenv
```

```typescript
npm install @composio/llamaindex @llamaindex/openai @llamaindex/tools @llamaindex/workflow dotenv
```

### 3. Set environment variables

Create a .env file in your project root:
These credentials will be used to:
- Authenticate with OpenAI's GPT-5 model
- Connect to Composio's Tool Router
- Identify your Composio user session for Polygon io access
```bash
OPENAI_API_KEY=your-openai-api-key
COMPOSIO_API_KEY=your-composio-api-key
COMPOSIO_USER_ID=your-user-id
```

### 4. Import modules

No description provided.
```python
import asyncio
import os
import dotenv

from composio import Composio
from composio_llamaindex import LlamaIndexProvider
from llama_index.core.agent.workflow import ReActAgent
from llama_index.core.workflow import Context
from llama_index.llms.openai import OpenAI
from llama_index.tools.mcp import BasicMCPClient, McpToolSpec

dotenv.load_dotenv()
```

```typescript
import "dotenv/config";
import readline from "node:readline/promises";
import { stdin as input, stdout as output } from "node:process";

import { Composio } from "@composio/core";

import { mcp } from "@llamaindex/tools";
import { agent as createAgent } from "@llamaindex/workflow";
import { openai } from "@llamaindex/openai";

dotenv.config();
```

### 5. Load environment variables and initialize Composio

No description provided.
```python
OPENAI_API_KEY = os.getenv("OPENAI_API_KEY")
COMPOSIO_API_KEY = os.getenv("COMPOSIO_API_KEY")
COMPOSIO_USER_ID = os.getenv("COMPOSIO_USER_ID")

if not OPENAI_API_KEY:
    raise ValueError("OPENAI_API_KEY is not set in the environment")
if not COMPOSIO_API_KEY:
    raise ValueError("COMPOSIO_API_KEY is not set in the environment")
if not COMPOSIO_USER_ID:
    raise ValueError("COMPOSIO_USER_ID is not set in the environment")
```

```typescript
const OPENAI_API_KEY = process.env.OPENAI_API_KEY;
const COMPOSIO_API_KEY = process.env.COMPOSIO_API_KEY;
const COMPOSIO_USER_ID = process.env.COMPOSIO_USER_ID;

if (!OPENAI_API_KEY) throw new Error("OPENAI_API_KEY is not set");
if (!COMPOSIO_API_KEY) throw new Error("COMPOSIO_API_KEY is not set");
if (!COMPOSIO_USER_ID) throw new Error("COMPOSIO_USER_ID is not set");
```

### 6. Create a Tool Router session and build the agent function

What's happening here:
- We create a Composio client using your API key and configure it with the LlamaIndex provider
- We then create a tool router MCP session for your user, specifying the toolkits we want to use (in this case, polygon io)
- The session returns an MCP HTTP endpoint URL that acts as a gateway to all your configured tools
- LlamaIndex will connect to this endpoint to dynamically discover and use the available Polygon io tools.
- The MCP tools are mapped to LlamaIndex-compatible tools and plug them into the Agent.
```python
async def build_agent() -> ReActAgent:
    composio_client = Composio(
        api_key=COMPOSIO_API_KEY,
        provider=LlamaIndexProvider(),
    )

    session = composio_client.create(
        user_id=COMPOSIO_USER_ID,
        toolkits=["polygon_io"],
    )

    mcp_url = session.mcp.url
    print(f"Composio MCP URL: {mcp_url}")

    mcp_client = BasicMCPClient(mcp_url, headers={"x-api-key": COMPOSIO_API_KEY})
    mcp_tool_spec = McpToolSpec(client=mcp_client)
    tools = await mcp_tool_spec.to_tool_list_async()

    llm = OpenAI(model="gpt-5")

    description = "An agent that uses Composio Tool Router MCP tools to perform Polygon io actions."
    system_prompt = """
    You are a helpful assistant connected to Composio Tool Router.
    Use the available tools to answer user queries and perform Polygon io actions.
    """
    return ReActAgent(tools=tools, llm=llm, description=description, system_prompt=system_prompt, verbose=True)
```

```typescript
async function buildAgent() {

  console.log(`Initializing Composio client...${COMPOSIO_USER_ID!}...`);
  console.log(`COMPOSIO_USER_ID: ${COMPOSIO_USER_ID!}...`);

  const composio = new Composio({
    apiKey: COMPOSIO_API_KEY,
    provider: new LlamaindexProvider(),
  });

  const session = await composio.create(
    COMPOSIO_USER_ID!,
    {
      toolkits: ["polygon_io"],
    },
  );

  const mcpUrl = session.mcp.url;
  console.log(`Composio Tool Router MCP URL: ${mcpUrl}`);

  const server = mcp({
    url: mcpUrl,
    clientName: "composio_tool_router_with_llamaindex",
    requestInit: {
      headers: {
        "x-api-key": COMPOSIO_API_KEY!,
      },
    },
    // verbose: true,
  });

  const tools = await server.tools();

  const llm = openai({ apiKey: OPENAI_API_KEY, model: "gpt-5" });

  const agent = createAgent({
    name: "composio_tool_router_with_llamaindex",
        description : "An agent that uses Composio Tool Router MCP tools to perform actions.",
    systemPrompt:
      "You are a helpful assistant connected to Composio Tool Router."+
"Use the available tools to answer user queries and perform Polygon io actions." ,
    llm,
    tools,
  });

  return agent;
}
```

### 7. Create an interactive chat loop

No description provided.
```python
async def chat_loop(agent: ReActAgent) -> None:
    ctx = Context(agent)
    print("Type 'quit', 'exit', or Ctrl+C to stop.")

    while True:
        try:
            user_input = input("\nYou: ").strip()
        except (KeyboardInterrupt, EOFError):
            print("\nBye!")
            break

        if not user_input or user_input.lower() in {"quit", "exit"}:
            print("Bye!")
            break

        try:
            print("Agent: ", end="", flush=True)
            handler = agent.run(user_input, ctx=ctx)

            async for event in handler.stream_events():
                # Stream token-by-token from LLM responses
                if hasattr(event, "delta") and event.delta:
                    print(event.delta, end="", flush=True)
                # Show tool calls as they happen
                elif hasattr(event, "tool_name"):
                    print(f"\n[Using tool: {event.tool_name}]", flush=True)

            # Get final response
            response = await handler
            print()  # Newline after streaming
        except KeyboardInterrupt:
            print("\n[Interrupted]")
            continue
        except Exception as e:
            print(f"\nError: {e}")
```

```typescript
async function chatLoop(agent: ReturnType<typeof createAgent>) {
  const rl = readline.createInterface({ input, output });

  console.log("Type 'quit' or 'exit' to stop.");

  while (true) {
    let userInput: string;

    try {
      userInput = (await rl.question("\nYou: ")).trim();
    } catch {
      console.log("\nAgent: Bye!");
      break;
    }

    if (!userInput) {
      continue;
    }

    const lower = userInput.toLowerCase();
    if (lower === "quit" || lower === "exit") {
      console.log("Agent: Bye!");
      break;
    }

    try {
      process.stdout.write("Agent: ");

      const stream = agent.runStream(userInput);
      let finalResult: any = null;

      for await (const event of stream) {
        // The event.data contains the streamed content
        const data: any = event.data;

        // Check for streaming delta content
        if (data?.delta) {
          process.stdout.write(data.delta);
        }

        // Store final result for fallback
        if (data?.result || data?.message) {
          finalResult = data;
        }
      }

      // If no streaming happened, show the final result
      if (finalResult) {
        const answer =
          finalResult.result ??
          finalResult.message?.content ??
          finalResult.message ??
          "";
        if (answer && typeof answer === "string" && !answer.includes("[object")) {
          process.stdout.write(answer);
        }
      }

      console.log(); // New line after streaming completes
    } catch (err: any) {
      console.error("\nAgent error:", err?.message ?? err);
    }
  }

  rl.close();
}
```

### 8. Define the main entry point

What's happening here:
- We're orchestrating the entire application flow
- The agent gets built with proper error handling
- Then we kick off the interactive chat loop so you can start talking to Polygon io
```python
async def main() -> None:
    agent = await build_agent()
    await chat_loop(agent)

if __name__ == "__main__":
    # Handle Ctrl+C gracefully
    signal.signal(signal.SIGINT, lambda s, f: (print("\nBye!"), exit(0)))
    try:
        asyncio.run(main())
    except KeyboardInterrupt:
        print("\nBye!")
```

```typescript
async function main() {
  try {
    const agent = await buildAgent();
    await chatLoop(agent);
  } catch (err) {
    console.error("Failed to start agent:", err);
    process.exit(1);
  }
}

main();
```

### 9. Run the agent

When prompted, authenticate and authorise your agent with Polygon io, then start asking questions.
```bash
python llamaindex_agent.py
```

```typescript
npx ts-node llamaindex-agent.ts
```

## Complete Code

```python
import asyncio
import os
import signal
import dotenv

from composio import Composio
from composio_llamaindex import LlamaIndexProvider
from llama_index.core.agent.workflow import ReActAgent
from llama_index.core.workflow import Context
from llama_index.llms.openai import OpenAI
from llama_index.tools.mcp import BasicMCPClient, McpToolSpec

dotenv.load_dotenv()

OPENAI_API_KEY = os.getenv("OPENAI_API_KEY")
COMPOSIO_API_KEY = os.getenv("COMPOSIO_API_KEY")
COMPOSIO_USER_ID = os.getenv("COMPOSIO_USER_ID")

if not OPENAI_API_KEY:
    raise ValueError("OPENAI_API_KEY is not set")
if not COMPOSIO_API_KEY:
    raise ValueError("COMPOSIO_API_KEY is not set")
if not COMPOSIO_USER_ID:
    raise ValueError("COMPOSIO_USER_ID is not set")

async def build_agent() -> ReActAgent:
    composio_client = Composio(
        api_key=COMPOSIO_API_KEY,
        provider=LlamaIndexProvider(),
    )

    session = composio_client.create(
        user_id=COMPOSIO_USER_ID,
        toolkits=["polygon_io"],
    )

    mcp_url = session.mcp.url
    print(f"Composio MCP URL: {mcp_url}")

    mcp_client = BasicMCPClient(mcp_url, headers={"x-api-key": COMPOSIO_API_KEY})
    mcp_tool_spec = McpToolSpec(client=mcp_client)
    tools = await mcp_tool_spec.to_tool_list_async()

    llm = OpenAI(model="gpt-5")
    description = "An agent that uses Composio Tool Router MCP tools to perform Polygon io actions."
    system_prompt = """
    You are a helpful assistant connected to Composio Tool Router.
    Use the available tools to answer user queries and perform Polygon io actions.
    """
    return ReActAgent(
        tools=tools,
        llm=llm,
        description=description,
        system_prompt=system_prompt,
        verbose=True,
    );

async def chat_loop(agent: ReActAgent) -> None:
    ctx = Context(agent)
    print("Type 'quit', 'exit', or Ctrl+C to stop.")

    while True:
        try:
            user_input = input("\nYou: ").strip()
        except (KeyboardInterrupt, EOFError):
            print("\nBye!")
            break

        if not user_input or user_input.lower() in {"quit", "exit"}:
            print("Bye!")
            break

        try:
            print("Agent: ", end="", flush=True)
            handler = agent.run(user_input, ctx=ctx)

            async for event in handler.stream_events():
                # Stream token-by-token from LLM responses
                if hasattr(event, "delta") and event.delta:
                    print(event.delta, end="", flush=True)
                # Show tool calls as they happen
                elif hasattr(event, "tool_name"):
                    print(f"\n[Using tool: {event.tool_name}]", flush=True)

            # Get final response
            response = await handler
            print()  # Newline after streaming
        except KeyboardInterrupt:
            print("\n[Interrupted]")
            continue
        except Exception as e:
            print(f"\nError: {e}")

async def main() -> None:
    agent = await build_agent()
    await chat_loop(agent)

if __name__ == "__main__":
    # Handle Ctrl+C gracefully
    signal.signal(signal.SIGINT, lambda s, f: (print("\nBye!"), exit(0)))
    try:
        asyncio.run(main())
    except KeyboardInterrupt:
        print("\nBye!")
```

```typescript
import "dotenv/config";
import readline from "node:readline/promises";
import { stdin as input, stdout as output } from "node:process";

import { Composio } from "@composio/core";
import { LlamaindexProvider } from "@composio/llamaindex";

import { mcp } from "@llamaindex/tools";
import { agent as createAgent } from "@llamaindex/workflow";
import { openai } from "@llamaindex/openai";

dotenv.config();

const OPENAI_API_KEY = process.env.OPENAI_API_KEY;
const COMPOSIO_API_KEY = process.env.COMPOSIO_API_KEY;
const COMPOSIO_USER_ID = process.env.COMPOSIO_USER_ID;

if (!OPENAI_API_KEY) {
    throw new Error("OPENAI_API_KEY is not set in the environment");
  }
if (!COMPOSIO_API_KEY) {
    throw new Error("COMPOSIO_API_KEY is not set in the environment");
  }
if (!COMPOSIO_USER_ID) {
    throw new Error("COMPOSIO_USER_ID is not set in the environment");
  }

async function buildAgent() {

  console.log(`Initializing Composio client...${COMPOSIO_USER_ID!}...`);
  console.log(`COMPOSIO_USER_ID: ${COMPOSIO_USER_ID!}...`);

  const composio = new Composio({
    apiKey: COMPOSIO_API_KEY,
    provider: new LlamaindexProvider(),
  });

  const session = await composio.create(
    COMPOSIO_USER_ID!,
    {
      toolkits: ["polygon_io"],
    },
  );

  const mcpUrl = session.mcp.url;
  console.log(`Composio Tool Router MCP URL: ${mcpUrl}`);

  const server = mcp({
    url: mcpUrl,
    clientName: "composio_tool_router_with_llamaindex",
    requestInit: {
      headers: {
        "x-api-key": COMPOSIO_API_KEY!,
      },
    },
    // verbose: true,
  });

  const tools = await server.tools();

  const llm = openai({ apiKey: OPENAI_API_KEY, model: "gpt-5" });

  const agent = createAgent({
    name: "composio_tool_router_with_llamaindex",
    description:
      "An agent that uses Composio Tool Router MCP tools to perform actions.",
    systemPrompt:
      "You are a helpful assistant connected to Composio Tool Router."+
"Use the available tools to answer user queries and perform Polygon io actions." ,
    llm,
    tools,
  });

  return agent;
}

async function chatLoop(agent: ReturnType<typeof createAgent>) {
  const rl = readline.createInterface({ input, output });

  console.log("Type 'quit' or 'exit' to stop.");

  while (true) {
    let userInput: string;

    try {
      userInput = (await rl.question("\nYou: ")).trim();
    } catch {
      console.log("\nAgent: Bye!");
      break;
    }

    if (!userInput) {
      continue;
    }

    const lower = userInput.toLowerCase();
    if (lower === "quit" || lower === "exit") {
      console.log("Agent: Bye!");
      break;
    }

    try {
      process.stdout.write("Agent: ");

      const stream = agent.runStream(userInput);
      let finalResult: any = null;

      for await (const event of stream) {
        // The event.data contains the streamed content
        const data: any = event.data;

        // Check for streaming delta content
        if (data?.delta) {
          process.stdout.write(data.delta);
        }

        // Store final result for fallback
        if (data?.result || data?.message) {
          finalResult = data;
        }
      }

      // If no streaming happened, show the final result
      if (finalResult) {
        const answer =
          finalResult.result ??
          finalResult.message?.content ??
          finalResult.message ??
          "";
        if (answer && typeof answer === "string" && !answer.includes("[object")) {
          process.stdout.write(answer);
        }
      }

      console.log(); // New line after streaming completes
    } catch (err: any) {
      console.error("\nAgent error:", err?.message ?? err);
    }
  }

  rl.close();
}

async function main() {
  try {
    const agent = await buildAgent();
    await chatLoop(agent);
  } catch (err: any) {
    console.error("Failed to start agent:", err?.message ?? err);
    process.exit(1);
  }
}

main();
```

## Conclusion

You've successfully connected Polygon io to LlamaIndex through Composio's Tool Router MCP layer.
Key takeaways:
- Tool Router dynamically exposes Polygon io tools through an MCP endpoint
- LlamaIndex's ReActAgent handles reasoning and orchestration; Composio handles integrations
- The agent becomes more capable without increasing prompt size
- Async Python provides clean, efficient execution of agent workflows
You can easily extend this to other toolkits like Gmail, Notion, Stripe, GitHub, and more by adding them to the toolkits parameter.

## How to build Polygon io MCP Agent with another framework

- [OpenAI Agents SDK](https://composio.dev/toolkits/polygon_io/framework/open-ai-agents-sdk)
- [Claude Agent SDK](https://composio.dev/toolkits/polygon_io/framework/claude-agents-sdk)
- [Claude Code](https://composio.dev/toolkits/polygon_io/framework/claude-code)
- [Claude Cowork](https://composio.dev/toolkits/polygon_io/framework/claude-cowork)
- [Codex](https://composio.dev/toolkits/polygon_io/framework/codex)
- [OpenClaw](https://composio.dev/toolkits/polygon_io/framework/openclaw)
- [Hermes](https://composio.dev/toolkits/polygon_io/framework/hermes-agent)
- [CLI](https://composio.dev/toolkits/polygon_io/framework/cli)
- [Google ADK](https://composio.dev/toolkits/polygon_io/framework/google-adk)
- [LangChain](https://composio.dev/toolkits/polygon_io/framework/langchain)
- [Vercel AI SDK](https://composio.dev/toolkits/polygon_io/framework/ai-sdk)
- [Mastra AI](https://composio.dev/toolkits/polygon_io/framework/mastra-ai)
- [CrewAI](https://composio.dev/toolkits/polygon_io/framework/crew-ai)

## Related Toolkits

- [Stripe](https://composio.dev/toolkits/stripe) - Stripe is a global online payments platform offering APIs for managing payments, customers, and subscriptions. Trusted by businesses for secure, efficient, and scalable payment processing worldwide.
- [Alpha vantage](https://composio.dev/toolkits/alpha_vantage) - Alpha Vantage is a financial data platform offering real-time and historical stock market APIs. Get instant, reliable access to equities, forex, and technical analysis data for smarter trading decisions.
- [Altoviz](https://composio.dev/toolkits/altoviz) - Altoviz is a cloud-based billing and invoicing platform for businesses. It streamlines online payments, expense tracking, and customizable invoice management.
- [Benzinga](https://composio.dev/toolkits/benzinga) - Benzinga provides real-time financial news and data APIs for market coverage. It helps you track breaking news and actionable market insights instantly.
- [Brex](https://composio.dev/toolkits/brex) - Brex provides corporate credit cards and spend management tailored for startups and tech businesses. It helps optimize company cash flow, streamline accounting, and accelerate business growth.
- [Chaser](https://composio.dev/toolkits/chaser) - Chaser is accounts receivable automation software that sends invoice reminders and helps businesses get paid faster. It streamlines the collections process to save time and improve cash flow.
- [Clientary](https://composio.dev/toolkits/clientary) - Clientary is a platform for managing clients, invoices, projects, proposals, and more. It streamlines client work and saves you serious admin time.
- [Coinbase](https://composio.dev/toolkits/coinbase) - Coinbase is a platform for buying, selling, and storing cryptocurrency. It makes exchanging and managing crypto simple and secure for everyone.
- [Coinranking](https://composio.dev/toolkits/coinranking) - Coinranking is a comprehensive cryptocurrency market data platform offering access to real-time coin prices, market caps, and historical data. Get accurate, up-to-date stats for thousands of digital assets in one place.
- [Coupa](https://composio.dev/toolkits/coupa) - Coupa is a business spend management platform for procurement, invoicing, and expenses. It helps organizations streamline purchasing, control costs, and gain complete visibility over financial operations.
- [CurrencyScoop](https://composio.dev/toolkits/currencyscoop) - CurrencyScoop is a developer-friendly API for real-time and historical currency exchange rates. Easily access fiat and crypto data for smart, up-to-date financial applications.
- [Daffy](https://composio.dev/toolkits/daffy) - Daffy is a modern charitable giving platform with a donor-advised fund. Easily set aside funds, grow them tax-free, and donate to over 1.7 million U.S. charities.
- [Eagle doc](https://composio.dev/toolkits/eagle_doc) - Eagle doc is an AI-powered OCR API for invoices and receipts. It delivers fast, reliable, and accurate document data extraction for seamless automation.
- [Elorus](https://composio.dev/toolkits/elorus) - Elorus is an online invoicing and time-tracking software for freelancers and small businesses. Easily manage finances, bill clients, and track work in one place.
- [Eodhd apis](https://composio.dev/toolkits/eodhd_apis) - Eodhd apis delivers comprehensive financial data, including live and historical stock prices, via robust APIs. Easily access reliable, up-to-date market insights to power your apps, dashboards, and analytics.
- [Fidel api](https://composio.dev/toolkits/fidel_api) - Fidel api is a secure platform for linking payment cards to web and mobile apps. It enables real-time card transaction monitoring and event-based automation for businesses.
- [Finage](https://composio.dev/toolkits/finage) - Finage is a secure API platform delivering real-time and historical financial data for stocks, forex, crypto, indices, and commodities. It empowers developers and businesses to access, analyze, and act on market data instantly.
- [Finmei](https://composio.dev/toolkits/finmei) - Finmei is an invoicing tool that simplifies billing, invoice management, and expense tracking. Ideal for automating and organizing your business finances in one place.
- [Fixer](https://composio.dev/toolkits/fixer) - Fixer is a currency data API offering real-time and historical exchange rates for 170 currencies. Instantly access accurate, up-to-date forex data for your applications and workflows.
- [Fixer io](https://composio.dev/toolkits/fixer_io) - Fixer.io is a lightweight API for real-time and historical foreign exchange rates. It makes global currency conversion fast, accurate, and hassle-free.

## Frequently Asked Questions

### What are the differences in Tool Router MCP and Polygon io MCP?

With a standalone Polygon io MCP server, the agents and LLMs can only access a fixed set of Polygon io tools tied to that server. However, with the Composio Tool Router, agents can dynamically load tools from Polygon io and many other apps based on the task at hand, all through a single MCP endpoint.

### Can I use Tool Router MCP with LlamaIndex?

Yes, you can. LlamaIndex fully supports MCP integration. You get structured tool calling, message history handling, and model orchestration while Tool Router takes care of discovering and serving the right Polygon io tools.

### Can I manage the permissions and scopes for Polygon io while using Tool Router?

Yes, absolutely. You can configure which Polygon io scopes and actions are allowed when connecting your account to Composio. You can also bring your own OAuth credentials or API configuration so you keep full control over what the agent can do.

### How safe is my data with Composio Tool Router?

All sensitive data such as tokens, keys, and configuration is fully encrypted at rest and in transit. Composio is SOC 2 Type 2 compliant and follows strict security practices so your Polygon io data and credentials are handled as safely as possible.

---
[See all toolkits](https://composio.dev/toolkits) · [Composio docs](https://docs.composio.dev/llms.txt)