ConnectClaudeto Klaviyo, Pipedrive MCP Servers

import os
import json
from anthropic import Anthropic
from klavis import Klavis
from klavis.types import McpServerName, ConnectionType, ToolFormat

# Initialize clients
anthropic_client = Anthropic(api_key=os.getenv("ANTHROPIC_API_KEY"))
klavis_client = Klavis(api_key=os.getenv("KLAVIS_API_KEY"))

# Constants
CLAUDE_MODEL = "claude-3-5-sonnet-20241022"
user_message = "Your message here"

klaviyo_mcp_instance = klavis_client.mcp_server.create_server_instance(
    server_name=McpServerName.KLAVIYO,
    user_id="1234",
    connection_type=ConnectionType.STREAMABLE_HTTP,
)

pipedrive_mcp_instance = klavis_client.mcp_server.create_server_instance(
    server_name=McpServerName.PIPEDRIVE,
    user_id="1234",
    connection_type=ConnectionType.STREAMABLE_HTTP,
)

# Get tools from all MCP servers
klaviyo_tools = klavis_client.mcp_server.list_tools(
    server_url=klaviyo_mcp_instance.server_url,
    connection_type=ConnectionType.STREAMABLE_HTTP,
    format=ToolFormat.ANTHROPIC,
)
pipedrive_tools = klavis_client.mcp_server.list_tools(
    server_url=pipedrive_mcp_instance.server_url,
    connection_type=ConnectionType.STREAMABLE_HTTP,
    format=ToolFormat.ANTHROPIC,
)

# Combine all tools
all_tools = []
all_tools.extend(klaviyo_tools.tools)
all_tools.extend(pipedrive_tools.tools)

messages = [
    {"role": "user", "content": user_message}
]
        
response = anthropic_client.messages.create(
    model=CLAUDE_MODEL,
    max_tokens=4000,
    messages=messages,
    tools=all_tools
)