Zapier MCP embed: SDK connection guide for TypeScript and Python

npm install @modelcontextprotocol/sdk

// or

pnpm add @modelcontextprotocol/sdk

pip install mcp

# or

uv pip install mcp

import { Client } from "@modelcontextprotocol/sdk/client/index.js";
import { StreamableHTTPClientTransport } from "@modelcontextprotocol/sdk/client/streamableHttp.js";

/**
 * Connect to the Zapier MCP server
 *
 * @param serverUrl URL for the MCP server for a specific user
 * @param secret Your Zapier MCP embed secret
 * @returns MCP client
 */
async function connectToZapierMcp(serverUrl: string, secret: string) {
  const transport = new StreamableHTTPClientTransport(new URL(serverUrl), {
    requestInit: {
      headers: {
        Authorization: `Bearer ${secret}`,
      },
    },
  });

  const client = new Client({
    name: "zapier-mcp",
    version: "1.0.0",
  });

  await client.connect(transport);

  return client;
}

async function main() {
  const client = await connectToZapierMcp(serverUrl, secret);

  const tools = await client.listTools();
  console.log("Available tools:", tools);

  await client.transport?.close();
  await client.close();
}

import asyncio

from mcp import ClientSession
from mcp.client.streamable_http import streamablehttp_client

def connect_to_zapier_mcp(server_url: str, secret: str):
    """
    Connect to the Zapier MCP server

    Args:
        server_url: URL for the MCP server for a specific user
        secret: Your Zapier MCP embed secret
    """
    return streamablehttp_client(
        server_url,
        headers={
            "Authorization": f"Bearer {secret}",
        },
    )


async def main():
    async with connect_to_zapier_mcp(server_url, secret) as (
        read_stream,
        write_stream,
        _,
    ):
        async with ClientSession(read_stream, write_stream) as session:
            await session.initialize()

            tools = await session.list_tools()
            print("Available tools:", tools)