How to integrate Amplitude MCP with OpenAI Agents SDK

This guide walks you through connecting Amplitude to the OpenAI Agents SDK using the Composio tool router. By the end, you'll have a working Amplitude agent that can get daily active users for last month, generate funnel analysis for onboarding flow, list top events for premium users through natural language commands. This guide will help you understand how to give your OpenAI Agents SDK agent real control over a Amplitude account through Composio's Amplitude MCP server. Before we dive in, let's take a quick look at the key ideas and tools involved.

Get started for freeGet a demo
Amplitude logoAmplitude
Api Key

Amplitude is a digital analytics platform for product and behavioral data insights. It helps teams analyze user journeys and make data-driven decisions quickly.

54 Tools

Introduction

This guide walks you through connecting Amplitude to the OpenAI Agents SDK using the Composio tool router. By the end, you'll have a working Amplitude agent that can get daily active users for last month, generate funnel analysis for onboarding flow, list top events for premium users through natural language commands.

This guide will help you understand how to give your OpenAI Agents SDK agent real control over a Amplitude account through Composio's Amplitude MCP server.

Before we dive in, let's take a quick look at the key ideas and tools involved.

Also integrate Amplitude with

Claude Agent SDKClaude CodeClaude CoworkCodexOpenClawHermesCLIGoogle ADKLangChainVercel AI SDKMastra AILlamaIndexCrewAI

TL;DR

Here's what you'll learn:
  • Get and set up your OpenAI and Composio API keys
  • Install the necessary dependencies
  • Initialize Composio and create a Tool Router session for Amplitude
  • Configure an AI agent that can use Amplitude as a tool
  • Run a live chat session where you can ask the agent to perform Amplitude operations

What is OpenAI Agents SDK?

The OpenAI Agents SDK is a lightweight framework for building AI agents that can use tools and maintain conversation state. It provides a simple interface for creating agents with hosted MCP tool support.

Key features include:

  • Hosted MCP Tools: Connect to external services through hosted MCP endpoints
  • SQLite Sessions: Persist conversation history across interactions
  • Simple API: Clean interface with Agent, Runner, and tool configuration
  • Streaming Support: Real-time response streaming for interactive applications

What is the Amplitude MCP server, and what's possible with it?

The Amplitude MCP server is an implementation of the Model Context Protocol that connects your AI agent and assistants like Claude, Cursor, etc directly to your Amplitude account. It provides structured and secure access to your analytics platform, so your agent can perform actions like managing event types, organizing cohorts, updating user properties, and tracking event categories on your behalf.

  • Cohort and user management: Ask your agent to request, download, and check the status of specific user cohorts for advanced segmentation or analysis.
  • Event type and category administration: Effortlessly create, update, or delete event types and categories, keeping your analytics taxonomy organized and up to date.
  • User property updates: Direct your agent to set or modify user properties—like device information or location—without sending new events, making user profile management a breeze.
  • Comprehensive analytics lookup: Retrieve detailed information about event types and categories, enabling your agent to provide insights or answer analytics questions in real time.

What is the Composio tool router, and how does it fit here?

What is Composio SDK?

Composio's Composio SDK helps agents find the right tools for a task at runtime. You can plug in multiple toolkits (like Gmail, HubSpot, and GitHub), and the agent will identify the relevant app and action to complete multi-step workflows. This can reduce token usage and improve the reliability of tool calls. Read more here: Getting started with Composio SDK

The tool router generates a secure MCP URL that your agents can access to perform actions.

How the Composio SDK works

The Composio SDK follows a three-phase workflow:

  1. Discovery: Searches for tools matching your task and returns relevant toolkits with their details.
  2. Authentication: Checks for active connections. If missing, creates an auth config and returns a connection URL via Auth Link.
  3. Execution: Executes the action using the authenticated connection.

Step-by-step Guide

Step by step09 STEPS
1

Prerequisites

Before starting, make sure you have:
  • Composio API Key and OpenAI API Key
  • Primary know-how of OpenAI Agents SDK
  • A live Amplitude project
  • Some knowledge of Python or Typescript
2

Getting API Keys for OpenAI and Composio

OpenAI API Key
  • Go to the OpenAI dashboard and create an API key. You'll need credits to use the models, or you can connect to another model provider.
  • Keep the API key safe.
Composio API Key
3

Install dependencies

npm install @composio/openai-agents @openai/agents dotenv

Install the Composio SDK and the OpenAI Agents SDK.

4

Set up environment variables

bash
OPENAI_API_KEY=sk-...your-api-key
COMPOSIO_API_KEY=your-api-key
USER_ID=composio_user@gmail.com

Create a .env file and add your OpenAI and Composio API keys.

5

Import dependencies

import 'dotenv/config';
import { Composio } from '@composio/core';
import { OpenAIAgentsProvider } from '@composio/openai-agents';
import { Agent, hostedMcpTool, run, OpenAIConversationsSession } from '@openai/agents';
import * as readline from 'readline';
What's happening:
  • You're importing all necessary libraries.
  • The Composio and OpenAIAgentsProvider classes are imported to connect your OpenAI agent to Composio tools like Amplitude.
6

Set up the Composio instance

dotenv.config();

const composioApiKey = process.env.COMPOSIO_API_KEY;
const userId = process.env.USER_ID;

if (!composioApiKey) {
  throw new Error('COMPOSIO_API_KEY is not set. Create a .env file with COMPOSIO_API_KEY=your_key');
}
if (!userId) {
  throw new Error('USER_ID is not set');
}

// Initialize Composio
const composio = new Composio({
  apiKey: composioApiKey,
  provider: new OpenAIAgentsProvider(),
});
What's happening:
  • dotenv.config() loads your .env file so COMPOSIO_API_KEY and USER_ID are available as environment variables.
  • Creating a Composio instance using the API Key and OpenAIAgentsProvider class.
7

Create a Tool Router session

// Create Tool Router session for Amplitude
const session = await composio.create(userId as string, {
  toolkits: ['amplitude'],
});
const mcpUrl = session.mcp.url;

What is happening:

  • You give the Tool Router the user id and the toolkits you want available. Here, it is only amplitude.
  • The router checks the user's Amplitude connection and prepares the MCP endpoint.
  • The returned session.mcp.url is the MCP URL that your agent will use to access Amplitude.
  • This approach keeps things lightweight and lets the agent request Amplitude tools only when needed during the conversation.
8

Configure the agent

// Configure agent with MCP tool
const agent = new Agent({
  name: 'Assistant',
  model: 'gpt-5',
  instructions:
    'You are a helpful assistant that can access Amplitude. Help users perform Amplitude operations through natural language.',
  tools: [
    hostedMcpTool({
      serverLabel: 'tool_router',
      serverUrl: mcpUrl,
      headers: { 'x-api-key': composioApiKey },
      requireApproval: 'never',
    }),
  ],
});
What's happening:
  • We're creating an Agent instance with a name, model (gpt-5), and clear instructions about its purpose.
  • The agent's instructions tell it that it can access Amplitude and help with queries, inserts, updates, authentication, and fetching database information.
  • The tools array includes a hostedMcpTool that connects to the MCP server URL we created earlier.
  • The headers object includes the Composio API key for secure authentication with the MCP server.
  • requireApproval: 'never' means the agent can execute Amplitude operations without asking for permission each time, making interactions smoother.
9

Start chat loop and handle conversation

// Keep conversation state across turns
const conversationSession = new OpenAIConversationsSession();

// Simple CLI
const rl = readline.createInterface({
  input: process.stdin,
  output: process.stdout,
  prompt: 'You: ',
});

console.log('\nComposio Tool Router session created.');
console.log('\nChat started. Type your requests below.');
console.log("Commands: 'exit', 'quit', or 'q' to end\n");

try {
  const first = await run(agent, 'What can you help me with?', { session: conversationSession });
  console.log(`Assistant: ${first.finalOutput}\n`);
} catch (e) {
  console.error('Error:', e instanceof Error ? e.message : e, '\n');
}

rl.prompt();

rl.on('line', async (userInput) => {
  const text = userInput.trim();

  if (['exit', 'quit', 'q'].includes(text.toLowerCase())) {
    console.log('Goodbye!');
    rl.close();
    process.exit(0);
  }

  if (!text) {
    rl.prompt();
    return;
  }

  try {
    const result = await run(agent, text, { session: conversationSession });
    console.log(`\nAssistant: ${result.finalOutput}\n`);
  } catch (e) {
    console.error('Error:', e instanceof Error ? e.message : e, '\n');
  }

  rl.prompt();
});

rl.on('close', () => {
  console.log('\n👋 Session ended.');
  process.exit(0);
});
What's happening:
  • The program prints a session URL that you visit to authorize Amplitude.
  • After authorization, the chat begins.
  • Each message you type is processed by the agent using run().
  • The responses are printed to the console.
  • Typing exit, quit, or q cleanly ends the chat.

Complete Code

Here's the complete code to get you started with Amplitude and OpenAI Agents SDK:

import 'dotenv/config';
import { Composio } from '@composio/core';
import { OpenAIAgentsProvider } from '@composio/openai-agents';
import { Agent, hostedMcpTool, run, OpenAIConversationsSession } from '@openai/agents';
import * as readline from 'readline';

const composioApiKey = process.env.COMPOSIO_API_KEY;
const userId = process.env.USER_ID;

if (!composioApiKey) {
  throw new Error('COMPOSIO_API_KEY is not set. Create a .env file with COMPOSIO_API_KEY=your_key');
}
if (!userId) {
  throw new Error('USER_ID is not set');
}

// Initialize Composio
const composio = new Composio({
  apiKey: composioApiKey,
  provider: new OpenAIAgentsProvider(),
});

async function main() {
  // Create Tool Router session
  const session = await composio.create(userId as string, {
    toolkits: ['amplitude'],
  });
  const mcpUrl = session.mcp.url;

  // Configure agent with MCP tool
  const agent = new Agent({
    name: 'Assistant',
    model: 'gpt-5',
    instructions:
      'You are a helpful assistant that can access Amplitude. Help users perform Amplitude operations through natural language.',
    tools: [
      hostedMcpTool({
        serverLabel: 'tool_router',
        serverUrl: mcpUrl,
        headers: { 'x-api-key': composioApiKey },
        requireApproval: 'never',
      }),
    ],
  });

  // Keep conversation state across turns
  const conversationSession = new OpenAIConversationsSession();

  // Simple CLI
  const rl = readline.createInterface({
    input: process.stdin,
    output: process.stdout,
    prompt: 'You: ',
  });

  console.log('\nComposio Tool Router session created.');
  console.log('\nChat started. Type your requests below.');
  console.log("Commands: 'exit', 'quit', or 'q' to end\n");

  try {
    const first = await run(agent, 'What can you help me with?', { session: conversationSession });
    console.log(`Assistant: ${first.finalOutput}\n`);
  } catch (e) {
    console.error('Error:', e instanceof Error ? e.message : e, '\n');
  }

  rl.prompt();

  rl.on('line', async (userInput) => {
    const text = userInput.trim();

    if (['exit', 'quit', 'q'].includes(text.toLowerCase())) {
      console.log('Goodbye!');
      rl.close();
      process.exit(0);
    }

    if (!text) {
      rl.prompt();
      return;
    }

    try {
      const result = await run(agent, text, { session: conversationSession });
      console.log(`\nAssistant: ${result.finalOutput}\n`);
    } catch (e) {
      console.error('Error:', e instanceof Error ? e.message : e, '\n');
    }

    rl.prompt();
  });

  rl.on('close', () => {
    console.log('\nSession ended.');
    process.exit(0);
  });
}

main().catch((err) => {
  console.error('Fatal error:', err);
  process.exit(1);
});

Conclusion

This was a starter code for integrating Amplitude MCP with OpenAI Agents SDK to build a functional AI agent that can interact with Amplitude.

Key features:

  • Hosted MCP tool integration through Composio's Tool Router
  • SQLite session persistence for conversation history
  • Simple async chat loop for interactive testing
You can extend this by adding more toolkits, implementing custom business logic, or building a web interface around the agent.
TOOLS

Supported Tools

Every Amplitude action and event your agent gets out of the box.

Bulk Assign Annotations to Category

Tool to bulk assign multiple annotations to a category in Amplitude.

Cancel User Deletion

Cancel a pending user deletion request in Amplitude.

Check Amplitude Cohort Status

Check the status of a cohort export request.

Create Chart Annotation in Amplitude

Create a chart annotation in Amplitude to mark important dates.

Create Annotation Category

Tool to create an annotation category in Amplitude to organize annotations.

Create Amplitude Event Category

Create a new event category in Amplitude.

Create Amplitude Event Type

Create a new event type in Amplitude.

Create Amplitude Release

Create a release to document product changes.

Delete Amplitude Chart Annotation

Delete a chart annotation from Amplitude.

Delete Amplitude Annotation Category

Delete an annotation category from Amplitude.

Delete Amplitude Event Category

Delete an event category from Amplitude.

Delete Amplitude Event Type

Delete an event type from Amplitude.

Delete Amplitude Users

Submit user deletion requests for GDPR/CCPA compliance.

Download Amplitude Cohort File

Download the cohort file after request is complete.

Search Amplitude User

Search for users in Amplitude by canonical identifier (Amplitude ID, device ID, user ID, or user ID prefix).

Get Active or New Users

Get the number of active or new users for a date range with optional segmentation.

Get Amplitude Annotation

Get a single chart annotation by ID from Amplitude.

Get Amplitude Annotation Category

Get a single annotation category by ID from Amplitude.

Request Amplitude Cohort

Get a single cohort by ID and initiate download.

Get User Deletion Requests

Get the status of user deletion requests within a date range.

Get Amplitude Event Categories

Get event categories from Amplitude.

Get Amplitude Event Property

Get a specific event property from Amplitude taxonomy.

Get Event Segmentation Data

Get event segmentation data from Amplitude Analytics API.

Get Amplitude Event Type

Get a specific event type from Amplitude by name.

Get Amplitude Event Types

Get all event types from Amplitude.

Get Funnel Analysis Data

Get funnel analysis data showing user conversion through a sequence of events.

Get Real-time Active Users

Get real-time active users count from Amplitude.

Get User Retention Analysis

Get user retention analysis showing how users return over time after a starting action.

Get Revenue LTV Metrics

Get revenue lifetime value (LTV) metrics including ARPU, ARPPU, and total revenue.

Get Session Average Length

Get average session length (in seconds) for a specified date range from Amplitude.

Get Session Length Distribution

Tool to retrieve session length distribution data for a specified date range from Amplitude.

Get Sessions Per User from Amplitude

Tool to get average number of sessions per user for each day in a date range from Amplitude.

Get User Activity from Amplitude

Fetch a single user's profile summary and event stream by Amplitude ID.

Get User Composition by Property

Tool to get user composition breakdown by property (platform, version, country, etc.

Get User Mappings

Get the list of user mappings for provided user IDs.

Get Amplitude User Property

Get a specific user property from Amplitude taxonomy.

Update User Properties in Amplitude

Update user properties using Amplitude's Identify API.

List Amplitude Annotation Categories

List all annotation categories from Amplitude.

List Chart Annotations

Tool to get all chart annotations with optional filtering by category, chart, and date range.

List Amplitude Cohorts

List all discoverable cohorts for an Amplitude project.

List Amplitude Event Properties

Get all event properties from Amplitude, optionally filtered by event type or property name.

List Amplitude Events

Tool to get a list of all event types in your Amplitude project with current week's statistics.

List Amplitude User Properties

Tool to get all user properties in your Amplitude project.

Map Users in Amplitude

Map users with different user IDs together (alias/merge users) in Amplitude.

Restore Amplitude Event Type

Restore a deleted event type in Amplitude.

Send Events to Amplitude

Send events to Amplitude using the HTTP V2 API.

Set Group Properties in Amplitude

Set group properties for account-level reporting without sending an event.

Update Amplitude Chart Annotation

Tool to update an existing chart annotation in Amplitude.

Update Amplitude Annotation Category

Tool to update an annotation category in Amplitude.

Update Amplitude Cohort Membership

Incrementally update cohort membership by adding or removing IDs.

Update Amplitude Event Category

Update an existing event category in Amplitude.

Update Amplitude Event Type

Update an existing event type in Amplitude.

Batch Upload Events to Amplitude

Bulk upload events to Amplitude using the Batch Event Upload API.

Upload Amplitude Cohort

Generate a new cohort or update an existing cohort by uploading user IDs or Amplitude IDs.

FRAMEWORKS

How to build Amplitude MCP Agent with another framework

Claude Agent SDK logo

Claude Agent SDK

Use Amplitude MCP with Claude Agent SDK

Claude Code logo

Claude Code

Use Amplitude MCP with Claude Code

Claude Cowork logo

Claude Cowork

Use Amplitude MCP with Claude Cowork

Codex logo

Codex

Use Amplitude MCP with Codex

OpenClaw logo

OpenClaw

Use Amplitude MCP with OpenClaw

Hermes logo

Hermes

Use Amplitude MCP with Hermes

CLI logo

CLI

Use Amplitude MCP with CLI

Google ADK logo

Google ADK

Use Amplitude MCP with Google ADK

LangChain logo

LangChain

Use Amplitude MCP with LangChain

Vercel AI SDK logo

Vercel AI SDK

Use Amplitude MCP with Vercel AI SDK

Mastra AI logo

Mastra AI

Use Amplitude MCP with Mastra AI

LlamaIndex logo

LlamaIndex

Use Amplitude MCP with LlamaIndex

CrewAI logo

CrewAI

Use Amplitude MCP with CrewAI

FAQ

Frequently asked questions

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

Yes, you can. OpenAI Agents SDK 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 Amplitude tools.

Yes, absolutely. You can configure which Amplitude 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.

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 Amplitude data and credentials are handled as safely as possible.

Start with Amplitude.It takes 30 seconds.

Managed auth, hosted MCP servers, and every Amplitude tool your agent needs.Free to start.

Start building
Customer stories

Teams ship real agents on Composio

GET STARTED FOR FREEBOOK A DEMO
agent.aiZoomLettaGleanHubSpotAWSWabi

Karan skipped his own birthday party to fix our critical issue. It was 10pm and he diverted his Waymo to help us instead. This really sets the bar — it shows the commitment you need when users rely on your software.

Harsha Gaddipati
Harsha Gaddipati
Co-founder, Slashy

A lot of students tell us that the moment their connected tools start talking to each other inside Opennote feels almost magical. The agent just knows them, and it's immensely helped keep new users on the platform.

Abhi Arya
Abhi Arya
Co-founder, Opennote

We chose Composio over Pipedream because it delivered depth where it mattered — niche tools and tricky edge cases other platforms simply ignored. That gave us confidence to scale without compromising.

Nirman Dave
Nirman Dave
CEO, Zams

As a solo builder, shipping fast is life or death. The only way I can outcompete incumbents is by outmanoeuvring them. Getting bogged down managing agent auth would have been a death sentence.

Ryan Yu
Ryan Yu
Founder, Extra Thursday

Before Composio, adding tool integrations was slow and resource-intensive. Each one could take weeks of engineering time, and maintaining them meant constantly keeping up with API changes.

Tomisin Jenrola
Tomisin Jenrola
Founder & CEO, SwarmZero

With hands-on help from their founder, we integrated Gmail and Google Drive in just 30 minutes. This level of personal support and commitment is exactly what startups should strive for.

Jerome Leclanche
Jerome Leclanche
Co-Founder, Ingram Technologies