Connect the OpenAI Agents SDK to an Apify Actor

import asyncio
import os

from agents import Agent, Runner
from agents.mcp import MCPServerStreamableHttp


async def main() -> None:
    async with MCPServerStreamableHttp(
        name="Apify",
        params={
            "url": "https://mcp.apify.com/?tools=fetch-actor-details,vexaloom-labs/google-maps-business-lead-finder-with-email",
            "headers": {"Authorization": f"Bearer {os.environ['APIFY_TOKEN']}"},
            "timeout": 120,
        },
        cache_tools_list=True,
    ) as server:
        tools = await server.list_tools()
        print("tools:", [t.name for t in tools])
        agent = Agent(name="Assistant", instructions="Use the Apify tools to get live data.", mcp_servers=[server])
        result = await Runner.run(agent, "Use Google Maps Business Lead Finder with Email & Social Links to get a few records and summarise what came back, with links.")
        print(result.final_output)


asyncio.run(main())

import asyncio
import os

from agents import Agent, Runner
from agents.mcp import MCPServerStreamableHttp


async def main() -> None:
    async with MCPServerStreamableHttp(
        name="Apify",
        params={
            "url": "https://mcp.apify.com/?tools=fetch-actor-details,nimbryxo-studio/reddit-keyword-search-with-advanced-filters",
            "headers": {"Authorization": f"Bearer {os.environ['APIFY_TOKEN']}"},
            "timeout": 120,
        },
        cache_tools_list=True,
    ) as server:
        tools = await server.list_tools()
        print("tools:", [t.name for t in tools])
        agent = Agent(name="Assistant", instructions="Use the Apify tools to get live data.", mcp_servers=[server])
        result = await Runner.run(agent, "Use Reddit Keyword Search with Advanced Filters to get a few records and summarise what came back, with links.")
        print(result.final_output)


asyncio.run(main())

import asyncio
import os

from agents import Agent, Runner
from agents.mcp import MCPServerStreamableHttp


async def main() -> None:
    async with MCPServerStreamableHttp(
        name="Apify",
        params={
            "url": "https://mcp.apify.com/?tools=fetch-actor-details,nimbryxo-studio/zillow-for-sale-rent-and-sold-listing-extractor",
            "headers": {"Authorization": f"Bearer {os.environ['APIFY_TOKEN']}"},
            "timeout": 120,
        },
        cache_tools_list=True,
    ) as server:
        tools = await server.list_tools()
        print("tools:", [t.name for t in tools])
        agent = Agent(name="Assistant", instructions="Use the Apify tools to get live data.", mcp_servers=[server])
        result = await Runner.run(agent, "Use Zillow For-Sale, Rent & Sold Listing Extractor to get a few records and summarise what came back, with links.")
        print(result.final_output)


asyncio.run(main())