mirror of
https://github.com/csunny/DB-GPT.git
synced 2025-07-25 21:14:06 +00:00
83 lines
2.5 KiB
Python
83 lines
2.5 KiB
Python
"""AWEL:
|
|
This example shows how to use AWEL to build a simple rag summary example.
|
|
pre-requirements:
|
|
1. install openai python sdk
|
|
```
|
|
pip install openai
|
|
```
|
|
2. set openai key and base
|
|
```
|
|
export OPENAI_API_KEY={your_openai_key}
|
|
export OPENAI_API_BASE={your_openai_base}
|
|
```
|
|
or
|
|
```
|
|
import os
|
|
os.environ["OPENAI_API_KEY"] = {your_openai_key}
|
|
os.environ["OPENAI_API_BASE"] = {your_openai_base}
|
|
```
|
|
python examples/awel/simple_rag_summary_example.py
|
|
Example:
|
|
|
|
.. code-block:: shell
|
|
|
|
curl -X POST http://127.0.0.1:5555/api/v1/awel/trigger/examples/rag/summary \
|
|
-H "Content-Type: application/json" -d '{
|
|
"url": "https://docs.dbgpt.site/docs/awel"
|
|
}'
|
|
"""
|
|
from typing import Dict
|
|
|
|
from dbgpt._private.pydantic import BaseModel, Field
|
|
from dbgpt.core.awel import DAG, HttpTrigger, MapOperator
|
|
from dbgpt.model.proxy import OpenAILLMClient
|
|
from dbgpt.rag.knowledge import KnowledgeType
|
|
from dbgpt.rag.operators import KnowledgeOperator, SummaryAssemblerOperator
|
|
|
|
|
|
class TriggerReqBody(BaseModel):
|
|
url: str = Field(..., description="url")
|
|
|
|
|
|
class RequestHandleOperator(MapOperator[TriggerReqBody, Dict]):
|
|
def __init__(self, **kwargs):
|
|
super().__init__(**kwargs)
|
|
|
|
async def map(self, input_value: TriggerReqBody) -> Dict:
|
|
params = {
|
|
"url": input_value.url,
|
|
}
|
|
print(f"Receive input value: {input_value}")
|
|
return params
|
|
|
|
|
|
with DAG("dbgpt_awel_simple_rag_summary_example") as dag:
|
|
trigger = HttpTrigger(
|
|
"/examples/rag/summary", methods="POST", request_body=TriggerReqBody
|
|
)
|
|
request_handle_task = RequestHandleOperator()
|
|
path_operator = MapOperator(lambda request: request["url"])
|
|
# build knowledge operator
|
|
knowledge_operator = KnowledgeOperator(knowledge_type=KnowledgeType.URL.name)
|
|
# build summary assembler operator
|
|
summary_operator = SummaryAssemblerOperator(
|
|
llm_client=OpenAILLMClient(), language="en"
|
|
)
|
|
(
|
|
trigger
|
|
>> request_handle_task
|
|
>> path_operator
|
|
>> knowledge_operator
|
|
>> summary_operator
|
|
)
|
|
|
|
|
|
if __name__ == "__main__":
|
|
if dag.leaf_nodes[0].dev_mode:
|
|
# Development mode, you can run the dag locally for debugging.
|
|
from dbgpt.core.awel import setup_dev_environment
|
|
|
|
setup_dev_environment([dag], port=5555)
|
|
else:
|
|
pass
|