perf(chatcmpl): use extra_body to pass args (#1254)

This commit is contained in:
Junyan Qin (Chin)
2025-03-30 23:43:45 +08:00
committed by GitHub
parent 8b56f94667
commit 7341435127
4 changed files with 10 additions and 9 deletions
+4 -3
View File
@@ -47,8 +47,9 @@ class OpenAIChatCompletions(requester.LLMAPIRequester):
async def _req( async def _req(
self, self,
args: dict, args: dict,
extra_body: dict = {},
) -> chat_completion.ChatCompletion: ) -> chat_completion.ChatCompletion:
return await self.client.chat.completions.create(**args) return await self.client.chat.completions.create(**args, extra_body=extra_body)
async def _make_msg( async def _make_msg(
self, self,
@@ -73,7 +74,7 @@ class OpenAIChatCompletions(requester.LLMAPIRequester):
) -> llm_entities.Message: ) -> llm_entities.Message:
self.client.api_key = use_model.token_mgr.get_token() self.client.api_key = use_model.token_mgr.get_token()
args = self.requester_cfg['args'].copy() args = {}
args["model"] = use_model.name if use_model.model_name is None else use_model.model_name args["model"] = use_model.name if use_model.model_name is None else use_model.model_name
if use_funcs: if use_funcs:
@@ -99,7 +100,7 @@ class OpenAIChatCompletions(requester.LLMAPIRequester):
args["messages"] = messages args["messages"] = messages
# 发送请求 # 发送请求
resp = await self._req(args) resp = await self._req(args, extra_body=self.requester_cfg['args'])
# 处理请求结果 # 处理请求结果
message = await self._make_msg(resp) message = await self._make_msg(resp)
@@ -23,7 +23,7 @@ class DeepseekChatCompletions(chatcmpl.OpenAIChatCompletions):
) -> llm_entities.Message: ) -> llm_entities.Message:
self.client.api_key = use_model.token_mgr.get_token() self.client.api_key = use_model.token_mgr.get_token()
args = self.requester_cfg['args'].copy() args = {}
args["model"] = use_model.name if use_model.model_name is None else use_model.model_name args["model"] = use_model.name if use_model.model_name is None else use_model.model_name
if use_funcs: if use_funcs:
@@ -43,7 +43,7 @@ class DeepseekChatCompletions(chatcmpl.OpenAIChatCompletions):
args["messages"] = messages args["messages"] = messages
# 发送请求 # 发送请求
resp = await self._req(args) resp = await self._req(args, extra_body=self.requester_cfg['args'])
if resp is None: if resp is None:
raise errors.RequesterError('接口返回为空,请确定模型提供商服务是否正常') raise errors.RequesterError('接口返回为空,请确定模型提供商服务是否正常')
@@ -30,7 +30,7 @@ class GiteeAIChatCompletions(chatcmpl.OpenAIChatCompletions):
) -> llm_entities.Message: ) -> llm_entities.Message:
self.client.api_key = use_model.token_mgr.get_token() self.client.api_key = use_model.token_mgr.get_token()
args = self.requester_cfg['args'].copy() args = {}
args["model"] = use_model.name if use_model.model_name is None else use_model.model_name args["model"] = use_model.name if use_model.model_name is None else use_model.model_name
if use_funcs: if use_funcs:
@@ -46,7 +46,7 @@ class GiteeAIChatCompletions(chatcmpl.OpenAIChatCompletions):
args["messages"] = req_messages args["messages"] = req_messages
resp = await self._req(args) resp = await self._req(args, extra_body=self.requester_cfg['args'])
message = await self._make_msg(resp) message = await self._make_msg(resp)
@@ -25,7 +25,7 @@ class MoonshotChatCompletions(chatcmpl.OpenAIChatCompletions):
) -> llm_entities.Message: ) -> llm_entities.Message:
self.client.api_key = use_model.token_mgr.get_token() self.client.api_key = use_model.token_mgr.get_token()
args = self.requester_cfg['args'].copy() args = {}
args["model"] = use_model.name if use_model.model_name is None else use_model.model_name args["model"] = use_model.name if use_model.model_name is None else use_model.model_name
if use_funcs: if use_funcs:
@@ -48,7 +48,7 @@ class MoonshotChatCompletions(chatcmpl.OpenAIChatCompletions):
args["messages"] = messages args["messages"] = messages
# 发送请求 # 发送请求
resp = await self._req(args) resp = await self._req(args, extra_body=self.requester_cfg['args'])
# 处理请求结果 # 处理请求结果
message = await self._make_msg(resp) message = await self._make_msg(resp)