Feat/metric 15 41 (#4)

* feat: Tools from metrics 0-14

* feat: Tools from metrics 15-30

* feat: Tools from metrics 31-41. Fill with '.*' when param is empty.

api/core/tools/builtin_tool/providers/apo_select/tools/alert.yaml

@@ -18,7 +18,7 @@ display:
 parameters:
   - name: service
     type: string
-    required: true
+    required: false
     label:
       en_US: service
       zh_Hans: service
@@ -31,7 +31,7 @@ parameters:
     form: llm
   - name: endpoint
     type: string
-    required: true
+    required: false
     label:
       en_US: endpoint
       zh_Hans: endpoint

api/core/tools/builtin_tool/providers/apo_select/tools/cluster_cpu_total.yaml

@@ -16,7 +16,7 @@ display:
 parameters:
   - name: cluster
     type: string
-    required: False
+    required: false
     label:
       en_US: Cluster name
       zh_Hans: 集群名称

api/core/tools/builtin_tool/providers/apo_select/tools/cluster_cpu_usage_linux.py

@@ -0,0 +1,44 @@
+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 ClusterCpuUsageLinuxTool(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]:
+        cluster = tool_parameters.get('cluster', '.*')
+        start_time = tool_parameters.get("startTime")
+        end_time = tool_parameters.get("endTime")
+        params = {
+            'metricName': '集群总览 - 总览 - CPU使用量 - Real Linux',
+            'params': {
+                'cluster': cluster
+            },
+            '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)

api/core/tools/builtin_tool/providers/apo_select/tools/cluster_cpu_usage_linux.yaml

@@ -0,0 +1,53 @@
+identity:
+  name: 实时集群CPU使用核数
+  author: APO
+  label:
+    en_US: Real-time cluster CPU cores usage
+    zh_Hans: 实时集群CPU使用核数
+description:
+  human:
+    en_US: Real-time cluster CPU cores usage
+    zh_Hans: 实时集群CPU使用核数
+  llm: Real-time cluster CPU cores usage
+display:
+  type: metric
+  title: 集群总览 - 总览 - CPU使用量 - Real Linux
+  unit: "core"
+parameters:
+  - name: cluster
+    type: string
+    required: False
+    label:
+      en_US: Cluster name
+      zh_Hans: 集群名称
+    human_description:
+      en_US: Cluster name
+      zh_Hans: 集群名称
+    llm_description: Cluster 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

api/core/tools/builtin_tool/providers/apo_select/tools/cluster_memory_total.yaml

@@ -16,7 +16,7 @@ display:
 parameters:
   - name: cluster
     type: string
-    required: False
+    required: false
     label:
       en_US: Cluster name
       zh_Hans: 集群名称

api/core/tools/builtin_tool/providers/apo_select/tools/cluster_memory_usage.yaml

@@ -16,7 +16,7 @@ display:
 parameters:
   - name: cluster
     type: string
-    required: False
+    required: false
     label:
       en_US: Cluster name
       zh_Hans: 集群名称

api/core/tools/builtin_tool/providers/apo_select/tools/cluster_memory_usage_linux.py

@@ -0,0 +1,44 @@
+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 ClusterMemoryUsageLinuxTool(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]:
+        cluster = tool_parameters.get('cluster', '.*')
+        start_time = tool_parameters.get("startTime")
+        end_time = tool_parameters.get("endTime")
+        params = {
+            'metricName': '集群总览 - 总览 - 内存使用量 - Real Linux',
+            'params': {
+                'cluster': cluster
+            },
+            '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)

api/core/tools/builtin_tool/providers/apo_select/tools/cluster_memory_usage_linux.yaml

@@ -0,0 +1,53 @@
+identity:
+  name: 实时集群内存使用字节数
+  author: APO
+  label:
+    en_US: Real-time cluster memory usage in bytes
+    zh_Hans: 实时集群内存使用字节数
+description:
+  human:
+    en_US: Real-time cluster memory usage in bytes
+    zh_Hans: 实时集群内存使用字节数
+  llm: Real-time cluster memory usage in bytes
+display:
+  type: metric
+  title: 集群总览 - 总览 - 内存使用量 - Real Linux
+  unit: "bytes"
+parameters:
+  - name: cluster
+    type: string
+    required: False
+    label:
+      en_US: Cluster name
+      zh_Hans: 集群名称
+    human_description:
+      en_US: Cluster name
+      zh_Hans: 集群名称
+    llm_description: Cluster 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

api/core/tools/builtin_tool/providers/apo_select/tools/cluster_memory_usage_real_linux.yaml

@@ -16,7 +16,7 @@ display:
 parameters:
   - name: cluster
     type: string
-    required: False
+    required: false
     label:
       en_US: Cluster name
       zh_Hans: 集群名称

api/core/tools/builtin_tool/providers/apo_select/tools/cluster_namespace_count.yaml

@@ -16,7 +16,7 @@ display:
 parameters:
   - name: cadvisor_job_name
     type: string
-    required: False
+    required: false
     label:
       en_US: cAdvisor job name
       zh_Hans: cAdvisor任务名称

api/core/tools/builtin_tool/providers/apo_select/tools/cluster_network_receive_bytes.py

@@ -0,0 +1,44 @@
+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 ClusterNetworkReceiveBytesTool(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]:
+        cluster = tool_parameters.get('cluster', '.*')
+        start_time = tool_parameters.get("startTime")
+        end_time = tool_parameters.get("endTime")
+        params = {
+            'metricName': '集群总览 - 总览 - 集群整体网络带宽(按设备统计) - 接收',
+            'params': {
+                'cluster': cluster
+            },
+            '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)

api/core/tools/builtin_tool/providers/apo_select/tools/cluster_network_receive_bytes.yaml

@@ -0,0 +1,53 @@
+identity:
+  name: 集群网络接收带宽(按设备统计,排除虚拟设备)
+  author: APO
+  label:
+    en_US: Cluster network receive bandwidth (by device, excluding virtual devices)
+    zh_Hans: 集群网络接收带宽(按设备统计,排除虚拟设备)
+description:
+  human:
+    en_US: Cluster network receive bandwidth (by device, excluding virtual devices)
+    zh_Hans: 集群网络接收带宽(按设备统计,排除虚拟设备)
+  llm: Cluster network receive bandwidth (by device, excluding virtual devices)
+display:
+  type: metric
+  title: 集群总览 - 总览 - 集群整体网络带宽(按设备统计) - 接收
+  unit: "bytes"
+parameters:
+  - name: cluster
+    type: string
+    required: False
+    label:
+      en_US: Cluster name
+      zh_Hans: 集群名称
+    human_description:
+      en_US: Cluster name
+      zh_Hans: 集群名称
+    llm_description: Cluster 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

api/core/tools/builtin_tool/providers/apo_select/tools/cluster_network_transmit_bytes.py

@@ -0,0 +1,44 @@
+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 ClusterNetworkTransmitBytesTool(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]:
+        cluster = tool_parameters.get('cluster', '.*')
+        start_time = tool_parameters.get("startTime")
+        end_time = tool_parameters.get("endTime")
+        params = {
+            'metricName': '集群总览 - 总览 - 集群整体网络带宽(按设备统计) - 发送',
+            'params': {
+                'cluster': cluster
+            },
+            '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)

api/core/tools/builtin_tool/providers/apo_select/tools/cluster_network_transmit_bytes.yaml

@@ -0,0 +1,53 @@
+identity:
+  name: 集群网络发送带宽(按设备统计,排除虚拟设备)
+  author: APO
+  label:
+    en_US: Cluster network transmit bandwidth (by device, excluding virtual devices)
+    zh_Hans: 集群网络发送带宽(按设备统计,排除虚拟设备)
+description:
+  human:
+    en_US: Cluster network transmit bandwidth (by device, excluding virtual devices)
+    zh_Hans: 集群网络发送带宽(按设备统计,排除虚拟设备)
+  llm: Cluster network transmit bandwidth (by device, excluding virtual devices)
+display:
+  type: metric
+  title: 集群总览 - 总览 - 集群整体网络带宽(按设备统计) - 发送
+  unit: "bytes"
+parameters:
+  - name: cluster
+    type: string
+    required: False
+    label:
+      en_US: Cluster name
+      zh_Hans: 集群名称
+    human_description:
+      en_US: Cluster name
+      zh_Hans: 集群名称
+    llm_description: Cluster 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

api/core/tools/builtin_tool/providers/apo_select/tools/cluster_node_cpu_throttle_seconds.py

@@ -0,0 +1,44 @@
+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 ClusterNodeCpuThrottleSecondsTool(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]:
+        cluster = tool_parameters.get('cluster')
+        start_time = tool_parameters.get("startTime")
+        end_time = tool_parameters.get("endTime")
+        params = {
+            'metricName': '集群总览 - 节点资源使用 - 节点CPU限流时长',
+            'params': {
+                **({'cluster': cluster} if cluster else {})
+            },
+            '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)

api/core/tools/builtin_tool/providers/apo_select/tools/cluster_node_cpu_throttle_seconds.yaml

@@ -0,0 +1,53 @@
+identity:
+  name: 节点CPU限流时长
+  author: APO
+  label:
+    en_US: Node CPU throttling time
+    zh_Hans: 节点CPU限流时长
+description:
+  human:
+    en_US: Node CPU throttling time
+    zh_Hans: 节点CPU限流时长
+  llm: Node CPU throttling time
+display:
+  type: metric
+  title: 集群总览 - 节点资源使用 - 节点CPU限流时长
+  unit: "s"
+parameters:
+  - name: cluster
+    type: string
+    required: False
+    label:
+      en_US: Cluster name
+      zh_Hans: 集群名称
+    human_description:
+      en_US: Cluster name
+      zh_Hans: 集群名称
+    llm_description: Cluster 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

api/core/tools/builtin_tool/providers/apo_select/tools/cluster_node_loopback_receive_bytes.py

@@ -0,0 +1,44 @@
+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 ClusterNodeLoopbackReceiveBytesTool(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]:
+        cluster = tool_parameters.get('cluster')
+        start_time = tool_parameters.get("startTime")
+        end_time = tool_parameters.get("endTime")
+        params = {
+            'metricName': '集群总览 - 节点资源使用 - 节点的网络使用量(仅回环) - Received bytes in',
+            'params': {
+                **({'cluster': cluster} if cluster else {})
+            },
+            '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)

api/core/tools/builtin_tool/providers/apo_select/tools/cluster_node_loopback_receive_bytes.yaml

@@ -0,0 +1,53 @@
+identity:
+  name: 节点回环网络接收带宽, 仅回环设备
+  author: APO
+  label:
+    en_US: Node loopback network receive bandwidth (loopback devices only)
+    zh_Hans: 节点回环网络接收带宽, 仅回环设备
+description:
+  human:
+    en_US: Node loopback network receive bandwidth (loopback devices only)
+    zh_Hans: 节点回环网络接收带宽, 仅回环设备
+  llm: Node loopback network receive bandwidth (loopback devices only)
+display:
+  type: metric
+  title: 集群总览 - 节点资源使用 - 节点的网络使用量(仅回环) - Received bytes in
+  unit: "bytes"
+parameters:
+  - name: cluster
+    type: string
+    required: False
+    label:
+      en_US: Cluster name
+      zh_Hans: 集群名称
+    human_description:
+      en_US: Cluster name
+      zh_Hans: 集群名称
+    llm_description: Cluster 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

api/core/tools/builtin_tool/providers/apo_select/tools/cluster_node_loopback_transmit_bytes.py

@@ -0,0 +1,44 @@
+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 ClusterNodeLoopbackTransmitBytesTool(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]:
+        cluster = tool_parameters.get('cluster')
+        start_time = tool_parameters.get("startTime")
+        end_time = tool_parameters.get("endTime")
+        params = {
+            'metricName': '集群总览 - 节点资源使用 - 节点的网络使用量(仅回环) - Transmitted bytes in',
+            'params': {
+                **({'cluster': cluster} if cluster else {})
+            },
+            '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)

api/core/tools/builtin_tool/providers/apo_select/tools/cluster_node_loopback_transmit_bytes.yaml

@@ -0,0 +1,53 @@
+identity:
+  name: 节点回环网络发送带宽, 仅回环设备
+  author: APO
+  label:
+    en_US: Node loopback network transmit bandwidth (loopback devices only)
+    zh_Hans: 节点回环网络发送带宽, 仅回环设备
+description:
+  human:
+    en_US: Node loopback network transmit bandwidth (loopback devices only)
+    zh_Hans: 节点回环网络发送带宽, 仅回环设备
+  llm: Node loopback network transmit bandwidth (loopback devices only)
+display:
+  type: metric
+  title: 集群总览 - 节点资源使用 - 节点的网络使用量(仅回环) - Transmitted bytes in
+  unit: "bytes"
+parameters:
+  - name: cluster
+    type: string
+    required: False
+    label:
+      en_US: Cluster name
+      zh_Hans: 集群名称
+    human_description:
+      en_US: Cluster name
+      zh_Hans: 集群名称
+    llm_description: Cluster 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

api/core/tools/builtin_tool/providers/apo_select/tools/cluster_node_network_receive_bytes.py

@@ -0,0 +1,44 @@
+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 ClusterNodeNetworkReceiveBytesTool(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]:
+        cluster = tool_parameters.get('cluster')
+        start_time = tool_parameters.get("startTime")
+        end_time = tool_parameters.get("endTime")
+        params = {
+            'metricName': '集群总览 - 节点资源使用 - 节点的网络使用量 - 接收',
+            'params': {
+                **({'cluster': cluster} if cluster else {})
+            },
+            '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)

api/core/tools/builtin_tool/providers/apo_select/tools/cluster_node_network_receive_bytes.yaml

@@ -0,0 +1,53 @@
+identity:
+  name: 节点网络接收带宽
+  author: APO
+  label:
+    en_US: Node network receive bandwidth
+    zh_Hans: 节点网络接收带宽
+description:
+  human:
+    en_US: Node network receive bandwidth
+    zh_Hans: 节点网络接收带宽
+  llm: Node network receive bandwidth
+display:
+  type: metric
+  title: 集群总览 - 节点资源使用 - 节点的网络使用量 - 接收
+  unit: "bytes"
+parameters:
+  - name: cluster
+    type: string
+    required: False
+    label:
+      en_US: Cluster name
+      zh_Hans: 集群名称
+    human_description:
+      en_US: Cluster name
+      zh_Hans: 集群名称
+    llm_description: Cluster 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

api/core/tools/builtin_tool/providers/apo_select/tools/cluster_node_network_receive_excl_virtual_bytes.py

@@ -0,0 +1,44 @@
+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 ClusterNodeNetworkReceiveExclVirtualBytesTool(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]:
+        cluster = tool_parameters.get('cluster')
+        start_time = tool_parameters.get("startTime")
+        end_time = tool_parameters.get("endTime")
+        params = {
+            'metricName': '集群总览 - 节点资源使用 - 节点的网络使用量(不含回环/虚拟设备) - Received bytes in',
+            'params': {
+                **({'cluster': cluster} if cluster else {})
+            },
+            '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)

api/core/tools/builtin_tool/providers/apo_select/tools/cluster_node_network_receive_excl_virtual_bytes.yaml

@@ -0,0 +1,53 @@
+identity:
+  name: 节点网络接收带宽(排除虚拟和回环设备)
+  author: APO
+  label:
+    en_US: Node network receive bandwidth (excluding virtual and loopback devices)
+    zh_Hans: 节点网络接收带宽(排除虚拟和回环设备)
+description:
+  human:
+    en_US: Node network receive bandwidth (excluding virtual and loopback devices)
+    zh_Hans: 节点网络接收带宽(排除虚拟和回环设备)
+  llm: Node network receive bandwidth (excluding virtual and loopback devices)
+display:
+  type: metric
+  title: 集群总览 - 节点资源使用 - 节点的网络使用量(不含回环/虚拟设备) - Received bytes in
+  unit: "bytes"
+parameters:
+  - name: cluster
+    type: string
+    required: False
+    label:
+      en_US: Cluster name
+      zh_Hans: 集群名称
+    human_description:
+      en_US: Cluster name
+      zh_Hans: 集群名称
+    llm_description: Cluster 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

api/core/tools/builtin_tool/providers/apo_select/tools/cluster_node_network_transmit_bytes.py

@@ -0,0 +1,44 @@
+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 ClusterNodeNetworkTransmitBytesTool(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]:
+        cluster = tool_parameters.get('cluster')
+        start_time = tool_parameters.get("startTime")
+        end_time = tool_parameters.get("endTime")
+        params = {
+            'metricName': '集群总览 - 节点资源使用 - 节点的网络使用量 - 发送',
+            'params': {
+                **({'cluster': cluster} if cluster else {})
+            },
+            '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)

api/core/tools/builtin_tool/providers/apo_select/tools/cluster_node_network_transmit_bytes.yaml

@@ -0,0 +1,53 @@
+identity:
+  name: 节点网络发送带宽
+  author: APO
+  label:
+    en_US: Node network transmit bandwidth
+    zh_Hans: 节点网络发送带宽
+description:
+  human:
+    en_US: Node network transmit bandwidth
+    zh_Hans: 节点网络发送带宽
+  llm: Node network transmit bandwidth
+display:
+  type: metric
+  title: 集群总览 - 节点资源使用 - 节点的网络使用量 - 发送
+  unit: "bytes"
+parameters:
+  - name: cluster
+    type: string
+    required: False
+    label:
+      en_US: Cluster name
+      zh_Hans: 集群名称
+    human_description:
+      en_US: Cluster name
+      zh_Hans: 集群名称
+    llm_description: Cluster 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

api/core/tools/builtin_tool/providers/apo_select/tools/cluster_node_network_transmit_excl_virtual_bytes.py

@@ -0,0 +1,44 @@
+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 ClusterNodeNetworkTransmitExclVirtualBytesTool(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]:
+        cluster = tool_parameters.get('cluster')
+        start_time = tool_parameters.get("startTime")
+        end_time = tool_parameters.get("endTime")
+        params = {
+            'metricName': '集群总览 - 节点资源使用 - 节点的网络使用量(不含回环/虚拟设备) - Transmitted bytes in',
+            'params': {
+                **({'cluster': cluster} if cluster else {})
+            },
+            '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)

api/core/tools/builtin_tool/providers/apo_select/tools/cluster_node_network_transmit_excl_virtual_bytes.yaml

@@ -0,0 +1,53 @@
+identity:
+  name: 节点网络发送带宽(排除虚拟和回环设备)
+  author: APO
+  label:
+    en_US: Node network transmit bandwidth (excluding virtual and loopback devices)
+    zh_Hans: 节点网络发送带宽(排除虚拟和回环设备)
+description:
+  human:
+    en_US: Node network transmit bandwidth (excluding virtual and loopback devices)
+    zh_Hans: 节点网络发送带宽(排除虚拟和回环设备)
+  llm: Node network transmit bandwidth (excluding virtual and loopback devices)
+display:
+  type: metric
+  title: 集群总览 - 节点资源使用 - 节点的网络使用量(不含回环/虚拟设备) - Transmitted bytes in
+  unit: "bytes"
+parameters:
+  - name: cluster
+    type: string
+    required: False
+    label:
+      en_US: Cluster name
+      zh_Hans: 集群名称
+    human_description:
+      en_US: Cluster name
+      zh_Hans: 集群名称
+    llm_description: Cluster 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

api/core/tools/builtin_tool/providers/apo_select/tools/cluster_overview_cpu_utilization_linux.py

@@ -0,0 +1,44 @@
+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 ClusterOverviewCpuUtilizationLinuxTool(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]:
+        cluster = tool_parameters.get('cluster', '.*')
+        start_time = tool_parameters.get("startTime")
+        end_time = tool_parameters.get("endTime")
+        params = {
+            'metricName': '集群总览 - 总览 - 集群总CPU使用率 - Real Linux',
+            'params': {
+                'cluster': cluster
+            },
+            '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)

api/core/tools/builtin_tool/providers/apo_select/tools/cluster_overview_cpu_utilization_linux.yaml

@@ -0,0 +1,53 @@
+identity:
+  name: 实时集群CPU使用率
+  author: APO
+  label:
+    en_US: Real-time cluster CPU utilization rate
+    zh_Hans: 实时集群CPU使用率
+description:
+  human:
+    en_US: Real-time cluster CPU utilization rate
+    zh_Hans: 实时集群CPU使用率
+  llm: Real-time cluster CPU utilization rate
+display:
+  type: metric
+  title: 集群总览 - 总览 - 集群总CPU使用率 - Real Linux
+  unit: "percentunit"
+parameters:
+  - name: cluster
+    type: string
+    required: False
+    label:
+      en_US: Cluster name
+      zh_Hans: 集群名称
+    human_description:
+      en_US: Cluster name
+      zh_Hans: 集群名称
+    llm_description: Cluster 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

api/core/tools/builtin_tool/providers/apo_select/tools/cluster_overview_memory_utilization_linux.py

@@ -0,0 +1,44 @@
+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 ClusterOverviewMemoryUtilizationLinuxTool(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]:
+        cluster = tool_parameters.get('cluster', '.*')
+        start_time = tool_parameters.get("startTime")
+        end_time = tool_parameters.get("endTime")
+        params = {
+            'metricName': '集群总览 - 总览 - 集群总内存使用率 - Real Linux',
+            'params': {
+                'cluster': cluster
+            },
+            '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)

api/core/tools/builtin_tool/providers/apo_select/tools/cluster_overview_memory_utilization_linux.yaml

@@ -0,0 +1,53 @@
+identity:
+  name: 实时集群内存使用率
+  author: APO
+  label:
+    en_US: Real-time cluster memory utilization rate
+    zh_Hans: 实时集群内存使用率
+description:
+  human:
+    en_US: Real-time cluster memory utilization rate
+    zh_Hans: 实时集群内存使用率
+  llm: Real-time cluster memory utilization rate
+display:
+  type: metric
+  title: 集群总览 - 总览 - 集群总内存使用率 - Real Linux
+  unit: "percentunit"
+parameters:
+  - name: cluster
+    type: string
+    required: False
+    label:
+      en_US: Cluster name
+      zh_Hans: 集群名称
+    human_description:
+      en_US: Cluster name
+      zh_Hans: 集群名称
+    llm_description: Cluster 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

api/core/tools/builtin_tool/providers/apo_select/tools/cluster_overview_namespace_count.py

@@ -0,0 +1,44 @@
+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 ClusterOverviewNamespaceCountTool(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]:
+        cadvisor_job_name = tool_parameters.get('cadvisor_job_name', '.*')
+        start_time = tool_parameters.get("startTime")
+        end_time = tool_parameters.get("endTime")
+        params = {
+            'metricName': '集群总览 - 总览 - 命名空间数量',
+            'params': {
+                'cadvisor_job_name': cadvisor_job_name
+            },
+            '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)

api/core/tools/builtin_tool/providers/apo_select/tools/cluster_overview_namespace_count.yaml

@@ -0,0 +1,53 @@
+identity:
+  name: K8s集群中命名空间的数量
+  author: APO
+  label:
+    en_US: Number of namespaces in Kubernetes cluster
+    zh_Hans: K8s集群中命名空间的数量
+description:
+  human:
+    en_US: Number of namespaces in Kubernetes cluster
+    zh_Hans: K8s集群中命名空间的数量
+  llm: Number of namespaces in Kubernetes cluster
+display:
+  type: metric
+  title: 集群总览 - 总览 - 命名空间数量
+  unit: "count"
+parameters:
+  - name: cadvisor_job_name
+    type: string
+    required: False
+    label:
+      en_US: cAdvisor job name
+      zh_Hans: cAdvisor任务名称
+    human_description:
+      en_US: cAdvisor job name
+      zh_Hans: cAdvisor任务名称
+    llm_description: cAdvisor job 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

api/core/tools/builtin_tool/providers/apo_select/tools/cluster_overview_node_count.py

@@ -0,0 +1,44 @@
+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 ClusterOverviewNodeCountTool(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]:
+        cadvisor_job_name = tool_parameters.get('cadvisor_job_name', '.*')
+        start_time = tool_parameters.get("startTime")
+        end_time = tool_parameters.get("endTime")
+        params = {
+            'metricName': '集群总览 - 总览 - 节点数',
+            'params': {
+                'cadvisor_job_name': cadvisor_job_name
+            },
+            '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)

api/core/tools/builtin_tool/providers/apo_select/tools/cluster_overview_node_count.yaml

@@ -0,0 +1,53 @@
+identity:
+  name: K8s集群中节点的数量
+  author: APO
+  label:
+    en_US: Number of nodes in Kubernetes cluster
+    zh_Hans: K8s集群中节点的数量
+description:
+  human:
+    en_US: Number of nodes in Kubernetes cluster
+    zh_Hans: K8s集群中节点的数量
+  llm: Number of nodes in Kubernetes cluster
+display:
+  type: metric
+  title: 集群总览 - 总览 - 节点数
+  unit: "count"
+parameters:
+  - name: cadvisor_job_name
+    type: string
+    required: False
+    label:
+      en_US: cAdvisor job name
+      zh_Hans: cAdvisor任务名称
+    human_description:
+      en_US: cAdvisor job name
+      zh_Hans: cAdvisor任务名称
+    llm_description: cAdvisor job 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

api/core/tools/builtin_tool/providers/apo_select/tools/cluster_running_pods_count.py

@@ -0,0 +1,44 @@
+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 ClusterRunningPodsCountTool(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]:
+        cadvisor_job_name = tool_parameters.get('cadvisor_job_name', '.*')
+        start_time = tool_parameters.get("startTime")
+        end_time = tool_parameters.get("endTime")
+        params = {
+            'metricName': '集群总览 - 总览 - 运行的Pod数',
+            'params': {
+                'cadvisor_job_name': cadvisor_job_name
+            },
+            '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)

api/core/tools/builtin_tool/providers/apo_select/tools/cluster_running_pods_count.yaml

@@ -0,0 +1,53 @@
+identity:
+  name: K8s集群中运行中的Pod数量
+  author: APO
+  label:
+    en_US: Number of running Pods in Kubernetes cluster
+    zh_Hans: K8s集群中运行中的Pod数量
+description:
+  human:
+    en_US: Number of running Pods in Kubernetes cluster
+    zh_Hans: K8s集群中运行中的Pod数量
+  llm: Number of running Pods in Kubernetes cluster
+display:
+  type: metric
+  title: 集群总览 - 总览 - 运行的Pod数
+  unit: "count"
+parameters:
+  - name: cadvisor_job_name
+    type: string
+    required: False
+    label:
+      en_US: cAdvisor job name
+      zh_Hans: cAdvisor任务名称
+    human_description:
+      en_US: cAdvisor job name
+      zh_Hans: cAdvisor任务名称
+    llm_description: cAdvisor job 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

api/core/tools/builtin_tool/providers/apo_select/tools/cluster_total_cpu_capacity.py

@@ -0,0 +1,44 @@
+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 ClusterTotalCpuCapacityTool(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]:
+        cluster = tool_parameters.get('cluster', '.*')
+        start_time = tool_parameters.get("startTime")
+        end_time = tool_parameters.get("endTime")
+        params = {
+            'metricName': '集群总览 - 总览 - CPU使用量 - Total',
+            'params': {
+                'cluster': cluster
+            },
+            '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)

api/core/tools/builtin_tool/providers/apo_select/tools/cluster_total_cpu_capacity.yaml

@@ -0,0 +1,53 @@
+identity:
+  name: 集群总可用CPU核数
+  author: APO
+  label:
+    en_US: Total available CPU cores in cluster
+    zh_Hans: 集群总可用CPU核数
+description:
+  human:
+    en_US: Total available CPU cores in cluster
+    zh_Hans: 集群总可用CPU核数
+  llm: Total available CPU cores in cluster
+display:
+  type: metric
+  title: 集群总览 - 总览 - CPU使用量 - Total
+  unit: "core"
+parameters:
+  - name: cluster
+    type: string
+    required: False
+    label:
+      en_US: Cluster name
+      zh_Hans: 集群名称
+    human_description:
+      en_US: Cluster name
+      zh_Hans: 集群名称
+    llm_description: Cluster 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

api/core/tools/builtin_tool/providers/apo_select/tools/cluster_total_memory_capacity.py

@@ -0,0 +1,44 @@
+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 ClusterTotalMemoryCapacityTool(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]:
+        cluster = tool_parameters.get('cluster', '.*')
+        start_time = tool_parameters.get("startTime")
+        end_time = tool_parameters.get("endTime")
+        params = {
+            'metricName': '集群总览 - 总览 - 内存使用量 - Total',
+            'params': {
+                'cluster': cluster
+            },
+            '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)

api/core/tools/builtin_tool/providers/apo_select/tools/cluster_total_memory_capacity.yaml

@@ -0,0 +1,53 @@
+identity:
+  name: 集群总可用内存字节数
+  author: APO
+  label:
+    en_US: Total available memory in bytes
+    zh_Hans: 集群总可用内存字节数
+description:
+  human:
+    en_US: Total available memory in bytes
+    zh_Hans: 集群总可用内存字节数
+  llm: Total available memory in bytes
+display:
+  type: metric
+  title: 集群总览 - 总览 - 内存使用量 - Total
+  unit: "bytes"
+parameters:
+  - name: cluster
+    type: string
+    required: False
+    label:
+      en_US: Cluster name
+      zh_Hans: 集群名称
+    human_description:
+      en_US: Cluster name
+      zh_Hans: 集群名称
+    llm_description: Cluster 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

api/core/tools/builtin_tool/providers/apo_select/tools/container_cpu.yaml

@@ -18,7 +18,7 @@ description:
 parameters:
   - name: pod
     type: string
-    required: true
+    required: false
     label:
       en_US: pod
       zh_Hans: pod
@@ -31,7 +31,7 @@ parameters:
     form: llm
   - name: namespace
     type: string
-    required: true
+    required: false
     label:
       en_US: namespace
       zh_Hans: namespace

api/core/tools/builtin_tool/providers/apo_select/tools/container_cpu_cfs.yaml

@@ -18,7 +18,7 @@ description:
 parameters:
   - name: pod
     type: string
-    required: true
+    required: false
     label:
       en_US: pod
       zh_Hans: pod
@@ -31,7 +31,7 @@ parameters:
     form: llm
   - name: namespace
     type: string
-    required: true
+    required: false
     label:
       en_US: namespace
       zh_Hans: namespace

api/core/tools/builtin_tool/providers/apo_select/tools/container_cpu_throttle_containerd_seconds.py

@@ -0,0 +1,48 @@
+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 ContainerCpuThrottleContainerdSecondsTool(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]:
+        cadvisor_job_name = tool_parameters.get('cadvisor_job_name', '.*')
+        namespace = tool_parameters.get('namespace', '.*')
+        pod = tool_parameters.get('pod', '.*')
+        start_time = tool_parameters.get("startTime")
+        end_time = tool_parameters.get("endTime")
+        params = {
+            'metricName': '基础设施情况 - 容器CPU - 容器CPU节流时间 - Containerd',
+            'params': {
+                'cadvisor_job_name': cadvisor_job_name,
+                'namespace': namespace,
+                'pod': pod
+            },
+            '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)

api/core/tools/builtin_tool/providers/apo_select/tools/container_cpu_throttle_containerd_seconds.yaml

@@ -0,0 +1,75 @@
+identity:
+  name: 容器CPU节流时长(使用Containerd容器运行时,按容器和Pod统计)
+  author: APO
+  label:
+    en_US: Container CPU throttling time (Containerd runtime, aggregated by container and Pod)
+    zh_Hans: 容器CPU节流时长(使用Containerd容器运行时,按容器和Pod统计)
+description:
+  human:
+    en_US: Container CPU throttling time (Containerd runtime, aggregated by container and Pod)
+    zh_Hans: 容器CPU节流时长(使用Containerd容器运行时,按容器和Pod统计)
+  llm: Container CPU throttling time (Containerd runtime, aggregated by container and Pod)
+display:
+  type: metric
+  title: 基础设施情况 - 容器CPU - 容器CPU节流时间 - Containerd
+  unit: "s"
+parameters:
+  - name: cadvisor_job_name
+    type: string
+    required: False
+    label:
+      en_US: cAdvisor job name
+      zh_Hans: cAdvisor任务名称
+    human_description:
+      en_US: cAdvisor job name
+      zh_Hans: cAdvisor任务名称
+    llm_description: cAdvisor job name
+    form: llm
+  - name: namespace
+    type: string
+    required: False
+    label:
+      en_US: Namespace
+      zh_Hans: 命名空间
+    human_description:
+      en_US: Namespace
+      zh_Hans: 命名空间
+    llm_description: Namespace
+    form: llm
+  - name: pod
+    type: string
+    required: False
+    label:
+      en_US: Pod name
+      zh_Hans: Pod名称
+    human_description:
+      en_US: Pod name
+      zh_Hans: Pod名称
+    llm_description: Pod 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

api/core/tools/builtin_tool/providers/apo_select/tools/container_cpu_throttle_docker_seconds.py

@@ -0,0 +1,48 @@
+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 ContainerCpuThrottleDockerSecondsTool(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]:
+        cadvisor_job_name = tool_parameters.get('cadvisor_job_name', '.*')
+        namespace = tool_parameters.get('namespace', '.*')
+        pod = tool_parameters.get('pod', '.*')
+        start_time = tool_parameters.get("startTime")
+        end_time = tool_parameters.get("endTime")
+        params = {
+            'metricName': '基础设施情况 - 容器CPU - 容器CPU节流时间 - Docker',
+            'params': {
+                'cadvisor_job_name': cadvisor_job_name,
+                'namespace': namespace,
+                'pod': pod
+            },
+            '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)

api/core/tools/builtin_tool/providers/apo_select/tools/container_cpu_throttle_docker_seconds.yaml

@@ -0,0 +1,75 @@
+identity:
+  name: 容器CPU节流时长(使用Docker容器运行时,按Pod统计)
+  author: APO
+  label:
+    en_US: Container CPU throttling time (Docker runtime, aggregated by Pod)
+    zh_Hans: 容器CPU节流时长(使用Docker容器运行时,按Pod统计)
+description:
+  human:
+    en_US: Container CPU throttling time (Docker runtime, aggregated by Pod)
+    zh_Hans: 容器CPU节流时长(使用Docker容器运行时,按Pod统计)
+  llm: Container CPU throttling time (Docker runtime, aggregated by Pod)
+display:
+  type: metric
+  title: 基础设施情况 - 容器CPU - 容器CPU节流时间 - Docker
+  unit: "s"
+parameters:
+  - name: cadvisor_job_name
+    type: string
+    required: False
+    label:
+      en_US: cAdvisor job name
+      zh_Hans: cAdvisor任务名称
+    human_description:
+      en_US: cAdvisor job name
+      zh_Hans: cAdvisor任务名称
+    llm_description: cAdvisor job name
+    form: llm
+  - name: namespace
+    type: string
+    required: False
+    label:
+      en_US: Namespace
+      zh_Hans: 命名空间
+    human_description:
+      en_US: Namespace
+      zh_Hans: 命名空间
+    llm_description: Namespace
+    form: llm
+  - name: pod
+    type: string
+    required: False
+    label:
+      en_US: Pod name
+      zh_Hans: Pod名称
+    human_description:
+      en_US: Pod name
+      zh_Hans: Pod名称
+    llm_description: Pod 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

api/core/tools/builtin_tool/providers/apo_select/tools/container_cpu_throttling_containerd_seconds.py

@@ -0,0 +1,48 @@
+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 ContainerCpuThrottlingContainerdSecondsTool(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]:
+        cadvisor_job_name = tool_parameters.get('cadvisor_job_name', '.*')
+        namespace = tool_parameters.get('namespace', '.*')
+        pod = tool_parameters.get('pod', '.*')
+        start_time = tool_parameters.get("startTime")
+        end_time = tool_parameters.get("endTime")
+        params = {
+            'metricName': '基础设施情况 - 容器CPU - 容器CPU节流时间 - Containerd',
+            'params': {
+                'cadvisor_job_name': cadvisor_job_name,
+                'namespace': namespace,
+                'pod': pod
+            },
+            '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)

api/core/tools/builtin_tool/providers/apo_select/tools/container_cpu_throttling_containerd_seconds.yaml

@@ -0,0 +1,75 @@
+identity:
+  name: 容器CPU节流时长(使用Containerd容器运行时,按容器和Pod统计)
+  author: APO
+  label:
+    en_US: Container CPU throttling duration (Containerd runtime, by container and Pod)
+    zh_Hans: 容器CPU节流时长(使用Containerd容器运行时,按容器和Pod统计)
+description:
+  human:
+    en_US: Container CPU throttling duration (Containerd runtime, by container and Pod)
+    zh_Hans: 容器CPU节流时长(使用Containerd容器运行时,按容器和Pod统计)
+  llm: Container CPU throttling duration (Containerd runtime, by container and Pod)
+display:
+  type: metric
+  title: 基础设施情况 - 容器CPU - 容器CPU节流时间 - Containerd
+  unit: "s"
+parameters:
+  - name: cadvisor_job_name
+    type: string
+    required: False
+    label:
+      en_US: cAdvisor job name
+      zh_Hans: cAdvisor任务名称
+    human_description:
+      en_US: cAdvisor job name
+      zh_Hans: cAdvisor任务名称
+    llm_description: cAdvisor job name
+    form: llm
+  - name: namespace
+    type: string
+    required: False
+    label:
+      en_US: Namespace
+      zh_Hans: 命名空间
+    human_description:
+      en_US: Namespace
+      zh_Hans: 命名空间
+    llm_description: Namespace
+    form: llm
+  - name: pod
+    type: string
+    required: False
+    label:
+      en_US: Pod name
+      zh_Hans: Pod名称
+    human_description:
+      en_US: Pod name
+      zh_Hans: Pod名称
+    llm_description: Pod 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

api/core/tools/builtin_tool/providers/apo_select/tools/container_cpu_usage_containerd.py

@@ -0,0 +1,48 @@
+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 ContainerCpuUsageContainerdTool(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]:
+        cadvisor_job_name = tool_parameters.get('cadvisor_job_name')
+        namespace = tool_parameters.get('namespace')
+        pod = tool_parameters.get('pod')
+        start_time = tool_parameters.get("startTime")
+        end_time = tool_parameters.get("endTime")
+        params = {
+            'metricName': '基础设施情况 - 容器CPU - 容器CPU使用率 - Containerd',
+            'params': {
+                **({'cadvisor_job_name': cadvisor_job_name} if cadvisor_job_name else {}),
+                **({'namespace': namespace} if namespace else {}),
+                **({'pod': pod} if pod else {})
+            },
+            '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)

api/core/tools/builtin_tool/providers/apo_select/tools/container_cpu_usage_containerd.yaml

@@ -0,0 +1,75 @@
+identity:
+  name: 容器CPU使用率(使用Containerd容器运行时,按容器和Pod统计)
+  author: APO
+  label:
+    en_US: Container CPU usage rate (Containerd runtime, aggregated by container and Pod)
+    zh_Hans: 容器CPU使用率(使用Containerd容器运行时,按容器和Pod统计)
+description:
+  human:
+    en_US: Container CPU usage rate (Containerd runtime, aggregated by container and Pod)
+    zh_Hans: 容器CPU使用率(使用Containerd容器运行时,按容器和Pod统计)
+  llm: Container CPU usage rate (Containerd runtime, aggregated by container and Pod)
+display:
+  type: metric
+  title: 基础设施情况 - 容器CPU - 容器CPU使用率 - Containerd
+  unit: "core"
+parameters:
+  - name: cadvisor_job_name
+    type: string
+    required: False
+    label:
+      en_US: cAdvisor job name
+      zh_Hans: cAdvisor任务名称
+    human_description:
+      en_US: cAdvisor job name
+      zh_Hans: cAdvisor任务名称
+    llm_description: cAdvisor job name
+    form: llm
+  - name: namespace
+    type: string
+    required: False
+    label:
+      en_US: Namespace
+      zh_Hans: 命名空间
+    human_description:
+      en_US: Namespace
+      zh_Hans: 命名空间
+    llm_description: Namespace
+    form: llm
+  - name: pod
+    type: string
+    required: False
+    label:
+      en_US: Pod name
+      zh_Hans: Pod名称
+    human_description:
+      en_US: Pod name
+      zh_Hans: Pod名称
+    llm_description: Pod 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

api/core/tools/builtin_tool/providers/apo_select/tools/container_cpu_usage_docker.py

@@ -0,0 +1,48 @@
+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 ContainerCpuUsageDockerTool(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]:
+        cadvisor_job_name = tool_parameters.get('cadvisor_job_name', '.*')
+        namespace = tool_parameters.get('namespace', '.*')
+        pod = tool_parameters.get('pod', '.*')
+        start_time = tool_parameters.get("startTime")
+        end_time = tool_parameters.get("endTime")
+        params = {
+            'metricName': '基础设施情况 - 容器CPU - 容器CPU使用率 - Docker',
+            'params': {
+                'cadvisor_job_name': cadvisor_job_name,
+                'namespace': namespace,
+                'pod': pod
+            },
+            '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)

api/core/tools/builtin_tool/providers/apo_select/tools/container_cpu_usage_docker.yaml

@@ -0,0 +1,75 @@
+identity:
+  name: 容器CPU使用率(使用Docker容器运行时,按Pod统计)
+  author: APO
+  label:
+    en_US: Container CPU usage rate (Docker runtime, aggregated by Pod)
+    zh_Hans: 容器CPU使用率(使用Docker容器运行时,按Pod统计)
+description:
+  human:
+    en_US: Container CPU usage rate (Docker runtime, aggregated by Pod)
+    zh_Hans: 容器CPU使用率(使用Docker容器运行时,按Pod统计)
+  llm: Container CPU usage rate (Docker runtime, aggregated by Pod)
+display:
+  type: metric
+  title: 基础设施情况 - 容器CPU - 容器CPU使用率 - Docker
+  unit: "core"
+parameters:
+  - name: cadvisor_job_name
+    type: string
+    required: False
+    label:
+      en_US: cAdvisor job name
+      zh_Hans: cAdvisor任务名称
+    human_description:
+      en_US: cAdvisor job name
+      zh_Hans: cAdvisor任务名称
+    llm_description: cAdvisor job name
+    form: llm
+  - name: namespace
+    type: string
+    required: False
+    label:
+      en_US: Namespace
+      zh_Hans: 命名空间
+    human_description:
+      en_US: Namespace
+      zh_Hans: 命名空间
+    llm_description: Namespace
+    form: llm
+  - name: pod
+    type: string
+    required: False
+    label:
+      en_US: Pod name
+      zh_Hans: Pod名称
+    human_description:
+      en_US: Pod name
+      zh_Hans: Pod名称
+    llm_description: Pod 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

api/core/tools/builtin_tool/providers/apo_select/tools/container_cpu_utilization_containerd.py

@@ -0,0 +1,48 @@
+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 ContainerCpuUtilizationContainerdTool(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]:
+        cadvisor_job_name = tool_parameters.get('cadvisor_job_name', '.*')
+        namespace = tool_parameters.get('namespace', '.*')
+        pod = tool_parameters.get('pod', '.*')
+        start_time = tool_parameters.get("startTime")
+        end_time = tool_parameters.get("endTime")
+        params = {
+            'metricName': '基础设施情况 - 容器CPU - 容器CPU使用率 - Containerd',
+            'params': {
+                'cadvisor_job_name': cadvisor_job_name,
+                'namespace': namespace,
+                'pod': pod
+            },
+            '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)

api/core/tools/builtin_tool/providers/apo_select/tools/container_cpu_utilization_containerd.yaml

@@ -0,0 +1,75 @@
+identity:
+  name: 容器CPU使用率(使用Containerd容器运行时,按容器和Pod统计)
+  author: APO
+  label:
+    en_US: Container CPU utilization rate (Containerd runtime, by container and Pod)
+    zh_Hans: 容器CPU使用率(使用Containerd容器运行时,按容器和Pod统计)
+description:
+  human:
+    en_US: Container CPU utilization rate (Containerd runtime, by container and Pod)
+    zh_Hans: 容器CPU使用率(使用Containerd容器运行时,按容器和Pod统计)
+  llm: Container CPU utilization rate (Containerd runtime, by container and Pod)
+display:
+  type: metric
+  title: 基础设施情况 - 容器CPU - 容器CPU使用率 - Containerd
+  unit: "core"
+parameters:
+  - name: cadvisor_job_name
+    type: string
+    required: False
+    label:
+      en_US: cAdvisor job name
+      zh_Hans: cAdvisor任务名称
+    human_description:
+      en_US: cAdvisor job name
+      zh_Hans: cAdvisor任务名称
+    llm_description: cAdvisor job name
+    form: llm
+  - name: namespace
+    type: string
+    required: False
+    label:
+      en_US: Namespace
+      zh_Hans: 命名空间
+    human_description:
+      en_US: Namespace
+      zh_Hans: 命名空间
+    llm_description: Namespace
+    form: llm
+  - name: pod
+    type: string
+    required: False
+    label:
+      en_US: Pod name
+      zh_Hans: Pod名称
+    human_description:
+      en_US: Pod name
+      zh_Hans: Pod名称
+    llm_description: Pod 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

api/core/tools/builtin_tool/providers/apo_select/tools/container_disk_read_bytes_docker.py

@@ -0,0 +1,48 @@
+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 ContainerDiskReadBytesDockerTool(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]:
+        cadvisor_job_name = tool_parameters.get('cadvisor_job_name', '.*')
+        namespace = tool_parameters.get('namespace', '.*')
+        pod = tool_parameters.get('pod', '.*')
+        start_time = tool_parameters.get("startTime")
+        end_time = tool_parameters.get("endTime")
+        params = {
+            'metricName': '基础设施情况 - 容器磁盘 - 读写字节数 /s - Read',
+            'params': {
+                'cadvisor_job_name': cadvisor_job_name,
+                'namespace': namespace,
+                'pod': pod
+            },
+            '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)

api/core/tools/builtin_tool/providers/apo_select/tools/container_disk_read_bytes_docker.yaml

@@ -0,0 +1,75 @@
+identity:
+  name: 容器磁盘读取字节数每秒(使用Docker,按Pod统计)
+  author: APO
+  label:
+    en_US: Container disk read bytes per second (Docker runtime, aggregated by Pod)
+    zh_Hans: 容器磁盘读取字节数每秒(使用Docker,按Pod统计)
+description:
+  human:
+    en_US: Container disk read bytes per second (Docker runtime, aggregated by Pod)
+    zh_Hans: 容器磁盘读取字节数每秒(使用Docker,按Pod统计)
+  llm: Container disk read bytes per second (Docker runtime, aggregated by Pod)
+display:
+  type: metric
+  title: 基础设施情况 - 容器磁盘 - 读写字节数 /s - Read
+  unit: "bytes"
+parameters:
+  - name: cadvisor_job_name
+    type: string
+    required: False
+    label:
+      en_US: cAdvisor job name
+      zh_Hans: cAdvisor任务名称
+    human_description:
+      en_US: cAdvisor job name
+      zh_Hans: cAdvisor任务名称
+    llm_description: cAdvisor job name
+    form: llm
+  - name: namespace
+    type: string
+    required: False
+    label:
+      en_US: Namespace
+      zh_Hans: 命名空间
+    human_description:
+      en_US: Namespace
+      zh_Hans: 命名空间
+    llm_description: Namespace
+    form: llm
+  - name: pod
+    type: string
+    required: False
+    label:
+      en_US: Pod name
+      zh_Hans: Pod名称
+    human_description:
+      en_US: Pod name
+      zh_Hans: Pod名称
+    llm_description: Pod 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

api/core/tools/builtin_tool/providers/apo_select/tools/container_disk_read_ops_docker.py

@@ -0,0 +1,48 @@
+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 ContainerDiskReadOpsDockerTool(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]:
+        cadvisor_job_name = tool_parameters.get('cadvisor_job_name', '.*')
+        namespace = tool_parameters.get('namespace', '.*')
+        pod = tool_parameters.get('pod', '.*')
+        start_time = tool_parameters.get("startTime")
+        end_time = tool_parameters.get("endTime")
+        params = {
+            'metricName': '基础设施情况 - 容器磁盘 - 读写次数 /s - Read',
+            'params': {
+                'cadvisor_job_name': cadvisor_job_name,
+                'namespace': namespace,
+                'pod': pod
+            },
+            '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)

api/core/tools/builtin_tool/providers/apo_select/tools/container_disk_read_ops_docker.yaml

@@ -0,0 +1,75 @@
+identity:
+  name: 容器磁盘读取次数每秒(使用Docker,按Pod统计)
+  author: APO
+  label:
+    en_US: Container disk read operations per second (Docker runtime, aggregated by Pod)
+    zh_Hans: 容器磁盘读取次数每秒(使用Docker,按Pod统计)
+description:
+  human:
+    en_US: Container disk read operations per second (Docker runtime, aggregated by Pod)
+    zh_Hans: 容器磁盘读取次数每秒(使用Docker,按Pod统计)
+  llm: Container disk read operations per second (Docker runtime, aggregated by Pod)
+display:
+  type: metric
+  title: 基础设施情况 - 容器磁盘 - 读写次数 /s - Read
+  unit: "ops"
+parameters:
+  - name: cadvisor_job_name
+    type: string
+    required: False
+    label:
+      en_US: cAdvisor job name
+      zh_Hans: cAdvisor任务名称
+    human_description:
+      en_US: cAdvisor job name
+      zh_Hans: cAdvisor任务名称
+    llm_description: cAdvisor job name
+    form: llm
+  - name: namespace
+    type: string
+    required: False
+    label:
+      en_US: Namespace
+      zh_Hans: 命名空间
+    human_description:
+      en_US: Namespace
+      zh_Hans: 命名空间
+    llm_description: Namespace
+    form: llm
+  - name: pod
+    type: string
+    required: False
+    label:
+      en_US: Pod name
+      zh_Hans: Pod名称
+    human_description:
+      en_US: Pod name
+      zh_Hans: Pod名称
+    llm_description: Pod 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

api/core/tools/builtin_tool/providers/apo_select/tools/container_disk_read_time_containerd_seconds.py

@@ -0,0 +1,48 @@
+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 ContainerDiskReadTimeContainerdSecondsTool(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]:
+        cadvisor_job_name = tool_parameters.get('cadvisor_job_name', '.*')
+        namespace = tool_parameters.get('namespace', '.*')
+        pod = tool_parameters.get('pod', '.*')
+        start_time = tool_parameters.get("startTime")
+        end_time = tool_parameters.get("endTime")
+        params = {
+            'metricName': '基础设施情况 - 容器磁盘 - 读写花费时间 /s - Read',
+            'params': {
+                'cadvisor_job_name': cadvisor_job_name,
+                'namespace': namespace,
+                'pod': pod
+            },
+            '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)

api/core/tools/builtin_tool/providers/apo_select/tools/container_disk_read_time_containerd_seconds.yaml

@@ -0,0 +1,75 @@
+identity:
+  name: 容器磁盘读取耗时每秒(使用Containerd,按Pod和容器统计)
+  author: APO
+  label:
+    en_US: Container disk read time per second (Containerd runtime, aggregated by container and Pod)
+    zh_Hans: 容器磁盘读取耗时每秒(使用Containerd,按Pod和容器统计)
+description:
+  human:
+    en_US: Container disk read time per second (Containerd runtime, aggregated by container and Pod)
+    zh_Hans: 容器磁盘读取耗时每秒(使用Containerd,按Pod和容器统计)
+  llm: Container disk read time per second (Containerd runtime, aggregated by container and Pod)
+display:
+  type: metric
+  title: 基础设施情况 - 容器磁盘 - 读写花费时间 /s - Read
+  unit: "s"
+parameters:
+  - name: cadvisor_job_name
+    type: string
+    required: False
+    label:
+      en_US: cAdvisor job name
+      zh_Hans: cAdvisor任务名称
+    human_description:
+      en_US: cAdvisor job name
+      zh_Hans: cAdvisor任务名称
+    llm_description: cAdvisor job name
+    form: llm
+  - name: namespace
+    type: string
+    required: False
+    label:
+      en_US: Namespace
+      zh_Hans: 命名空间
+    human_description:
+      en_US: Namespace
+      zh_Hans: 命名空间
+    llm_description: Namespace
+    form: llm
+  - name: pod
+    type: string
+    required: False
+    label:
+      en_US: Pod name
+      zh_Hans: Pod名称
+    human_description:
+      en_US: Pod name
+      zh_Hans: Pod名称
+    llm_description: Pod 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

api/core/tools/builtin_tool/providers/apo_select/tools/container_disk_time.yaml

@@ -18,7 +18,7 @@ description:
 parameters:
   - name: pod
     type: string
-    required: true
+    required: false
     label:
       en_US: pod
       zh_Hans: pod
@@ -31,7 +31,7 @@ parameters:
     form: llm
   - name: namespace
     type: string
-    required: true
+    required: false
     label:
       en_US: namespace
       zh_Hans: namespace

api/core/tools/builtin_tool/providers/apo_select/tools/container_disk_write_bytes_docker.py

@@ -0,0 +1,48 @@
+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 ContainerDiskWriteBytesDockerTool(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]:
+        cadvisor_job_name = tool_parameters.get('cadvisor_job_name', '.*')
+        namespace = tool_parameters.get('namespace', '.*')
+        pod = tool_parameters.get('pod', '.*')
+        start_time = tool_parameters.get("startTime")
+        end_time = tool_parameters.get("endTime")
+        params = {
+            'metricName': '基础设施情况 - 容器磁盘 - 读写字节数 /s - Write',
+            'params': {
+                'cadvisor_job_name': cadvisor_job_name,
+                'namespace': namespace,
+                'pod': pod
+            },
+            '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)

api/core/tools/builtin_tool/providers/apo_select/tools/container_disk_write_bytes_docker.yaml

@@ -0,0 +1,75 @@
+identity:
+  name: 容器磁盘写入字节数每秒(使用Docker,按Pod统计)
+  author: APO
+  label:
+    en_US: Container disk write bytes per second (Docker runtime, aggregated by Pod)
+    zh_Hans: 容器磁盘写入字节数每秒(使用Docker,按Pod统计)
+description:
+  human:
+    en_US: Container disk write bytes per second (Docker runtime, aggregated by Pod)
+    zh_Hans: 容器磁盘写入字节数每秒(使用Docker,按Pod统计)
+  llm: Container disk write bytes per second (Docker runtime, aggregated by Pod)
+display:
+  type: metric
+  title: 基础设施情况 - 容器磁盘 - 读写字节数 /s - Write
+  unit: "bytes"
+parameters:
+  - name: cadvisor_job_name
+    type: string
+    required: False
+    label:
+      en_US: cAdvisor job name
+      zh_Hans: cAdvisor任务名称
+    human_description:
+      en_US: cAdvisor job name
+      zh_Hans: cAdvisor任务名称
+    llm_description: cAdvisor job name
+    form: llm
+  - name: namespace
+    type: string
+    required: False
+    label:
+      en_US: Namespace
+      zh_Hans: 命名空间
+    human_description:
+      en_US: Namespace
+      zh_Hans: 命名空间
+    llm_description: Namespace
+    form: llm
+  - name: pod
+    type: string
+    required: False
+    label:
+      en_US: Pod name
+      zh_Hans: Pod名称
+    human_description:
+      en_US: Pod name
+      zh_Hans: Pod名称
+    llm_description: Pod 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

api/core/tools/builtin_tool/providers/apo_select/tools/container_disk_write_ops_docker.py

@@ -0,0 +1,48 @@
+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 ContainerDiskWriteOpsDockerTool(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]:
+        cadvisor_job_name = tool_parameters.get('cadvisor_job_name', '.*')
+        namespace = tool_parameters.get('namespace', '.*')
+        pod = tool_parameters.get('pod', '.*')
+        start_time = tool_parameters.get("startTime")
+        end_time = tool_parameters.get("endTime")
+        params = {
+            'metricName': '基础设施情况 - 容器磁盘 - 读写次数 /s - Write',
+            'params': {
+                'cadvisor_job_name': cadvisor_job_name,
+                'namespace': namespace,
+                'pod': pod
+            },
+            '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)

api/core/tools/builtin_tool/providers/apo_select/tools/container_disk_write_ops_docker.yaml

@@ -0,0 +1,75 @@
+identity:
+  name: 容器磁盘写入次数每秒(使用Docker,按Pod统计)
+  author: APO
+  label:
+    en_US: Container disk write operations per second (Docker runtime, aggregated by Pod)
+    zh_Hans: 容器磁盘写入次数每秒(使用Docker,按Pod统计)
+description:
+  human:
+    en_US: Container disk write operations per second (Docker runtime, aggregated by Pod)
+    zh_Hans: 容器磁盘写入次数每秒(使用Docker,按Pod统计)
+  llm: Container disk write operations per second (Docker runtime, aggregated by Pod)
+display:
+  type: metric
+  title: 基础设施情况 - 容器磁盘 - 读写次数 /s - Write
+  unit: "ops"
+parameters:
+  - name: cadvisor_job_name
+    type: string
+    required: False
+    label:
+      en_US: cAdvisor job name
+      zh_Hans: cAdvisor任务名称
+    human_description:
+      en_US: cAdvisor job name
+      zh_Hans: cAdvisor任务名称
+    llm_description: cAdvisor job name
+    form: llm
+  - name: namespace
+    type: string
+    required: False
+    label:
+      en_US: Namespace
+      zh_Hans: 命名空间
+    human_description:
+      en_US: Namespace
+      zh_Hans: 命名空间
+    llm_description: Namespace
+    form: llm
+  - name: pod
+    type: string
+    required: False
+    label:
+      en_US: Pod name
+      zh_Hans: Pod名称
+    human_description:
+      en_US: Pod name
+      zh_Hans: Pod名称
+    llm_description: Pod 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

api/core/tools/builtin_tool/providers/apo_select/tools/container_disk_write_time_containerd_seconds.py

@@ -0,0 +1,48 @@
+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 ContainerDiskWriteTimeContainerdSecondsTool(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]:
+        cadvisor_job_name = tool_parameters.get('cadvisor_job_name', '.*')
+        namespace = tool_parameters.get('namespace', '.*')
+        pod = tool_parameters.get('pod', '.*')
+        start_time = tool_parameters.get("startTime")
+        end_time = tool_parameters.get("endTime")
+        params = {
+            'metricName': '基础设施情况 - 容器磁盘 - 读写花费时间 /s - Write',
+            'params': {
+                'cadvisor_job_name': cadvisor_job_name,
+                'namespace': namespace,
+                'pod': pod
+            },
+            '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)

api/core/tools/builtin_tool/providers/apo_select/tools/container_disk_write_time_containerd_seconds.yaml

@@ -0,0 +1,75 @@
+identity:
+  name: 容器磁盘写入耗时每秒(使用Containerd,按Pod和容器统计)
+  author: APO
+  label:
+    en_US: Container disk write time per second (Containerd runtime, aggregated by container and Pod)
+    zh_Hans: 容器磁盘写入耗时每秒(使用Containerd,按Pod和容器统计)
+description:
+  human:
+    en_US: Container disk write time per second (Containerd runtime, aggregated by container and Pod)
+    zh_Hans: 容器磁盘写入耗时每秒(使用Containerd,按Pod和容器统计)
+  llm: Container disk write time per second (Containerd runtime, aggregated by container and Pod)
+display:
+  type: metric
+  title: 基础设施情况 - 容器磁盘 - 读写花费时间 /s - Write
+  unit: "s"
+parameters:
+  - name: cadvisor_job_name
+    type: string
+    required: False
+    label:
+      en_US: cAdvisor job name
+      zh_Hans: cAdvisor任务名称
+    human_description:
+      en_US: cAdvisor job name
+      zh_Hans: cAdvisor任务名称
+    llm_description: cAdvisor job name
+    form: llm
+  - name: namespace
+    type: string
+    required: False
+    label:
+      en_US: Namespace
+      zh_Hans: 命名空间
+    human_description:
+      en_US: Namespace
+      zh_Hans: 命名空间
+    llm_description: Namespace
+    form: llm
+  - name: pod
+    type: string
+    required: False
+    label:
+      en_US: Pod name
+      zh_Hans: Pod名称
+    human_description:
+      en_US: Pod name
+      zh_Hans: Pod名称
+    llm_description: Pod 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

api/core/tools/builtin_tool/providers/apo_select/tools/container_memory_usage_containerd_bytes.py

@@ -0,0 +1,48 @@
+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 ContainerMemoryUsageContainerdBytesTool(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]:
+        cadvisor_job_name = tool_parameters.get('cadvisor_job_name', '.*')
+        namespace = tool_parameters.get('namespace', '.*')
+        pod = tool_parameters.get('pod', '.*')
+        start_time = tool_parameters.get("startTime")
+        end_time = tool_parameters.get("endTime")
+        params = {
+            'metricName': '基础设施情况 - 容器内存 - 容器内存使用率 - Containerd',
+            'params': {
+                'cadvisor_job_name': cadvisor_job_name,
+                'namespace': namespace,
+                'pod': pod
+            },
+            '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)

api/core/tools/builtin_tool/providers/apo_select/tools/container_memory_usage_containerd_bytes.yaml

@@ -0,0 +1,75 @@
+identity:
+  name: 容器内存使用字节数(使用Containerd容器运行时,按容器和Pod统计)
+  author: APO
+  label:
+    en_US: Container memory usage in bytes (Containerd runtime, aggregated by container and Pod)
+    zh_Hans: 容器内存使用字节数(使用Containerd容器运行时,按容器和Pod统计)
+description:
+  human:
+    en_US: Container memory usage in bytes (Containerd runtime, aggregated by container and Pod)
+    zh_Hans: 容器内存使用字节数(使用Containerd容器运行时,按容器和Pod统计)
+  llm: Container memory usage in bytes (Containerd runtime, aggregated by container and Pod)
+display:
+  type: metric
+  title: 基础设施情况 - 容器内存 - 容器内存使用率 - Containerd
+  unit: "bytes"
+parameters:
+  - name: cadvisor_job_name
+    type: string
+    required: False
+    label:
+      en_US: cAdvisor job name
+      zh_Hans: cAdvisor任务名称
+    human_description:
+      en_US: cAdvisor job name
+      zh_Hans: cAdvisor任务名称
+    llm_description: cAdvisor job name
+    form: llm
+  - name: namespace
+    type: string
+    required: False
+    label:
+      en_US: Namespace
+      zh_Hans: 命名空间
+    human_description:
+      en_US: Namespace
+      zh_Hans: 命名空间
+    llm_description: Namespace
+    form: llm
+  - name: pod
+    type: string
+    required: False
+    label:
+      en_US: Pod name
+      zh_Hans: Pod名称
+    human_description:
+      en_US: Pod name
+      zh_Hans: Pod名称
+    llm_description: Pod 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

api/core/tools/builtin_tool/providers/apo_select/tools/container_memory_usage_docker_bytes.py

@@ -0,0 +1,48 @@
+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 ContainerMemoryUsageDockerBytesTool(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]:
+        cadvisor_job_name = tool_parameters.get('cadvisor_job_name', '.*')
+        namespace = tool_parameters.get('namespace', '.*')
+        pod = tool_parameters.get('pod', '.*')
+        start_time = tool_parameters.get("startTime")
+        end_time = tool_parameters.get("endTime")
+        params = {
+            'metricName': '基础设施情况 - 容器内存 - 容器内存使用率 - Docker',
+            'params': {
+                'cadvisor_job_name': cadvisor_job_name,
+                'namespace': namespace,
+                'pod': pod
+            },
+            '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)

api/core/tools/builtin_tool/providers/apo_select/tools/container_memory_usage_docker_bytes.yaml

@@ -0,0 +1,75 @@
+identity:
+  name: 容器内存使用字节数(使用Docker容器运行时,按Pod统计)
+  author: APO
+  label:
+    en_US: Container memory usage in bytes (Docker runtime, aggregated by Pod)
+    zh_Hans: 容器内存使用字节数(使用Docker容器运行时,按Pod统计)
+description:
+  human:
+    en_US: Container memory usage in bytes (Docker runtime, aggregated by Pod)
+    zh_Hans: 容器内存使用字节数(使用Docker容器运行时,按Pod统计)
+  llm: Container memory usage in bytes (Docker runtime, aggregated by Pod)
+display:
+  type: metric
+  title: 基础设施情况 - 容器内存 - 容器内存使用率 - Docker
+  unit: "bytes"
+parameters:
+  - name: cadvisor_job_name
+    type: string
+    required: False
+    label:
+      en_US: cAdvisor job name
+      zh_Hans: cAdvisor任务名称
+    human_description:
+      en_US: cAdvisor job name
+      zh_Hans: cAdvisor任务名称
+    llm_description: cAdvisor job name
+    form: llm
+  - name: namespace
+    type: string
+    required: False
+    label:
+      en_US: Namespace
+      zh_Hans: 命名空间
+    human_description:
+      en_US: Namespace
+      zh_Hans: 命名空间
+    llm_description: Namespace
+    form: llm
+  - name: pod
+    type: string
+    required: False
+    label:
+      en_US: Pod name
+      zh_Hans: Pod名称
+    human_description:
+      en_US: Pod name
+      zh_Hans: Pod名称
+    llm_description: Pod 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

api/core/tools/builtin_tool/providers/apo_select/tools/container_rss.yaml

@@ -18,7 +18,7 @@ display:
 parameters:
   - name: pod
     type: string
-    required: true
+    required: false
     label:
       en_US: pod
       zh_Hans: pod
@@ -31,7 +31,7 @@ parameters:
     form: llm
   - name: namespace
     type: string
-    required: true
+    required: false
     label:
       en_US: namespace
       zh_Hans: namespace

api/core/tools/builtin_tool/providers/apo_select/tools/container_rtt.yaml

@@ -18,7 +18,7 @@ display:
 parameters:
   - name: pod
     type: string
-    required: true
+    required: false
     label:
       en_US: pod
       zh_Hans: pod
@@ -31,7 +31,7 @@ parameters:
     form: llm
   - name: namespace
     type: string
-    required: true
+    required: false
     label:
       en_US: namespace
       zh_Hans: namespace

api/core/tools/builtin_tool/providers/apo_select/tools/host_core_num.py

@@ -19,15 +19,15 @@ class HostCoreNumTool(BuiltinTool):
         app_id: Optional[str] = None,
         message_id: Optional[str] = None,
     ) -> Generator[ToolInvokeMessage, None, None]:
-        node = tool_parameters.get("node")
+        node = tool_parameters.get("node", '.*')
-        job = tool_parameters.get("job")
+        job = tool_parameters.get("job", '.*')
         start_time = tool_parameters.get("startTime")
         end_time = tool_parameters.get("endTime")
         params = {
           'metricName': "宿主机监控指标 - Quick CPU / Mem / Disk - CPU Cores",
           'params': {
             'node': node,
-            **({'job': job} if job else {})
+            'job': job
           },
           'startTime': start_time,
           'endTime': end_time,

api/core/tools/builtin_tool/providers/apo_select/tools/host_core_num.yaml

@@ -31,7 +31,7 @@ parameters:
     form: llm
   - name: node
     type: string
-    required: true
+    required: false
     label:
       en_US: Host Node
       zh_Hans: 宿主机节点

api/core/tools/builtin_tool/providers/apo_select/tools/host_cpu_core_usage.py

@@ -19,14 +19,15 @@ class HostCpuCoreUsageTool(BuiltinTool):
         app_id: Optional[str] = None,
         message_id: Optional[str] = None,
     ) -> Generator[ToolInvokeMessage, None, None]:
-        node = tool_parameters.get("node")
+        node = tool_parameters.get("node", '.*')
-        job = tool_parameters.get("job")
+        job = tool_parameters.get("job", '.*')
         start_time = tool_parameters.get("startTime")
         end_time = tool_parameters.get("endTime")
         params = {
           'metricName': "宿主机监控指标 - Basic CPU / Mem / Net / Disk - CPU Basic - CPU Usage",
           'params': {
             'node': node,
+            'job': job
           },
           'startTime': start_time,
           'endTime': end_time,

api/core/tools/builtin_tool/providers/apo_select/tools/host_cpu_core_usage.yaml

@@ -31,7 +31,7 @@ parameters:
     form: llm
   - name: node
     type: string
-    required: true
+    required: false
     label:
       en_US: Host Node
       zh_Hans: 宿主机节点

api/core/tools/builtin_tool/providers/apo_select/tools/host_cpu_iowait.py

@@ -18,7 +18,7 @@ class HostCPUIoWaitRespTool(BuiltinTool):
         app_id: Optional[str] = None,
         message_id: Optional[str] = None,
     ) -> Generator[ToolInvokeMessage, None, None]:
-        node = tool_parameters.get("node")
+        node = tool_parameters.get("node", '.*')
         start_time = tool_parameters.get("startTime")
         end_time = tool_parameters.get("endTime")
         params = {

api/core/tools/builtin_tool/providers/apo_select/tools/host_cpu_iowait.yaml

@@ -18,7 +18,7 @@ display:
 parameters:
   - name: node
     type: string
-    required: true
+    required: false
     label:
       en_US: node
       zh_Hans: node

api/core/tools/builtin_tool/providers/apo_select/tools/host_cpu_pressure.py

@@ -19,15 +19,15 @@ class HostCpuPressureTool(BuiltinTool):
         app_id: Optional[str] = None,
         message_id: Optional[str] = None,
     ) -> Generator[ToolInvokeMessage, None, None]:
-        node = tool_parameters.get("node")
+        node = tool_parameters.get("node", '.*')
-        job = tool_parameters.get("job")
+        job = tool_parameters.get("job", '.*')
         start_time = tool_parameters.get("startTime")
         end_time = tool_parameters.get("endTime")
         params = {
           'metricName': "宿主机监控指标 - Quick CPU / Mem / Disk - Pressure - CPU",
           'params': {
             'node': node,
-            **({'job': job} if job else {})
+            'job': job
           },
           'startTime': start_time,
           'endTime': end_time,

api/core/tools/builtin_tool/providers/apo_select/tools/host_cpu_pressure.yaml

@@ -31,7 +31,7 @@ parameters:
     form: llm
   - name: node
     type: string
-    required: true
+    required: false
     label:
       en_US: Host Node
       zh_Hans: 宿主机节点

api/core/tools/builtin_tool/providers/apo_select/tools/host_cpu_usage.py

@@ -19,7 +19,7 @@ class HostCpuUsageTool(BuiltinTool):
         app_id: Optional[str] = None,
         message_id: Optional[str] = None,
     ) -> Generator[ToolInvokeMessage, None, None]:
-        node = tool_parameters.get("node")
+        node = tool_parameters.get("node", '.*')
         start_time = tool_parameters.get("startTime")
         end_time = tool_parameters.get("endTime")
         params = {

api/core/tools/builtin_tool/providers/apo_select/tools/host_cpu_usage.yaml

@@ -18,7 +18,7 @@ display:
 parameters:
   - name: node
     type: string
-    required: true
+    required: false
     label:
       en_US: Host Node
       zh_Hans: 宿主机节点

api/core/tools/builtin_tool/providers/apo_select/tools/host_disk_io.py

@@ -18,7 +18,7 @@ class HostDiskIOTool(BuiltinTool):
         app_id: Optional[str] = None,
         message_id: Optional[str] = None,
     ) -> Generator[ToolInvokeMessage, None, None]:
-        node = tool_parameters.get("node")
+        node = tool_parameters.get("node", '.*')
         start_time = tool_parameters.get("startTime")
         end_time = tool_parameters.get("endTime")
         params = {

api/core/tools/builtin_tool/providers/apo_select/tools/host_disk_io.yaml

@@ -18,7 +18,7 @@ display:
 parameters:
   - name: node
     type: string
-    required: true
+    required: false
     label:
       en_US: node
       zh_Hans: node

api/core/tools/builtin_tool/providers/apo_select/tools/host_disk_read_bytes.py

@@ -18,7 +18,7 @@ class HostDiskReadBytesTool(BuiltinTool):
         app_id: Optional[str] = None,
         message_id: Optional[str] = None,
     ) -> Generator[ToolInvokeMessage, None, None]:
-        node = tool_parameters.get("node")
+        node = tool_parameters.get("node", '.*')
         start_time = tool_parameters.get("startTime")
         end_time = tool_parameters.get("endTime")
         params = {

api/core/tools/builtin_tool/providers/apo_select/tools/host_disk_read_bytes.yaml

@@ -18,7 +18,7 @@ display:
 parameters:
   - name: node
     type: string
-    required: true
+    required: false
     label:
       en_US: node
       zh_Hans: node

api/core/tools/builtin_tool/providers/apo_select/tools/host_disk_used.py

@@ -18,7 +18,7 @@ class HostDiskUsedTool(BuiltinTool):
         app_id: Optional[str] = None,
         message_id: Optional[str] = None,
     ) -> Generator[ToolInvokeMessage, None, None]:
-        node = tool_parameters.get("node")
+        node = tool_parameters.get("node", '.*')
         start_time = tool_parameters.get("startTime")
         end_time = tool_parameters.get("endTime")
         params = {

api/core/tools/builtin_tool/providers/apo_select/tools/host_disk_used.yaml

@@ -18,7 +18,7 @@ display:
 parameters:
   - name: node
     type: string
-    required: true
+    required: false
     label:
       en_US: node
       zh_Hans: node

api/core/tools/builtin_tool/providers/apo_select/tools/host_disk_write_bytes.py

@@ -18,7 +18,7 @@ class HostDiskWriteBytesTool(BuiltinTool):
         app_id: Optional[str] = None,
         message_id: Optional[str] = None,
     ) -> Generator[ToolInvokeMessage, None, None]:
-        node = tool_parameters.get("node")
+        node = tool_parameters.get("node", '.*')
         start_time = tool_parameters.get("startTime")
         end_time = tool_parameters.get("endTime")
         params = {

api/core/tools/builtin_tool/providers/apo_select/tools/host_disk_write_bytes.yaml

@@ -18,7 +18,7 @@ display:
 parameters:
   - name: node
     type: string
-    required: true
+    required: false
     label:
       en_US: node
       zh_Hans: node

api/core/tools/builtin_tool/providers/apo_select/tools/host_fd_open.py

@@ -18,7 +18,7 @@ class HostCPUIoWaitRespTool(BuiltinTool):
         app_id: Optional[str] = None,
         message_id: Optional[str] = None,
     ) -> Generator[ToolInvokeMessage, None, None]:
-        node = tool_parameters.get("node")
+        node = tool_parameters.get("node", '.*')
         start_time = tool_parameters.get("startTime")
         end_time = tool_parameters.get("endTime")
         params = {

api/core/tools/builtin_tool/providers/apo_select/tools/host_fd_open.yaml

@@ -18,7 +18,7 @@ display:
 parameters:
   - name: node
     type: string
-    required: true
+    required: false
     label:
       en_US: node
       zh_Hans: node

api/core/tools/builtin_tool/providers/apo_select/tools/host_io_pressure.py

@@ -19,15 +19,15 @@ class HostIoPressureTool(BuiltinTool):
         app_id: Optional[str] = None,
         message_id: Optional[str] = None,
     ) -> Generator[ToolInvokeMessage, None, None]:
-        node = tool_parameters.get("node")
+        node = tool_parameters.get("node", '.*')
-        job = tool_parameters.get("job")
+        job = tool_parameters.get("job", '.*')
         start_time = tool_parameters.get("startTime")
         end_time = tool_parameters.get("endTime")
         params = {
           'metricName': "宿主机监控指标 - Quick CPU / Mem / Disk - Pressure - I/O",
           'params': {
             'node': node,
-            **({'job': job} if job else {})
+            'job': job
           },
           'startTime': start_time,
           'endTime': end_time,

api/core/tools/builtin_tool/providers/apo_select/tools/host_io_pressure.yaml

@@ -31,7 +31,7 @@ parameters:
     form: llm
   - name: node
     type: string
-    required: true
+    required: false
     label:
       en_US: Host Node
       zh_Hans: 宿主机节点

api/core/tools/builtin_tool/providers/apo_select/tools/host_memory_pressure.py

@@ -19,15 +19,15 @@ class HostMemPressureTool(BuiltinTool):
         app_id: Optional[str] = None,
         message_id: Optional[str] = None,
     ) -> Generator[ToolInvokeMessage, None, None]:
-        node = tool_parameters.get("node")
+        node = tool_parameters.get("node", '.*')
-        job = tool_parameters.get("job")
+        job = tool_parameters.get("job", '.*')
         start_time = tool_parameters.get("startTime")
         end_time = tool_parameters.get("endTime")
         params = {
           'metricName': "宿主机监控指标 - Quick CPU / Mem / Disk - Pressure - Mem",
           'params': {
             'node': node,
-            **({'job': job} if job else {})
+            'job': job
           },
           'startTime': start_time,
           'endTime': end_time,

api/core/tools/builtin_tool/providers/apo_select/tools/host_memory_pressure.yaml

@@ -31,7 +31,7 @@ parameters:
     form: llm
   - name: node
     type: string
-    required: true
+    required: false
     label:
       en_US: Host Node
       zh_Hans: 宿主机节点

api/core/tools/builtin_tool/providers/apo_select/tools/host_net_recv.py

@@ -18,7 +18,7 @@ class HostCPUIoWaitRespTool(BuiltinTool):
         app_id: Optional[str] = None,
         message_id: Optional[str] = None,
     ) -> Generator[ToolInvokeMessage, None, None]:
-        node = tool_parameters.get("node")
+        node = tool_parameters.get("node", '.*')
         start_time = tool_parameters.get("startTime")
         end_time = tool_parameters.get("endTime")
         params = {