Python + LangChain + OpenAI with Meta Ads MCP

Create pipeboard_analysis.py:

import asyncio, os, sys
from langchain_mcp_adapters.client import MultiServerMCPClient
from langgraph.prebuilt import create_react_agent

def env(k):
    v=os.getenv(k)
    if not v:
        print(f"{k} is required")
        sys.exit(1)
    return v

def to_text(r):
    try:
        if isinstance(r,dict) and "messages" in r:
            m=r["messages"]
            if isinstance(m,list) and m:
                last=m[-1]
                if isinstance(last,dict): return str(last.get("content", last))
                c=getattr(last,"content",None); return str(c if c is not None else last)
        return str(r)
    except Exception:
        return str(r)

async def run():
    t=env("PIPEBOARD_API_TOKEN")
    model=os.getenv("OPENAI_MODEL","openai:gpt-4.1")
    url=os.getenv("MCP_META_ADS_URL","https://mcp.pipeboard.co/meta-ads-mcp")
    # Note: You can also use query parameter auth by adding f"?token={t}" to the URL
    # but header auth (shown below) is more secure and recommended
    client=MultiServerMCPClient({"meta-ads":{"transport":"streamable_http","url":url,"headers":{"Authorization":f"Bearer {t}","X-Pipeboard-Token":t}}})
    tools=await client.get_tools()
    agent=create_react_agent(model,tools)
    prompt = """You are a Meta Ads optimization assistant.
1) Find the most active ad account in the last 7 days.
2) In that account, find the top-spend campaign last 7 days.
3) Analyze performance and give 3–5 recommendations. Include names, IDs, spend, impressions, clicks, conversions, CTR, CPC, CPA/ROAS if available."""
    resp=await agent.ainvoke({"messages":prompt})
    print(to_text(resp))

if __name__=="__main__":
    try: asyncio.run(run())
    except KeyboardInterrupt: pass

Run it:

python pipeboard_analysis.py