Connect AI agents to the Customer.io MCP server

Vendor MCP

The Customer.io MCP connector routes your AI agent's tool calls to Customer.io's own MCP server through Scalekit. Each user signs in to Customer.io once, and Scalekit stores and refreshes their tokens, so your agent never handles credentials. It comes with 8 tools.

Tools: 8
What they doRead · write · destructive: 6 · 0 · 26 read0 write2 destructive
Users sign in with: OAuth
OAuth app: Scalekit's or your own

Setup

npm install @scalekit-sdk/node dotenv

pip install scalekit-sdk-python python-dotenv

Set your credentials
Add your Scalekit credentials to your .env file. Find values in app.scalekit.com > Developers > API Credentials.
.env
```
SCALEKIT_ENVIRONMENT_URL=<your-environment-url>
SCALEKIT_CLIENT_ID=<your-client-id>
SCALEKIT_CLIENT_SECRET=<your-client-secret>
```
Create the Customer.io MCP connection
In AgentKit > Connections, create a Customer.io MCP connection. The name you give it is the connection_name your code passes. See Configure connections.
Scalekit credentials are available for Customer.io MCP server, so you don't need to register an OAuth app. To show your own app on the consent screen, use your own credentials instead.
Use your own OAuth app
Customer.io MCP uses Dynamic Client Registration (DCR) — no client ID or secret is required. The only step is creating a connection in Scalekit and authorizing your Customer.io account.
1. Create a connection in Scalekit
  - In the Scalekit dashboard, go to AgentKit → Connections → Create Connection.
  - Search for Customer.io MCP and click Create.
  - Note the Connection name — use this as connection_name in your code (e.g., customeriomcp).
2. Authorize your Customer.io account
  
  Generate an authorization link and open it in a browser to complete the Customer.io OAuth flow.
  
  The user is redirected to Customer.io to sign in and grant access. Scalekit stores the token and injects it automatically into every tool call — no further configuration is needed.
  
  After connecting, call customeriomcp_cio_prime as your first tool call. It loads LLM-ready instructions about the Customer.io API structure, available resources, and recommended workflows.

Authorize a user and make your first call

Node.js
Python

1
import { ScalekitClient } from '@scalekit-sdk/node'
2
import 'dotenv/config'
3
import { createInterface } from 'node:readline/promises'
4

5
const scalekit = new ScalekitClient(
6
  process.env.SCALEKIT_ENVIRONMENT_URL,
7
  process.env.SCALEKIT_CLIENT_ID,
8
  process.env.SCALEKIT_CLIENT_SECRET,
9
)
10
const actions = scalekit.actions
11

12
const connector = 'customeriomcp'
13
const identifier = 'user_123'
14

15
// Generate an authorization link for the user
16
const { link } = await actions.getAuthorizationLink({ connectionName: connector, identifier })
17
console.log('Authorize Customer.io MCP:', link)
18
const rl = createInterface({ input: process.stdin, output: process.stdout })
19
await rl.question('Press Enter after authorizing...')
20
rl.close()
21

22
// Make your first call
23
const result = await actions.executeTool({
24
  connector,
25
  identifier,
26
  toolName: 'customeriomcp_cio_auth_status',
27
  toolInput: {},
28
})
29
console.log(result)

npx tsx quickstart.mts

1
import os
2
from scalekit import ScalekitClient
3
from dotenv import load_dotenv
4
load_dotenv()
5

6
scalekit_client = ScalekitClient(
7
    env_url=os.getenv("SCALEKIT_ENVIRONMENT_URL"),
8
    client_id=os.getenv("SCALEKIT_CLIENT_ID"),
9
    client_secret=os.getenv("SCALEKIT_CLIENT_SECRET"),
10
)
11
actions = scalekit_client.actions
12

13
connection_name = "customeriomcp"
14
identifier = "user_123"
15

16
# Generate an authorization link for the user
17
link_response = actions.get_authorization_link(
18
    connection_name=connection_name,
19
    identifier=identifier,
20
)
21
print("Authorize Customer.io MCP:", link_response.link)
22
input("Press Enter after authorizing...")
23

24
# Make your first call
25
result = actions.execute_tool(
26
    tool_input={},
27
    tool_name="customeriomcp_cio_auth_status",
28
    connection_name=connection_name,
29
    identifier=identifier,
30
)
31
print(result)

python quickstart.py

Each user signs in once. See Authorize a user for the full flow and statuses.

Tools

Pass the exact name to execute_tool

Try in Playground Request a tool

customeriomcp_cio_auth_statusShow the active authentication state — authenticated user, account, and accessible workspaces.Read-only
Cio Auth Status
Show the active authentication state — authenticated user, account, and accessible workspaces. Call this to verify which Customer.io account is connected.
Inputs
This tool takes no inputs.
customeriomcp_cio_primePrint LLM-ready instructions for using the Customer.io API.Read-only
Cio Prime
Print LLM-ready instructions for using the Customer.io API. Call this first in a new task to load context about available endpoints and best practices.
Inputs
This tool takes no inputs.
customeriomcp_cio_read_apiRead from the Customer.io API (GET only).Read-only
Cio Read Api
Read from the Customer.io API (GET only). Use cio_schema first to find the correct path. Supports pagination, jq filtering, and dry_run preview.
Inputs
pathstringrequired
API path including placeholders, e.g. '/v1/environments/{environment_id}/campaigns'. Placeholders are substituted from params.
dry_runboolean
Validate and return the request without executing it.
jqstring
gojq expression to filter the response before returning. Use to trim large responses.
limitnumber
Page size.
pagenumber
Page number (1-indexed).
page_allboolean
Auto-paginate and return NDJSON for the full dataset.
paramsobject
Parameters object. Keys matching path placeholders are substituted; remaining keys become the query string.
customeriomcp_cio_schemaIntrospect the Customer.io API schema to discover endpoints, parameters, and response shapes.Read-only
Cio Schema
Introspect the Customer.io API schema to discover endpoints, parameters, and response shapes. Use this before calling cio_read_api or cio_write_api to find the correct path and placeholders.
Inputs
querystring
One of: '' (list resources), 'campaigns' (resource), 'campaigns.list' (resource.method), 'GET /v1/...' (method + path), or '/v1/...' (all methods for a path).
refreshboolean
Force re-download of API specs.
customeriomcp_cio_skills_listList available Customer.io agent skills — task-specific instruction manuals covering campaigns, segments, deliveries, analytics, and more.Read-only
Cio Skills List
List available Customer.io agent skills — task-specific instruction manuals covering campaigns, segments, deliveries, analytics, and more.
Inputs
refreshboolean
Force re-download of skills.
customeriomcp_cio_skills_readRead the full content of a specific Customer.io agent skill by path.Read-only
Cio Skills Read
Read the full content of a specific Customer.io agent skill by path. Use cio_skills_list to find available paths (e.g. 'campaigns', 'fly-api/campaigns.md').
Inputs
pathstringrequired
Skill path, e.g. 'campaigns' or 'campaigns/examples'. See cio_skills_list for available paths.
customeriomcp_cio_delete_apiDelete a resource via the Customer.io API (DELETE only).Destructive
Cio Delete Api
Delete a resource via the Customer.io API (DELETE only). Always run with dry_run=true first to preview before executing.
Inputs
pathstringrequired
API path including placeholders, e.g. '/v1/environments/{environment_id}/campaigns/{campaign_id}'. Placeholders are substituted from params.
dry_runboolean
Validate and return the request without executing it.
jqstring
gojq expression to filter the response before returning.
paramsobject
Parameters object. Keys matching path placeholders are substituted; remaining keys become the query string.
customeriomcp_cio_write_apiWrite to the Customer.io API (POST, PUT, or PATCH).Destructive
Cio Write Api
Write to the Customer.io API (POST, PUT, or PATCH). Always run with dry_run=true first to preview the request before executing.
Inputs
pathstringrequired
API path including placeholders, e.g. '/v1/environments/{environment_id}/campaigns'. Placeholders are substituted from params.
bodyobject
JSON request body.
dry_runboolean
Validate and return the request without executing it.
jqstring
gojq expression to filter the response before returning.
methodstring
HTTP method: POST, PUT, or PATCH. Defaults to POST.
paramsobject
Parameters object. Keys matching path placeholders are substituted; remaining keys become the query string.

Workflows

Check authentication status

Use customeriomcp_cio_auth_status to verify the connection and see the authenticated user, account, and accessible workspaces.

Node.js
Python

const status = await actions.executeTool({
  connector: 'customeriomcp',
  identifier: 'user_123',
  toolName: 'customeriomcp_cio_auth_status',
  toolInput: {},
});
console.log(status);

status = actions.execute_tool(
    connection_name="customeriomcp",
    identifier="user_123",
    tool_name="customeriomcp_cio_auth_status",
    tool_input={},
)
print(status)

Read campaign data

Use customeriomcp_cio_read_api to fetch campaigns from a Customer.io environment. Call customeriomcp_cio_schema first to discover the correct API path and available parameters.

Node.js
Python

const campaigns = await actions.executeTool({
  connector: 'customeriomcp',
  identifier: 'user_123',
  toolName: 'customeriomcp_cio_read_api',
  toolInput: {
    path: '/v1/environments/{environment_id}/campaigns',
    params: { environment_id: 'env_abc123' },
    limit: 10,
  },
});
console.log(campaigns);

campaigns = actions.execute_tool(
    connection_name="customeriomcp",
    identifier="user_123",
    tool_name="customeriomcp_cio_read_api",
    tool_input={
        "path": "/v1/environments/{environment_id}/campaigns",
        "params": {"environment_id": "env_abc123"},
        "limit": 10,
    },
)
print(campaigns)

Create a campaign

Use customeriomcp_cio_write_api to create a new campaign. Always set dry_run: true first to validate the request before executing.

Node.js
Python

1
// Step 1 — dry run to validate
2
const preview = await actions.executeTool({
3
  connector: 'customeriomcp',
4
  identifier: 'user_123',
5
  toolName: 'customeriomcp_cio_write_api',
6
  toolInput: {
7
    path: '/v1/environments/{environment_id}/campaigns',
8
    params: { environment_id: 'env_abc123' },
9
    body: { name: 'Welcome Series', type: 'triggered' },
10
    dry_run: true,
11
  },
12
});
13
console.log(preview);
14

15
// Step 2 — execute after confirming dry run looks correct
16
const result = await actions.executeTool({
17
  connector: 'customeriomcp',
18
  identifier: 'user_123',
19
  toolName: 'customeriomcp_cio_write_api',
20
  toolInput: {
21
    path: '/v1/environments/{environment_id}/campaigns',
22
    params: { environment_id: 'env_abc123' },
23
    body: { name: 'Welcome Series', type: 'triggered' },
24
  },
25
});
26
console.log(result);

1
# Step 1 — dry run to validate
2
preview = actions.execute_tool(
3
    connection_name="customeriomcp",
4
    identifier="user_123",
5
    tool_name="customeriomcp_cio_write_api",
6
    tool_input={
7
        "path": "/v1/environments/{environment_id}/campaigns",
8
        "params": {"environment_id": "env_abc123"},
9
        "body": {"name": "Welcome Series", "type": "triggered"},
10
        "dry_run": True,
11
    },
12
)
13
print(preview)
14

15
# Step 2 — execute after confirming dry run looks correct
16
result = actions.execute_tool(
17
    connection_name="customeriomcp",
18
    identifier="user_123",
19
    tool_name="customeriomcp_cio_write_api",
20
    tool_input={
21
        "path": "/v1/environments/{environment_id}/campaigns",
22
        "params": {"environment_id": "env_abc123"},
23
        "body": {"name": "Welcome Series", "type": "triggered"},
24
    },
25
)
26
print(result)

Connect AI agents to the Customer.io MCP server

Setup

Install the SDK

Set your credentials

Create the Customer.io MCP connection

Create a connection in Scalekit

Authorize your Customer.io account

Authorize a user and make your first call

Tools

Call it

Returns

Cio Auth Status

Inputs

Cio Prime

Inputs

Cio Read Api

Inputs

Cio Schema

Inputs

Cio Skills List

Inputs

Cio Skills Read

Inputs

Cio Delete Api

Inputs

Cio Write Api

Inputs

Workflows

Check authentication status

Read campaign data

Create a campaign

Setup

Install the SDK

Set your credentials

Create the Customer.io MCP connection

Create a connection in Scalekit

Authorize your Customer.io account

Authorize a user and make your first call

Tools

Call it

Returns

Cio Auth Status

Inputs

Cio Prime

Inputs

Cio Read Api

Inputs

Cio Schema

Inputs

Cio Skills List

Inputs

Cio Skills Read

Inputs

Cio Delete Api

Inputs

Cio Write Api

Inputs

Workflows

Check authentication status

Read campaign data

Create a campaign

Related: other Marketing connectors