Zapier MCP for Python: setup with a connection token

export ZAPIER_MCP_TOKEN="YOUR_ZAPIER_MCP_API_KEY"

pip install fastmcp

uv pip install fastmcp

import asyncio
import json
import os

from fastmcp import Client
from fastmcp.client.transports import StreamableHttpTransport

# Create the transport with your MCP server URL and API key
# The API key is read from the ZAPIER_MCP_TOKEN environment variable
server_url = "https://mcp.zapier.com/api/v1/connect"
api_key = os.environ["ZAPIER_MCP_TOKEN"]
transport = StreamableHttpTransport(
    server_url,
    headers={"Authorization": f"Bearer {api_key}"}
)

# Initialize the client with the transport
client = Client(transport=transport)


async def main():
    # Connection is established here
    print("Connecting to MCP server...")
    async with client:
        print(f"Client connected: {client.is_connected()}")

        # Make MCP calls within the context
        print("Fetching available tools...")
        tools = await client.list_tools()

        print(f"Available tools: {json.dumps([t.name for t in tools], indent=2)}")

    # Connection is closed automatically when exiting the context manager
    print("Example completed")


if __name__ == "__main__":
    asyncio.run(main())