环境设置
- Python
- Javascript
- cURL
from langgraph_sdk import get_client
client = get_client(url=<DEPLOYMENT_URL>)
# 创建一个使用 OpenAI 模型的助手
openai_assistant = await client.assistants.create(
graph_id="agent", config={"configurable": {"model_name": "openai"}}
)
# 总是应该有一个没有配置的默认助手
assistants = await client.assistants.search()
default_assistant = [a for a in assistants if not a["config"]][0]
import { Client } from "@langchain/langgraph-sdk";
const client = new Client({ apiUrl: <DEPLOYMENT_URL> });
// 创建一个使用 OpenAI 模型的助手
const openAIAssistant = await client.assistants.create(
{ graphId: "agent", config: {"configurable": {"model_name": "openai"}}}
);
// 查找默认助手
const assistants = await client.assistants.search();
const defaultAssistant = assistants.find(a => !a.config);
# 创建使用 OpenAI 模型的助手
curl --request POST \
--url <DEPLOYMENT_URL>/assistants \
--header 'Content-Type: application/json' \
--data '{
"graph_id": "agent",
"config": { "configurable": { "model_name": "openai" } }
}' && \
# 搜索助手并筛选出默认助手（config 为空或 {} 的助手）
curl --request POST \
--url <DEPLOYMENT_URL>/assistants/search \
--header 'Content-Type: application/json' \
--data '{
"limit": 10,
"offset": 0
}' | jq -c 'map(select(.config == null or .config == {})) | .[0]'
- Python
- Javascript
- cURL
print(openai_assistant)
console.log(openAIAssistant);
curl --request GET \
--url <DEPLOYMENT_URL>/assistants/<OPENAI_ASSISTANT_ID>
{
"assistant_id": "db87f39d-b2b1-4da8-ac65-cf81beb3c766",
"graph_id": "agent",
"created_at": "2024-08-30T21:18:51.850581+00:00",
"updated_at": "2024-08-30T21:18:51.850581+00:00",
"config": {
"configurable": {
"model_name": "openai"
}
},
"metadata": {}
}
- Python
- Javascript
- cURL
print(default_assistant)
console.log(defaultAssistant);
curl --request GET \
--url <DEPLOYMENT_URL>/assistants/<DEFAULT_ASSISTANT_ID>
{
"assistant_id": "fe096781-5601-53d2-b2f6-0d3403f7e9ca",
"graph_id": "agent",
"created_at": "2024-08-08T22:45:24.562906+00:00",
"updated_at": "2024-08-08T22:45:24.562906+00:00",
"config": {},
"metadata": {
"created_by": "system"
}
}
在线程上运行助手
运行 OpenAI 助手
我们现在可以首先在线程上运行 OpenAI 助手。- Python
- Javascript
- cURL
thread = await client.threads.create()
input = {"messages": [{"role": "user", "content": "谁创造了你？"}]}
async for event in client.runs.stream(
thread["thread_id"],
openai_assistant["assistant_id"],
input=input,
stream_mode="updates",
):
print(f"接收到事件类型: {event.event}")
print(event.data)
print("\n\n")
const thread = await client.threads.create();
let input = {"messages": [{"role": "user", "content": "谁创造了你？"}]}
const streamResponse = client.runs.stream(
thread["thread_id"],
openAIAssistant["assistant_id"],
{
input,
streamMode: "updates"
}
);
for await (const event of streamResponse) {
console.log(`接收到事件类型: ${event.event}`);
console.log(event.data);
console.log("\n\n");
}
# 创建一个线程并提取 thread_id
thread_id=$(curl --request POST \
--url <DEPLOYMENT_URL>/threads \
--header 'Content-Type: application/json' \
--data '{}' | jq -r '.thread_id') && \
# 在该线程上运行 OpenAI 助手
curl --request POST \
--url "<DEPLOYMENT_URL>/threads/${thread_id}/runs/stream" \
--header 'Content-Type: application/json' \
--data '{
"assistant_id": <OPENAI_ASSISTANT_ID>,
"input": {
"messages": [
{
"role": "user",
"content": "谁创造了你？"
}
]
},
"stream_mode": [
"updates"
]
}' | \
sed 's/\r$//' | \
awk '
/^event:/ {
if (data_content != "") {
print data_content "\n"
}
sub(/^event: /, "接收到事件类型: ", $0)
printf "%s...\n", $0
data_content = ""
}
/^data:/ {
sub(/^data: /, "", $0)
data_content = $0
}
END {
if (data_content != "") {
print data_content "\n\n"
}
}
'
接收到事件类型: metadata
{'run_id': '1ef671c5-fb83-6e70-b698-44dba2d9213e'}
接收到事件类型: updates
{'agent': {'messages': [{'content': '我由 OpenAI 创建，这是一个专注于开发和推进人工智能技术的研究组织。', 'additional_kwargs': {}, 'response_metadata': {'finish_reason': 'stop', 'model_name': 'gpt-4o-2024-05-13', 'system_fingerprint': 'fp_157b3831f5'}, 'type': 'ai', 'name': None, 'id': 'run-f5735b86-b80d-4c71-8dc3-4782b5a9c7c8', 'example': False, 'tool_calls': [], 'invalid_tool_calls': [], 'usage_metadata': None}]}}
运行默认助手
现在，我们可以在默认助手运行它，并看到这第二个助手知道初始的问题，并能回答“那么你呢？”：- Python
- Javascript
- cURL
input = {"messages": [{"role": "user", "content": "那么你呢？"}]}
async for event in client.runs.stream(
thread["thread_id"],
default_assistant["assistant_id"],
input=input,
stream_mode="updates",
):
print(f"接收到事件类型: {event.event}")
print(event.data)
print("\n\n")
let input = {"messages": [{"role": "user", "content": "那么你呢？"}]}
const streamResponse = client.runs.stream(
thread["thread_id"],
defaultAssistant["assistant_id"],
{
input,
streamMode: "updates"
}
);
for await (const event of streamResponse) {
console.log(`接收到事件类型: ${event.event}`);
console.log(event.data);
console.log("\n\n");
}
# 在同一线程上运行默认助手
curl --request POST \
--url <DEPLOYMENT_URL>/threads/<THREAD_ID>/runs/stream \
--header 'Content-Type: application/json' \
--data '{
"assistant_id": <DEFAULT_ASSISTANT_ID>,
"input": {
"messages": [
{
"role": "user",
"content": "那么你呢？"
}
]
},
"stream_mode": [
"updates"
]
}' | \
sed 's/\r$//' | \
awk '
/^event:/ {
if (data_content != "") {
print data_content "\n"
}
sub(/^event: /, "接收到事件类型: ", $0)
printf "%s...\n", $0
data_content = ""
}
/^data:/ {
sub(/^data: /, "", $0)
data_content = $0
}
END {
if (data_content != "") {
print data_content "\n\n"
}
}
'
接收到事件类型: metadata
{'run_id': '1ef6722d-80b3-6fbb-9324-253796b1cd13'}
接收到事件类型: updates
{'agent': {'messages': [{'content': [{'text': '我是由 Anthropic 创建的人工智能，而不是由 OpenAI 创建的。我不应该说 OpenAI 创造了我，因为那是不正确的。Anthropic 是开发并使用先进语言模型和人工智能技术训练我的公司。今后我会更加小心，提供关于我起源的准确信息。', 'type': 'text', 'index': 0}], 'additional_kwargs': {}, 'response_metadata': {'stop_reason': 'end_turn', 'stop_sequence': None}, 'type': 'ai', 'name': None, 'id': 'run-ebaacf62-9dd9-4165-9535-db432e4793ec', 'example': False, 'tool_calls': [], 'invalid_tool_calls': [], 'usage_metadata': {'input_tokens': 302, 'output_tokens': 72, 'total_tokens': 374}}]}}
Connect these docs to Claude, VSCode, and more via MCP for real-time answers.