mirror of
https://github.com/arc53/DocsGPT
synced 2024-11-02 03:40:17 +00:00
44 lines
1.5 KiB
Python
44 lines
1.5 KiB
Python
from application.llm.base import BaseLLM
|
|
import json
|
|
import requests
|
|
|
|
|
|
class DocsGPTAPILLM(BaseLLM):
|
|
|
|
def __init__(self, api_key=None, *args, **kwargs):
|
|
super().__init__(*args, **kwargs)
|
|
self.api_key = api_key
|
|
self.endpoint = "https://llm.docsgpt.co.uk"
|
|
|
|
def _raw_gen(self, baseself, model, messages, stream=False, *args, **kwargs):
|
|
context = messages[0]["content"]
|
|
user_question = messages[-1]["content"]
|
|
prompt = f"### Instruction \n {user_question} \n ### Context \n {context} \n ### Answer \n"
|
|
|
|
response = requests.post(
|
|
f"{self.endpoint}/answer", json={"prompt": prompt, "max_new_tokens": 30}
|
|
)
|
|
response_clean = response.json()["a"].replace("###", "")
|
|
|
|
return response_clean
|
|
|
|
def _raw_gen_stream(self, baseself, model, messages, stream=True, *args, **kwargs):
|
|
context = messages[0]["content"]
|
|
user_question = messages[-1]["content"]
|
|
prompt = f"### Instruction \n {user_question} \n ### Context \n {context} \n ### Answer \n"
|
|
|
|
# send prompt to endpoint /stream
|
|
response = requests.post(
|
|
f"{self.endpoint}/stream",
|
|
json={"prompt": prompt, "max_new_tokens": 256},
|
|
stream=True,
|
|
)
|
|
|
|
for line in response.iter_lines():
|
|
if line:
|
|
# data = json.loads(line)
|
|
data_str = line.decode("utf-8")
|
|
if data_str.startswith("data: "):
|
|
data = json.loads(data_str[6:])
|
|
yield data["a"]
|