LangGraph

1
from langchain_openai import ChatOpenAI
2
from langchain_youdotcom import YouSearchTool, YouContentsTool
3
from langchain.agents import create_agent
4
5
llm = ChatOpenAI(model="gpt-4o-mini")
6
tools = [YouSearchTool(), YouContentsTool()]
7
8
agent = create_agent(llm, tools)
9
10
response = agent.invoke(
11
    {"messages": [{"role": "user", "content": "What are the top AI stories this week?"}]}
12
)
13
print(response["messages"][-1].content)

1
from langchain_youdotcom import YouSearchAPIWrapper, YouSearchTool
2
3
tool = YouSearchTool(
4
    api_wrapper=YouSearchAPIWrapper(
5
        count=5,
6
        livecrawl="web",
7
        freshness="day",
8
        safesearch="moderate",
9
    )
10
)

1
import asyncio
2
from langchain_openai import ChatOpenAI
3
from langchain_youdotcom import YouSearchTool
4
from langchain.agents import create_agent
5
6
llm = ChatOpenAI(model="gpt-4o-mini")
7
agent = create_agent(llm, [YouSearchTool()])
8
9
10
async def main():
11
    async for event in agent.astream_events(
12
        {"messages": [{"role": "user", "content": "What is the current price of Bitcoin?"}]},
13
        version="v2",
14
    ):
15
        if event["event"] == "on_chat_model_stream":
16
            token = event["data"]["chunk"].content
17
            if token:
18
                print(token, end="", flush=True)
19
    print()
20
21
22
asyncio.run(main())

1
from langchain_openai import ChatOpenAI
2
from langchain_youdotcom import YouSearchTool
3
from langgraph.graph import START, END, StateGraph, MessagesState
4
5
llm = ChatOpenAI(model="gpt-4o-mini")
6
search = YouSearchTool()
7
8
9
def search_web(state: MessagesState):
10
    """Search the web for the user's query."""
11
    user_message = state["messages"][-1].content
12
    results = search.invoke(user_message)
13
    return {
14
        "messages": [
15
            {
16
                "role": "system",
17
                "content": f"Search results:\n\n{results}",
18
            }
19
        ]
20
    }
21
22
23
def summarize(state: MessagesState):
24
    """Summarize the search results into a final answer."""
25
    response = llm.invoke(state["messages"])
26
    return {"messages": [response]}
27
28
29
graph = StateGraph(MessagesState)
30
graph.add_node("search", search_web)
31
graph.add_node("summarize", summarize)
32
33
graph.add_edge(START, "search")
34
graph.add_edge("search", "summarize")
35
graph.add_edge("summarize", END)
36
37
app = graph.compile()
38
39
response = app.invoke(
40
    {"messages": [{"role": "user", "content": "What happened in tech this week?"}]}
41
)
42
print(response["messages"][-1].content)

1
from langchain_openai import ChatOpenAI
2
from langchain_youdotcom import YouSearchAPIWrapper
3
from langgraph.graph import START, END, StateGraph, MessagesState
4
5
llm = ChatOpenAI(model="gpt-4o-mini")
6
wrapper = YouSearchAPIWrapper(count=5)
7
8
9
class SearchState(MessagesState):
10
    urls: list[str]
11
12
13
def search_web(state: SearchState):
14
    """Search the web and extract URLs from the results."""
15
    query = state["messages"][-1].content
16
    docs = wrapper.results(query)
17
    urls = [doc.metadata["url"] for doc in docs if "url" in doc.metadata]
18
    results_text = "\n\n".join(
19
        f"{doc.metadata.get('title', 'Untitled')}: {doc.page_content[:200]}"
20
        for doc in docs
21
    )
22
    return {
23
        "messages": [
24
            {"role": "system", "content": f"Search results:\n\n{results_text}"}
25
        ],
26
        "urls": urls,
27
    }
28
29
30
def extract_content(state: SearchState):
31
    """Extract full content from the URLs found in search."""
32
    urls = state.get("urls", [])[:3]
33
    if not urls:
34
        return {"messages": []}
35
    docs = wrapper.contents(urls)
36
    content = "\n\n".join(doc.page_content for doc in docs)
37
    return {
38
        "messages": [
39
            {"role": "system", "content": f"Extracted content:\n\n{content}"}
40
        ]
41
    }
42
43
44
def synthesize(state: SearchState):
45
    """Generate a final answer from all gathered context."""
46
    response = llm.invoke(state["messages"])
47
    return {"messages": [response]}
48
49
50
graph = StateGraph(SearchState)
51
graph.add_node("search", search_web)
52
graph.add_node("extract", extract_content)
53
graph.add_node("synthesize", synthesize)
54
55
graph.add_edge(START, "search")
56
graph.add_edge("search", "extract")
57
graph.add_edge("extract", "synthesize")
58
graph.add_edge("synthesize", END)
59
60
app = graph.compile()
61
62
response = app.invoke(
63
    {"messages": [{"role": "user", "content": "Explain the latest advances in quantum computing"}]}
64
)
65
print(response["messages"][-1].content)

1
from langchain_youdotcom import YouSearchAPIWrapper
2
3
wrapper = YouSearchAPIWrapper()
4
docs = wrapper.contents(
5
    ["https://example.com"],
6
    formats=["markdown", "metadata"],  # default
7
    crawl_timeout=30,                  # seconds (1–60)
8
)