update tools
fuwx
1 year ago
parent
ff2c59a881
commit
9529911932
@ -0,0 +1,45 @@
|
||||
import json
|
||||
from collections.abc import Generator
|
||||
from typing import Any, Optional
|
||||
|
||||
import requests
|
||||
|
||||
from configs import dify_config
|
||||
from core.tools.builtin_tool.tool import BuiltinTool
|
||||
from core.tools.entities.tool_entities import ToolInvokeMessage
|
||||
from libs.apo_utils import APOUtils
|
||||
|
||||
class SelectContainerCPUTool(BuiltinTool):
|
||||
def _invoke(
|
||||
self,
|
||||
user_id: str,
|
||||
tool_parameters: dict[str, Any],
|
||||
conversation_id: Optional[str] = None,
|
||||
app_id: Optional[str] = None,
|
||||
message_id: Optional[str] = None,
|
||||
) -> Generator[ToolInvokeMessage, None, None]:
|
||||
pod = tool_parameters.get("pod")
|
||||
namespace = tool_parameters.get("namespace")
|
||||
start_time = tool_parameters.get("startTime")
|
||||
end_time = tool_parameters.get("endTime")
|
||||
params = {
|
||||
'metricName': '基础设施情况 - 容器CPU - 容器CPU节流时间 - Containerd',
|
||||
'params': {
|
||||
"pod": pod,
|
||||
"namespace": namespace
|
||||
},
|
||||
'startTime': start_time,
|
||||
'endTime': end_time,
|
||||
'step': APOUtils.get_step(start_time, end_time),
|
||||
}
|
||||
resp = requests.post(dify_config.APO_BACKEND_URL + '/api/metric/query', json=params)
|
||||
list = resp.json()['result']
|
||||
list = json.dumps({
|
||||
'type': 'metric',
|
||||
'display': True,
|
||||
'unit': list['unit'],
|
||||
'data': {
|
||||
"timeseries": list['timeseries']
|
||||
}
|
||||
})
|
||||
yield self.create_text_message(list)
|
||||
@ -0,0 +1,70 @@
|
||||
identity:
|
||||
name: 容器CPU节流时长(使用Containerd容器运行时,按容器和Pod统计)
|
||||
author: APO
|
||||
label:
|
||||
en_US: Query the CPU utilization of the container
|
||||
zh_Hans: 容器CPU节流时长(使用Containerd容器运行时,按容器和Pod统计)
|
||||
pt_BR: Query the CPU utilization of the container
|
||||
display:
|
||||
type: metric
|
||||
title: 基础设施情况 - 容器CPU - 容器CPU节流时间 - Containerd
|
||||
unit: s 秒
|
||||
description:
|
||||
human:
|
||||
en_US: Query the CPU utilization of the container
|
||||
zh_Hans: 容器CPU节流时长(使用Containerd容器运行时,按容器和Pod统计)
|
||||
pt_BR: Query the CPU utilization of the container
|
||||
llm: Query the CPU utilization of the container
|
||||
parameters:
|
||||
- name: pod
|
||||
type: string
|
||||
required: true
|
||||
label:
|
||||
en_US: pod
|
||||
zh_Hans: pod
|
||||
pt_BR: pod
|
||||
human_description:
|
||||
en_US: Specified pod name
|
||||
zh_Hans: 指定的容器POD名称
|
||||
pt_BR: Specified pod name
|
||||
llm_description: Specified pod name
|
||||
form: llm
|
||||
- name: namespace
|
||||
type: string
|
||||
required: true
|
||||
label:
|
||||
en_US: namespace
|
||||
zh_Hans: namespace
|
||||
pt_BR: namespace
|
||||
human_description:
|
||||
en_US: Specified namespace
|
||||
zh_Hans: 指定的容器所在Namespace
|
||||
pt_BR: Specified namespace
|
||||
llm_description: Specified namespace
|
||||
form: llm
|
||||
- name: startTime
|
||||
type: number
|
||||
required: true
|
||||
label:
|
||||
en_US: startTime
|
||||
zh_Hans: startTime
|
||||
pt_BR: startTime
|
||||
human_description:
|
||||
en_US: Data query start time
|
||||
zh_Hans: 开始时间 (微秒)
|
||||
pt_BR: Data query start time
|
||||
llm_description: Data query start time
|
||||
form: llm
|
||||
- name: endTime
|
||||
type: number
|
||||
required: true
|
||||
label:
|
||||
en_US: endTime
|
||||
zh_Hans: endTime
|
||||
pt_BR: endTime
|
||||
human_description:
|
||||
en_US: Data query end time
|
||||
zh_Hans: 结束时间 (微秒)
|
||||
pt_BR: Data query end time
|
||||
llm_description: Data query start time
|
||||
form: llm
|
||||
@ -0,0 +1,43 @@
|
||||
import json
|
||||
from collections.abc import Generator
|
||||
from typing import Any, Optional
|
||||
|
||||
import requests
|
||||
|
||||
from configs import dify_config
|
||||
from core.tools.builtin_tool.tool import BuiltinTool
|
||||
from core.tools.entities.tool_entities import ToolInvokeMessage
|
||||
from libs.apo_utils import APOUtils
|
||||
|
||||
class HostDiskIOTool(BuiltinTool):
|
||||
def _invoke(
|
||||
self,
|
||||
user_id: str,
|
||||
tool_parameters: dict[str, Any],
|
||||
conversation_id: Optional[str] = None,
|
||||
app_id: Optional[str] = None,
|
||||
message_id: Optional[str] = None,
|
||||
) -> Generator[ToolInvokeMessage, None, None]:
|
||||
node = tool_parameters.get("node")
|
||||
start_time = tool_parameters.get("startTime")
|
||||
end_time = tool_parameters.get("endTime")
|
||||
params = {
|
||||
'metricName': '宿主机监控指标 - Storage Disk - Time Spent Doing I/Os - IO',
|
||||
'params': {
|
||||
"node": node
|
||||
},
|
||||
'startTime': start_time,
|
||||
'endTime': end_time,
|
||||
'step': APOUtils.get_step(start_time, end_time),
|
||||
}
|
||||
resp = requests.post(dify_config.APO_BACKEND_URL + '/api/metric/query', json=params)
|
||||
list = resp.json()['result']
|
||||
list = json.dumps({
|
||||
'type': 'metric',
|
||||
'display': True,
|
||||
'unit': list['unit'],
|
||||
'data': {
|
||||
"timeseries": list['timeseries']
|
||||
}
|
||||
})
|
||||
yield self.create_text_message(list)
|
||||
@ -0,0 +1,57 @@
|
||||
identity:
|
||||
name: 宿主机磁盘IO耗时速率
|
||||
author: APO
|
||||
label:
|
||||
en_US: Query the CPU utilization of the host
|
||||
zh_Hans: 宿主机磁盘IO耗时速率
|
||||
pt_BR: Query the CPU utilization of the host
|
||||
description:
|
||||
human:
|
||||
en_US: Query the CPU utilization of the host
|
||||
zh_Hans: 宿主机磁盘IO耗时速率
|
||||
pt_BR: Query the CPU utilization of the host
|
||||
llm: 宿主机磁盘IO耗时速率
|
||||
display:
|
||||
type: metric
|
||||
title: 宿主机监控指标 - Storage Disk - Time Spent Doing I/Os - IO
|
||||
unit: percent(0-100)百分比
|
||||
parameters:
|
||||
- name: node
|
||||
type: string
|
||||
required: true
|
||||
label:
|
||||
en_US: node
|
||||
zh_Hans: node
|
||||
pt_BR: node
|
||||
human_description:
|
||||
en_US: Specified host name
|
||||
zh_Hans: 指定的主机名
|
||||
pt_BR: Specified host name
|
||||
llm_description: Specified host name
|
||||
form: llm
|
||||
- name: startTime
|
||||
type: number
|
||||
required: true
|
||||
label:
|
||||
en_US: startTime
|
||||
zh_Hans: startTime
|
||||
pt_BR: startTime
|
||||
human_description:
|
||||
en_US: Data query start time
|
||||
zh_Hans: 开始时间 (微秒)
|
||||
pt_BR: Data query start time
|
||||
llm_description: Data query start time
|
||||
form: llm
|
||||
- name: endTime
|
||||
type: number
|
||||
required: true
|
||||
label:
|
||||
en_US: endTime
|
||||
zh_Hans: endTime
|
||||
pt_BR: endTime
|
||||
human_description:
|
||||
en_US: Data query end time
|
||||
zh_Hans: 结束时间 (微秒)
|
||||
pt_BR: Data query end time
|
||||
llm_description: Data query start time
|
||||
form: llm
|
||||
@ -0,0 +1,43 @@
|
||||
import json
|
||||
from collections.abc import Generator
|
||||
from typing import Any, Optional
|
||||
|
||||
import requests
|
||||
|
||||
from configs import dify_config
|
||||
from core.tools.builtin_tool.tool import BuiltinTool
|
||||
from core.tools.entities.tool_entities import ToolInvokeMessage
|
||||
from libs.apo_utils import APOUtils
|
||||
|
||||
class HostDiskReadBytesTool(BuiltinTool):
|
||||
def _invoke(
|
||||
self,
|
||||
user_id: str,
|
||||
tool_parameters: dict[str, Any],
|
||||
conversation_id: Optional[str] = None,
|
||||
app_id: Optional[str] = None,
|
||||
message_id: Optional[str] = None,
|
||||
) -> Generator[ToolInvokeMessage, None, None]:
|
||||
node = tool_parameters.get("node")
|
||||
start_time = tool_parameters.get("startTime")
|
||||
end_time = tool_parameters.get("endTime")
|
||||
params = {
|
||||
'metricName': '宿主机监控指标 - Storage Disk - Disk R/W Data - Read bytes',
|
||||
'params': {
|
||||
"node": node
|
||||
},
|
||||
'startTime': start_time,
|
||||
'endTime': end_time,
|
||||
'step': APOUtils.get_step(start_time, end_time),
|
||||
}
|
||||
resp = requests.post(dify_config.APO_BACKEND_URL + '/api/metric/query', json=params)
|
||||
list = resp.json()['result']
|
||||
list = json.dumps({
|
||||
'type': 'metric',
|
||||
'display': True,
|
||||
'unit': list['unit'],
|
||||
'data': {
|
||||
"timeseries": list['timeseries']
|
||||
}
|
||||
})
|
||||
yield self.create_text_message(list)
|
||||
@ -0,0 +1,57 @@
|
||||
identity:
|
||||
name: 宿主机磁盘读取数据速率(字节/秒)
|
||||
author: APO
|
||||
label:
|
||||
en_US: Query the CPU utilization of the host
|
||||
zh_Hans: 宿主机磁盘读取数据速率(字节/秒)
|
||||
pt_BR: Query the CPU utilization of the host
|
||||
description:
|
||||
human:
|
||||
en_US: Query the CPU utilization of the host
|
||||
zh_Hans: 宿主机磁盘读取数据速率(字节/秒)
|
||||
pt_BR: Query the CPU utilization of the host
|
||||
llm: 宿主机磁盘读取数据速率(字节/秒)
|
||||
display:
|
||||
type: metric
|
||||
title: 宿主机监控指标 - Storage Disk - Disk R/W Data - Read bytes
|
||||
unit: Bps 字节每秒
|
||||
parameters:
|
||||
- name: node
|
||||
type: string
|
||||
required: true
|
||||
label:
|
||||
en_US: node
|
||||
zh_Hans: node
|
||||
pt_BR: node
|
||||
human_description:
|
||||
en_US: Specified host name
|
||||
zh_Hans: 指定的主机名
|
||||
pt_BR: Specified host name
|
||||
llm_description: Specified host name
|
||||
form: llm
|
||||
- name: startTime
|
||||
type: number
|
||||
required: true
|
||||
label:
|
||||
en_US: startTime
|
||||
zh_Hans: startTime
|
||||
pt_BR: startTime
|
||||
human_description:
|
||||
en_US: Data query start time
|
||||
zh_Hans: 开始时间 (微秒)
|
||||
pt_BR: Data query start time
|
||||
llm_description: Data query start time
|
||||
form: llm
|
||||
- name: endTime
|
||||
type: number
|
||||
required: true
|
||||
label:
|
||||
en_US: endTime
|
||||
zh_Hans: endTime
|
||||
pt_BR: endTime
|
||||
human_description:
|
||||
en_US: Data query end time
|
||||
zh_Hans: 结束时间 (微秒)
|
||||
pt_BR: Data query end time
|
||||
llm_description: Data query start time
|
||||
form: llm
|
||||
@ -0,0 +1,43 @@
|
||||
import json
|
||||
from collections.abc import Generator
|
||||
from typing import Any, Optional
|
||||
|
||||
import requests
|
||||
|
||||
from configs import dify_config
|
||||
from core.tools.builtin_tool.tool import BuiltinTool
|
||||
from core.tools.entities.tool_entities import ToolInvokeMessage
|
||||
from libs.apo_utils import APOUtils
|
||||
|
||||
class HostDiskUsedTool(BuiltinTool):
|
||||
def _invoke(
|
||||
self,
|
||||
user_id: str,
|
||||
tool_parameters: dict[str, Any],
|
||||
conversation_id: Optional[str] = None,
|
||||
app_id: Optional[str] = None,
|
||||
message_id: Optional[str] = None,
|
||||
) -> Generator[ToolInvokeMessage, None, None]:
|
||||
node = tool_parameters.get("node")
|
||||
start_time = tool_parameters.get("startTime")
|
||||
end_time = tool_parameters.get("endTime")
|
||||
params = {
|
||||
'metricName': '宿主机监控指标 - Basic CPU / Mem / Net / Disk - Disk Space Used Basic',
|
||||
'params': {
|
||||
"node": node
|
||||
},
|
||||
'startTime': start_time,
|
||||
'endTime': end_time,
|
||||
'step': APOUtils.get_step(start_time, end_time),
|
||||
}
|
||||
resp = requests.post(dify_config.APO_BACKEND_URL + '/api/metric/query', json=params)
|
||||
list = resp.json()['result']
|
||||
list = json.dumps({
|
||||
'type': 'metric',
|
||||
'display': True,
|
||||
'unit': list['unit'],
|
||||
'data': {
|
||||
"timeseries": list['timeseries']
|
||||
}
|
||||
})
|
||||
yield self.create_text_message(list)
|
||||
@ -0,0 +1,57 @@
|
||||
identity:
|
||||
name: 宿主机磁盘使用率(百分比,不含rootfs)
|
||||
author: APO
|
||||
label:
|
||||
en_US: Query the CPU utilization of the host
|
||||
zh_Hans: 宿主机磁盘使用率(百分比,不含rootfs)
|
||||
pt_BR: Query the CPU utilization of the host
|
||||
description:
|
||||
human:
|
||||
en_US: Query the CPU utilization of the host
|
||||
zh_Hans: 宿主机磁盘使用率(百分比,不含rootfs)
|
||||
pt_BR: Query the CPU utilization of the host
|
||||
llm: 宿主机磁盘使用率(百分比,不含rootfs)
|
||||
display:
|
||||
type: metric
|
||||
title: 宿主机监控指标 - Basic CPU / Mem / Net / Disk - Disk Space Used Basic
|
||||
unit: percent(0-100)百分比
|
||||
parameters:
|
||||
- name: node
|
||||
type: string
|
||||
required: true
|
||||
label:
|
||||
en_US: node
|
||||
zh_Hans: node
|
||||
pt_BR: node
|
||||
human_description:
|
||||
en_US: Specified host name
|
||||
zh_Hans: 指定的主机名
|
||||
pt_BR: Specified host name
|
||||
llm_description: Specified host name
|
||||
form: llm
|
||||
- name: startTime
|
||||
type: number
|
||||
required: true
|
||||
label:
|
||||
en_US: startTime
|
||||
zh_Hans: startTime
|
||||
pt_BR: startTime
|
||||
human_description:
|
||||
en_US: Data query start time
|
||||
zh_Hans: 开始时间 (微秒)
|
||||
pt_BR: Data query start time
|
||||
llm_description: Data query start time
|
||||
form: llm
|
||||
- name: endTime
|
||||
type: number
|
||||
required: true
|
||||
label:
|
||||
en_US: endTime
|
||||
zh_Hans: endTime
|
||||
pt_BR: endTime
|
||||
human_description:
|
||||
en_US: Data query end time
|
||||
zh_Hans: 结束时间 (微秒)
|
||||
pt_BR: Data query end time
|
||||
llm_description: Data query start time
|
||||
form: llm
|
||||
@ -0,0 +1,43 @@
|
||||
import json
|
||||
from collections.abc import Generator
|
||||
from typing import Any, Optional
|
||||
|
||||
import requests
|
||||
|
||||
from configs import dify_config
|
||||
from core.tools.builtin_tool.tool import BuiltinTool
|
||||
from core.tools.entities.tool_entities import ToolInvokeMessage
|
||||
from libs.apo_utils import APOUtils
|
||||
|
||||
class HostDiskWriteBytesTool(BuiltinTool):
|
||||
def _invoke(
|
||||
self,
|
||||
user_id: str,
|
||||
tool_parameters: dict[str, Any],
|
||||
conversation_id: Optional[str] = None,
|
||||
app_id: Optional[str] = None,
|
||||
message_id: Optional[str] = None,
|
||||
) -> Generator[ToolInvokeMessage, None, None]:
|
||||
node = tool_parameters.get("node")
|
||||
start_time = tool_parameters.get("startTime")
|
||||
end_time = tool_parameters.get("endTime")
|
||||
params = {
|
||||
'metricName': '宿主机监控指标 - Storage Disk - Disk R/W Data - Written bytes',
|
||||
'params': {
|
||||
"node": node
|
||||
},
|
||||
'startTime': start_time,
|
||||
'endTime': end_time,
|
||||
'step': APOUtils.get_step(start_time, end_time),
|
||||
}
|
||||
resp = requests.post(dify_config.APO_BACKEND_URL + '/api/metric/query', json=params)
|
||||
list = resp.json()['result']
|
||||
list = json.dumps({
|
||||
'type': 'metric',
|
||||
'display': True,
|
||||
'unit': list['unit'],
|
||||
'data': {
|
||||
"timeseries": list['timeseries']
|
||||
}
|
||||
})
|
||||
yield self.create_text_message(list)
|
||||
@ -0,0 +1,57 @@
|
||||
identity:
|
||||
name: 宿主机磁盘写入数据速率(字节/秒)
|
||||
author: APO
|
||||
label:
|
||||
en_US: Query the CPU utilization of the host
|
||||
zh_Hans: 宿主机磁盘写入数据速率(字节/秒)
|
||||
pt_BR: Query the CPU utilization of the host
|
||||
description:
|
||||
human:
|
||||
en_US: Query the CPU utilization of the host
|
||||
zh_Hans: 宿主机磁盘写入数据速率(字节/秒)
|
||||
pt_BR: Query the CPU utilization of the host
|
||||
llm: 宿主机磁盘写入数据速率(字节/秒)
|
||||
display:
|
||||
type: metric
|
||||
title: 宿主机监控指标 - Storage Disk - Disk R/W Data - Written bytes
|
||||
unit: Bps 字节每秒
|
||||
parameters:
|
||||
- name: node
|
||||
type: string
|
||||
required: true
|
||||
label:
|
||||
en_US: node
|
||||
zh_Hans: node
|
||||
pt_BR: node
|
||||
human_description:
|
||||
en_US: Specified host name
|
||||
zh_Hans: 指定的主机名
|
||||
pt_BR: Specified host name
|
||||
llm_description: Specified host name
|
||||
form: llm
|
||||
- name: startTime
|
||||
type: number
|
||||
required: true
|
||||
label:
|
||||
en_US: startTime
|
||||
zh_Hans: startTime
|
||||
pt_BR: startTime
|
||||
human_description:
|
||||
en_US: Data query start time
|
||||
zh_Hans: 开始时间 (微秒)
|
||||
pt_BR: Data query start time
|
||||
llm_description: Data query start time
|
||||
form: llm
|
||||
- name: endTime
|
||||
type: number
|
||||
required: true
|
||||
label:
|
||||
en_US: endTime
|
||||
zh_Hans: endTime
|
||||
pt_BR: endTime
|
||||
human_description:
|
||||
en_US: Data query end time
|
||||
zh_Hans: 结束时间 (微秒)
|
||||
pt_BR: Data query end time
|
||||
llm_description: Data query start time
|
||||
form: llm
|
||||
@ -0,0 +1,43 @@
|
||||
import json
|
||||
from collections.abc import Generator
|
||||
from typing import Any, Optional
|
||||
|
||||
import requests
|
||||
|
||||
from configs import dify_config
|
||||
from core.tools.builtin_tool.tool import BuiltinTool
|
||||
from core.tools.entities.tool_entities import ToolInvokeMessage
|
||||
from libs.apo_utils import APOUtils
|
||||
|
||||
class HostCPUIoWaitRespTool(BuiltinTool):
|
||||
def _invoke(
|
||||
self,
|
||||
user_id: str,
|
||||
tool_parameters: dict[str, Any],
|
||||
conversation_id: Optional[str] = None,
|
||||
app_id: Optional[str] = None,
|
||||
message_id: Optional[str] = None,
|
||||
) -> Generator[ToolInvokeMessage, None, None]:
|
||||
node = tool_parameters.get("node")
|
||||
start_time = tool_parameters.get("startTime")
|
||||
end_time = tool_parameters.get("endTime")
|
||||
params = {
|
||||
'metricName': '宿主机监控指标 - Basic CPU / Mem / Net / Disk - Network Traffic Basic - recv',
|
||||
'params': {
|
||||
"node": node
|
||||
},
|
||||
'startTime': start_time,
|
||||
'endTime': end_time,
|
||||
'step': APOUtils.get_step(start_time, end_time),
|
||||
}
|
||||
resp = requests.post(dify_config.APO_BACKEND_URL + '/api/metric/query', json=params)
|
||||
list = resp.json()['result']
|
||||
list = json.dumps({
|
||||
'type': 'metric',
|
||||
'display': True,
|
||||
'unit': list['unit'],
|
||||
'data': {
|
||||
"timeseries": list['timeseries']
|
||||
}
|
||||
})
|
||||
yield self.create_text_message(list)
|
||||
@ -0,0 +1,57 @@
|
||||
identity:
|
||||
name: 宿主机网络接收速率(比特/秒)
|
||||
author: APO
|
||||
label:
|
||||
en_US: Query the CPU utilization of the host
|
||||
zh_Hans: 宿主机网络接收速率(比特/秒)
|
||||
pt_BR: Query the CPU utilization of the host
|
||||
description:
|
||||
human:
|
||||
en_US: Query the CPU utilization of the host
|
||||
zh_Hans: 宿主机网络接收速率(比特/秒)
|
||||
pt_BR: Query the CPU utilization of the host
|
||||
llm: 宿主机网络接收速率(比特/秒)
|
||||
display:
|
||||
type: metric
|
||||
title: 宿主机监控指标 - Basic CPU / Mem / Net / Disk - Network Traffic Basic - recv
|
||||
unit: percent(0-100)百分比
|
||||
parameters:
|
||||
- name: node
|
||||
type: string
|
||||
required: true
|
||||
label:
|
||||
en_US: node
|
||||
zh_Hans: node
|
||||
pt_BR: node
|
||||
human_description:
|
||||
en_US: Specified host name
|
||||
zh_Hans: 指定的主机名
|
||||
pt_BR: Specified host name
|
||||
llm_description: Specified host name
|
||||
form: llm
|
||||
- name: startTime
|
||||
type: number
|
||||
required: true
|
||||
label:
|
||||
en_US: startTime
|
||||
zh_Hans: startTime
|
||||
pt_BR: startTime
|
||||
human_description:
|
||||
en_US: Data query start time
|
||||
zh_Hans: 开始时间 (微秒)
|
||||
pt_BR: Data query start time
|
||||
llm_description: Data query start time
|
||||
form: llm
|
||||
- name: endTime
|
||||
type: number
|
||||
required: true
|
||||
label:
|
||||
en_US: endTime
|
||||
zh_Hans: endTime
|
||||
pt_BR: endTime
|
||||
human_description:
|
||||
en_US: Data query end time
|
||||
zh_Hans: 结束时间 (微秒)
|
||||
pt_BR: Data query end time
|
||||
llm_description: Data query start time
|
||||
form: llm
|
||||
@ -0,0 +1,45 @@
|
||||
import json
|
||||
from collections.abc import Generator
|
||||
from typing import Any, Optional
|
||||
|
||||
import requests
|
||||
|
||||
from configs import dify_config
|
||||
from core.tools.builtin_tool.tool import BuiltinTool
|
||||
from core.tools.entities.tool_entities import ToolInvokeMessage
|
||||
from libs.apo_utils import APOUtils
|
||||
|
||||
class OriginxServiceRedRespOkTool(BuiltinTool):
|
||||
def _invoke(
|
||||
self,
|
||||
user_id: str,
|
||||
tool_parameters: dict[str, Any],
|
||||
conversation_id: Optional[str] = None,
|
||||
app_id: Optional[str] = None,
|
||||
message_id: Optional[str] = None,
|
||||
) -> Generator[ToolInvokeMessage, None, None]:
|
||||
service_name = tool_parameters.get("service_name")
|
||||
content_key = tool_parameters.get("content_key")
|
||||
start_time = tool_parameters.get("startTime")
|
||||
end_time = tool_parameters.get("endTime")
|
||||
params = {
|
||||
'metricName': 'Originx 北极星指标 (服务层级) - RED指标 - 请求成功率',
|
||||
'params': {
|
||||
"service_name": service_name,
|
||||
"content_key": content_key
|
||||
},
|
||||
'startTime': start_time,
|
||||
'endTime': end_time,
|
||||
'step': APOUtils.get_step(start_time, end_time),
|
||||
}
|
||||
resp = requests.post(dify_config.APO_BACKEND_URL + '/api/metric/query', json=params)
|
||||
list = resp.json()['result']
|
||||
list = json.dumps({
|
||||
'type': 'metric',
|
||||
'display': True,
|
||||
'unit': list['unit'],
|
||||
'data': {
|
||||
"timeseries": list['timeseries']
|
||||
}
|
||||
})
|
||||
yield self.create_text_message(list)
|
||||
@ -0,0 +1,70 @@
|
||||
identity:
|
||||
name: Originx 北极星指标 (服务层级) - RED指标 - 请求成功率
|
||||
author: APO
|
||||
label:
|
||||
en_US: Query the CPU utilization of the host
|
||||
zh_Hans: 服务请求成功率(按服务名和内容键统计,指定时间段内)
|
||||
pt_BR: Query the CPU utilization of the host
|
||||
description:
|
||||
human:
|
||||
en_US: Query the CPU utilization of the host
|
||||
zh_Hans: 服务请求成功率(按服务名和内容键统计,指定时间段内)
|
||||
pt_BR: Query the CPU utilization of the host
|
||||
llm: 服务请求成功率(按服务名和内容键统计,指定时间段内)
|
||||
display:
|
||||
type: metric
|
||||
title: Originx 北极星指标 (服务层级) - RED指标 - 请求成功率
|
||||
unit: ms
|
||||
parameters:
|
||||
- name: service_name
|
||||
type: string
|
||||
required: true
|
||||
label:
|
||||
en_US: service_name
|
||||
zh_Hans: service_name
|
||||
pt_BR: service_name
|
||||
human_description:
|
||||
en_US: Specified service name
|
||||
zh_Hans: 指定的服务名
|
||||
pt_BR: Specified service name
|
||||
llm_description: 指定的服务名
|
||||
form: llm
|
||||
- name: content_key
|
||||
type: string
|
||||
required: true
|
||||
label:
|
||||
en_US: content_key
|
||||
zh_Hans: content_key
|
||||
pt_BR: content_key
|
||||
human_description:
|
||||
en_US: Specified endpoint name
|
||||
zh_Hans: 指定的服务端点名
|
||||
pt_BR: Specified endpoint name
|
||||
llm_description: 指定的服务端点名
|
||||
form: llm
|
||||
- name: startTime
|
||||
type: number
|
||||
required: true
|
||||
label:
|
||||
en_US: startTime
|
||||
zh_Hans: startTime
|
||||
pt_BR: startTime
|
||||
human_description:
|
||||
en_US: Data query start time
|
||||
zh_Hans: 开始时间 (微秒)
|
||||
pt_BR: Data query start time
|
||||
llm_description: Data query start time
|
||||
form: llm
|
||||
- name: endTime
|
||||
type: number
|
||||
required: true
|
||||
label:
|
||||
en_US: endTime
|
||||
zh_Hans: endTime
|
||||
pt_BR: endTime
|
||||
human_description:
|
||||
en_US: Data query end time
|
||||
zh_Hans: 结束时间 (微秒)
|
||||
pt_BR: Data query end time
|
||||
llm_description: Data query start time
|
||||
form: llm
|
||||
Loading…
Reference in New Issue