Flow
Get started with the Flow API
Chat Flow
POST /api/v2/chat/completions
Examplesâ
Stream Chat Flowâ
- Curl
- Python
- Python(OpenAI SDK)
DBGPT_API_KEY=dbgpt
FLOW_ID={YOUR_FLOW_ID}
curl -X POST "http://localhost:5670/api/v2/chat/completions" \
-H "Authorization: Bearer $DBGPT_API_KEY" \
-H "accept: application/json" \
-H "Content-Type: application/json" \
-d "{\"messages\":\"Hello\",\"model\":\"gpt-4o\", \"chat_mode\": \"chat_flow\", \"chat_param\": \"$FLOW_ID\"}"
from dbgpt_client import Client
DBGPT_API_KEY = "dbgpt"
FLOW_ID="{YOUR_FLOW_ID}"
client = Client(api_key=DBGPT_API_KEY)
async for data in client.chat_stream(
messages="Introduce AWEL",
model="gpt-4o",
chat_mode="chat_flow",
chat_param=FLOW_ID
):
print(data)
from openai import OpenAI
DBGPT_API_KEY = "dbgpt"
FLOW_ID="{YOUR_FLOW_ID}"
client = OpenAI(
api_key=DBGPT_API_KEY,
base_url="http://localhost:5670/api/v2"
)
response = client.chat.completions.create(
model="gpt-4o",
messages=[
{
"role": "user",
"content": "Hello",
},
],
extra_body={
"chat_mode": "chat_flow",
"chat_param": FLOW_ID,
},
stream=True,
max_tokens=2048,
)
for chunk in response:
delta_content = chunk.choices[0].delta.content
print(delta_content, end="", flush=True)
Chat Completion Stream Responseâ
data: {"id": "579f8862-fc4b-481e-af02-a127e6d036c8", "created": 1710918094, "model": "gpt-4o", "choices": [{"index": 0, "delta": {"role": "assistant", "content": "\n\n"}}]}
Create Flowâ
POST /api/v2/serve/awel/flows
Request bodyâ
Request Flow Object
Response bodyâ
Return Flow Object
Update Flowâ
PUT /api/v2/serve/awel/flows
Request bodyâ
Request Flow Object
Response bodyâ
Return Flow Object
Delete Flowâ
DELETE /api/v2/serve/awel/flows
- Curl
- Python
DBGPT_API_KEY=dbgpt
FLOW_ID={YOUR_FLOW_ID}
curl -X DELETE "http://localhost:5670/api/v2/serve/awel/flows/$FLOW_ID" \
-H "Authorization: Bearer $DBGPT_API_KEY" \
from dbgpt_client import Client
from dbgpt_client.flow import delete_flow
DBGPT_API_KEY = "dbgpt"
flow_id = "{your_flow_id}"
client = Client(api_key=DBGPT_API_KEY)
res = await delete_flow(client=client, flow_id=flow_id)
Delete Parametersâ
uid string Required
flow id
Response bodyâ
Return Flow Object
Get Flowâ
GET /api/v2/serve/awel/flows/{flow_id}
- Curl
- Python
DBGPT_API_KEY=dbgpt
FLOW_ID={YOUR_FLOW_ID}
curl -X GET "http://localhost:5670/api/v2/serve/awel/flows/$FLOW_ID" -H "Authorization: Bearer $DBGPT_API_KEY"
from dbgpt_client import Client
from dbgpt_client.flow import get_flow
DBGPT_API_KEY = "dbgpt"
flow_id = "{your_flow_id}"
client = Client(api_key=DBGPT_API_KEY)
res = await get_flow(client=client, flow_id=flow_id)
Query Parametersâ
uid string Required
flow id
Response bodyâ
Return Flow Object
List Flowâ
GET /api/v2/serve/awel/flows
- Curl
- Python
DBGPT_API_KEY=dbgpt
curl -X GET "http://localhost:5670/api/v2/serve/awel/flows" -H "Authorization: Bearer $DBGPT_API_KEY"
from dbgpt_client import Client
from dbgpt_client.flow import list_flow
DBGPT_API_KEY = "dbgpt"
client = Client(api_key=DBGPT_API_KEY)
res = await list_flow(client=client)
Response bodyâ
Return Flow Object
The Flow Objectâ
uid string
The unique id for the flow.
name string
The name of the flow.
description string
The description of the flow.
label string
The label of the flow.
flow_category string
The category of the flow. Default is FlowCategory.COMMON.
flow_data object
The flow data.
state string
The state of the flow.Default is INITIALIZING.
error_message string
The error message of the flow.
source string
The source of the flow. Default is DBGPT-WEB.
source_url string
The source url of the flow.
version string
The version of the flow. Default is 0.1.0.
editable boolean
Whether the flow is editable. Default is True.
user_name string
The user name of the flow.
sys_code string
The system code of the flow.
dag_id string
The dag id of the flow.
gmt_created string
The created time of the flow.
gmt_modified string
The modified time of the flow.