Last9 MCP for AI Agents

https://app.last9.io/api/v4/organizations/<org_slug>/mcp

import anthropic

client = anthropic.Anthropic()

response = client.beta.messages.create(
    model="claude-opus-4-7-20250514",
    max_tokens=4096,
    system="You are an SRE assistant. Investigate issues using Last9 observability data.",
    messages=[
        {
            "role": "user",
            "content": "Why is the payment-service error rate elevated right now?",
        }
    ],
    mcp_servers=[
        {
            "type": "url",
            "url": "https://app.last9.io/api/v4/organizations/<org_slug>/mcp",
            "name": "last9",
            "authorization_token": "<mcp_token>",
        }
    ],
    betas=["mcp-client-2025-04-04"],
)

print(response.content[-1].text)

import asyncio
from langchain_mcp_adapters.client import MultiServerMCPClient
from langgraph.prebuilt import create_react_agent

ORG_SLUG = "<org_slug>"
MCP_TOKEN = "<mcp_token>"

async def run_sre_agent(question: str) -> str:
    async with MultiServerMCPClient(
        {
            "last9": {
                "url": f"https://app.last9.io/api/v4/organizations/{ORG_SLUG}/mcp",
                "transport": "streamable_http",
                "headers": {"Authorization": f"Bearer {MCP_TOKEN}"},
            }
        }
    ) as mcp_client:
        tools = await mcp_client.get_tools()
        agent = create_react_agent("anthropic:claude-opus-4-7", tools)
        result = await agent.ainvoke(
            {"messages": [{"role": "user", "content": question}]}
        )
        return result["messages"][-1].content

if __name__ == "__main__":
    answer = asyncio.run(
        run_sre_agent("Which services had elevated error rates in the last hour?")
    )
    print(answer)

pip install langchain-mcp-adapters langgraph langchain-anthropic

import os
import anthropic

client = anthropic.Anthropic()

LAST9_MCP_SERVER = {
    "type": "url",
    "url": f"https://app.last9.io/api/v4/organizations/{os.environ['LAST9_ORG_SLUG']}/mcp",
    "name": "last9",
    "authorization_token": os.environ["LAST9_MCP_TOKEN"],
}

def investigate_alert(alert_text: str) -> str:
    """Call from your alerting webhook handler."""
    response = client.beta.messages.create(
        model="claude-opus-4-7-20250514",
        max_tokens=2048,
        system=(
            "You are an on-call SRE assistant. Investigate the alert using Last9 tools. "
            "Return a concise summary: what is failing, probable cause, and suggested next action. "
            "Be direct and specific — avoid hedging."
        ),
        messages=[{"role": "user", "content": f"Alert fired: {alert_text}"}],
        mcp_servers=[LAST9_MCP_SERVER],
        betas=["mcp-client-2025-04-04"],
    )
    return response.content[-1].text


# Example: wire into a Slack Events API handler
# investigation = investigate_alert("payment-service error rate > 5% for 5 minutes")
# slack_client.chat_postMessage(channel="#incidents", text=investigation)