更新时间:2025-12-10 GMT+08:00

查询SQL列表

功能介绍

该接口用于查询实时SQL列表。

调用方法

请参见如何调用API。

URI

POST /v2/{project_id}/clusters/{cluster_id}/dms/queries

表1 路径参数

参数

是否必选

参数类型

描述

project_id

是

String

参数解释:

项目ID。获取方法请参见获取项目ID。

约束限制:

不涉及。

取值范围:

不涉及。

默认取值:

不涉及。

cluster_id

是

String

参数解释:

集群ID。获取方法请参见获取集群ID。

约束限制:

必须是有效的dws集群ID。

取值范围:

36位UUID。

默认取值:

不涉及。

请求参数

表2 请求Body参数

参数

是否必选

参数类型

描述

cluster_id

是

String

参数解释:

集群ID。获取方法请参见获取集群ID。

约束限制:

必须是有效的dws集群ID。

取值范围:

36位UUID。

默认取值:

不涉及。

project_id

是

String

参数解释:

项目ID。获取方法请参见获取项目ID。

约束限制:

不涉及。

取值范围:

不涉及。

默认取值:

不涉及。

offset

是

String

参数解释:

偏移量,表示从此偏移量开始查询,一般为页数减1。

取值范围:

大于等于0。

limit

是

String

参数解释:

每页显示的条目数量。

取值范围:

大于0。

conditions

是

Array of ListQueriesCondition objects

参数解释:

查询条件数组。

取值范围:

不涉及。

order_by

否

String

参数解释:

排序字段。

取值范围:

不涉及。

target

是

String

参数解释:

固定值db_queries。

取值范围:

不涉及。

表3 ListQueriesCondition

参数

是否必选

参数类型

描述

field

是

String

参数解释:

字段名称。

取值范围:

systemQuery:是否隐藏系统查询。

userName:用户名称。

applicationName:应用名称。

dbName:数据库名称。

resourcePool:资源池。

queryStatus:查询状态。

enqueue:排队状态。

value

是

String

参数解释:

字段值。

取值范围:

不涉及。

operator

是

String

参数解释:

比较方式。

取值范围:

String类型参数:=、!=、like、not like

int类型参数:=、!=、>、<、>=、<=

boolean类型参数:=、!=

响应参数

状态码:200

表4 响应Body参数

参数

参数类型

描述

code

Integer

参数解释:

响应码。

取值范围:

不涉及。

msg

String

参数解释:

响应信息。

取值范围:

不涉及。

data

ListQueriesData object

参数解释:

响应数据。

取值范围:

不涉及。

count

Integer

参数解释:

总条数。

取值范围:

不涉及。

表5 ListQueriesData

参数

参数类型

描述

queries

Array of ListQueriesDto objects

参数解释:

查询数据列表。

取值范围:

不涉及。

status

ListQueriesStatus object

参数解释:

统计数据。

取值范围:

不涉及。

表6 ListQueriesDto

参数

参数类型

描述

virtual_cluster_id

Integer

参数解释:

虚拟集群ID。

取值范围:

不涉及。

ctime

Long

参数解释:

采集时间。

取值范围:

不涉及。

pid

String

参数解释:

会话ID。

取值范围:

不涉及。

inst_name

String

参数解释:

实例名称。

取值范围:

不涉及。

waiting

Boolean

参数解释:

如果后台当前正等待锁则为true。

取值范围:

不涉及。

enqueue

String

参数解释:

资源状态。

取值范围:

不涉及。

warning

String

参数解释:

主要显示如下几类告警信息以及sql自诊断调优相关告警。

取值范围:

不涉及。

query

String

参数解释:

查询语句。

取值范围:

不涉及。

lane

String

参数解释:

快慢车道。

取值范围:

fast:快车道。

slow:慢车道。

db_name

String

参数解释:

数据库名称。

取值范围:

不涉及。

priority

String

参数解释:

任务在资源池中的优先级。

取值范围:

1:最高。

2:高。

4:中。

8:低。

query_id

String

参数解释:

语句执行使用的内部查询ID。

取值范围:

不涉及。

query_band

String

参数解释:

用于标示作业类型,可通过guc参数query_band进行设置,默认为空字符串。

取值范围:

不涉及。

job_name

String

参数解释:

该值是从query_band的字段中取出来的,位置0。

取值范围:

不涉及。

job_inst

String

参数解释:

该值是从query_band的字段中取出来的,位置1。

取值范围:

不涉及。

user_name

String

参数解释:

连接到后端的用户名。

取值范围:

不涉及。

application_name

String

参数解释:

连接到后端的应用名。

取值范围:

不涉及。

client_address

String

参数解释:

连接到后端的客户端的IP地址。

取值范围:

不涉及。

client_hostname

String

参数解释:

客户端的主机名。

取值范围:

不涉及。

client_port

String

参数解释:

客户端用于与后端通讯的tcp端口号。

取值范围:

不涉及。

start_time

Long

参数解释:

语句执行的开始时间。

取值范围:

不涉及。

block_time

Long

参数解释:

语句执行前的阻塞时间,单位ms。

取值范围:

不涉及。

duration

Long

参数解释:

语句已经执行的时间,单位ms。

取值范围:

不涉及。

estimate_total_time

Long

参数解释:

语句执行预估总时间,单位ms。

取值范围:

不涉及。

estimate_left_time

Long

参数解释:

语句执行预估剩余时间,单位ms。

取值范围:

不涉及。

resource_pool

String

参数解释:

用户使用的资源池。

取值范围:

不涉及。

control_group

String

参数解释:

语句所使用的cgroup。

取值范围:

不涉及。

min_peak_memory

Integer

参数解释:

语句在所有dn上的最小内存峰值,单位mb。

取值范围:

不涉及。

max_peak_memory

Integer

参数解释:

语句在所有dn上的最大内存峰值,单位mb。

取值范围:

不涉及。

average_peak_memory

Integer

参数解释:

语句执行过程中的内存使用平均值,单位mb。

取值范围:

不涉及。

memory_skew_percent

Integer

参数解释:

语句在各dn间的内存使用倾斜率。

取值范围:

不涉及。

estimate_memory

Integer

参数解释:

语句预估使用内存,单位mb。

取值范围:

不涉及。

spill_info

String

参数解释:

语句在所有dn上的下盘信息。

取值范围:

不涉及。

min_spill_size

Integer

参数解释:

若发生下盘,所有dn上下盘的最小数据量 (单位mb) 默认为0。

取值范围:

不涉及。

max_spill_size

Integer

参数解释:

若发生下盘,所有dn上下盘的最大数据量 (单位mb) 默认为0。

取值范围:

不涉及。

average_spill_size

Integer

参数解释:

若发生下盘,所有dn上下盘的平均数据量 (单位mb) 默认为0。

取值范围:

不涉及。

spill_skew_percent

Integer

参数解释:

若发生下盘,dn间下盘倾斜率。

取值范围:

不涉及。

min_dn_time

Long

参数解释:

语句在所有dn上的最小执行时间,单位ms。

取值范围:

不涉及。

max_dn_time

Long

参数解释:

语句在所有dn上的最大执行时间,单位ms。

取值范围:

不涉及。

average_dn_time

Long

参数解释:

语句在所有dn上的平均执行时间,单位ms。

取值范围:

不涉及。

dntime_skew_percent

Integer

参数解释:

语句在各dn间的执行时间倾斜率。

取值范围:

不涉及。

min_cpu_time

Long

参数解释:

语句在所有dn上的最小cpu时间,单位ms。

取值范围:

不涉及。

max_cpu_time

Long

参数解释:

语句在所有dn上的最大cpu时间,单位ms。

取值范围:

不涉及。

total_cpu_time

Long

参数解释:

语句在所有dn上的cpu总时间,单位ms。

取值范围:

不涉及。

cpu_skew_percent

Integer

参数解释:

语句在各dn间的cpu时间倾斜率。

取值范围:

不涉及。

average_peak_iops

Integer

参数解释:

语句在所有dn上的每秒平均io峰值(列存单位是次/s,行存单位是万次/s)。

取值范围:

不涉及。

iops_skew_percent

Integer

参数解释:

语句在dn间的io倾斜率。

取值范围:

不涉及。

max_peak_iops

Integer

参数解释:

语句在所有dn上的每秒最大io峰值(列存单位是次/s,行存单位是万次/s)。

取值范围:

不涉及。

min_peak_iops

Integer

参数解释:

语句在所有dn上的每秒最小io峰值(列存单位是次/s,行存单位是万次/s)。

取值范围:

不涉及。

query_plan

String

参数解释:

查询计划。

取值范围:

不涉及。

query_status

String

参数解释:

当前查询语句的实时运行状态。

取值范围:

active、idle、idle in transaction、idle in transaction(aborted)、fastpath function call、disabled。

wlm_status

String

参数解释:

当前查询语句在资源池上的运行状态。

取值范围:

pending:待生效。

running:运行中。

finished:结束。

aborted:终止。

active:正常。

unknown:未知。

wlm_attrib

String

参数解释:

语句的属性。

取值范围:

ordinary:普通。

simple:简单。

complicated:复杂。

internal:内部。

system_query

Boolean

参数解释:

是否系统查询。

取值范围:

不涉及。

backend_start

Long

参数解释:

该过程开始的时间,即当客户端连接服务器时。

取值范围:

不涉及。

elapsed_time

Long

参数解释:

到目前为止的执行时间。

取值范围:

不涉及。

curr_xact_start

Long

参数解释:

启动当前事务的时间,如果没有事务是活跃的,则为null。如果当前查询是首个事务,则这列等同于query_start列。

取值范围:

不涉及。

state_change

Long

参数解释:

上次状态改变的时间。

取值范围:

不涉及。

query_start

Long

参数解释:

语句执行的开始时间。

取值范围:

不涉及。

query_elapsed_time

Long

参数解释:

语句当前为止的实际执行时间。单位:秒。

取值范围:

不涉及。

表7 ListQueriesStatus

参数

参数类型

描述

average_query_waiting_time

Double

参数解释:

平均查询等待时间。

取值范围:

不涉及。

average_time_consumption_of_queries

Double

参数解释:

平均查询耗时。

取值范围:

不涉及。

average_time_consumption_of_sessions

Double

参数解释:

平均会话耗时。

取值范围:

不涉及。

queries_count

Long

参数解释:

查询数量。

取值范围:

不涉及。

session_count

Long

参数解释:

会话数量。

取值范围:

不涉及。

请求示例

https://{Endpoint}/v2/{project_id}/clusters/{cluster_id}/dms/queries 

{
  "offset" : 0,
  "limit" : 1,
  "cluster_id" : "cluster_id",
  "project_id" : "project_id",
  "conditions" : [ {
    "field" : "userName",
    "value" : "用户名称",
    "operator" : "="
  }, {
    "field" : "applicationName",
    "value" : "应用名称",
    "operator" : "<>"
  }, {
    "field" : "dbName",
    "value" : "数据库名称",
    "operator" : "="
  }, {
    "field" : "resourcePool",
    "value" : "资源池",
    "operator" : "<>"
  }, {
    "field" : "queryStatus",
    "value" : "查询状态",
    "operator" : "="
  }, {
    "field" : "enqueue",
    "value" : "排队状态",
    "operator" : "<>"
  }, {
    "field" : "lane",
    "value" : "快慢车道",
    "operator" : "="
  }, {
    "field" : "instName",
    "value" : "接入CN",
    "operator" : "<>"
  }, {
    "field" : "pid",
    "value" : "会话ID",
    "operator" : "="
  }, {
    "field" : "blockTime",
    "value" : "1",
    "operator" : "="
  }, {
    "field" : "duration",
    "value" : "2",
    "operator" : "<>"
  }, {
    "field" : "minCpuTime",
    "value" : "3",
    "operator" : ">"
  }, {
    "field" : "maxCpuTime",
    "value" : "4",
    "operator" : "<"
  }, {
    "field" : "totalCpuTime",
    "value" : "5",
    "operator" : ">="
  }, {
    "field" : "cpuSkewPercent",
    "value" : "6",
    "operator" : "<="
  }, {
    "field" : "spillInfo",
    "value" : "dn下盘信息",
    "operator" : "="
  }, {
    "field" : "minSpillSize",
    "value" : "7",
    "operator" : "<>"
  }, {
    "field" : "maxSpillSize",
    "value" : "8",
    "operator" : ">"
  }, {
    "field" : "averageSpillSize",
    "value" : "9",
    "operator" : "<"
  }, {
    "field" : "spillSkewPercent",
    "value" : "10",
    "operator" : ">="
  }, {
    "field" : "queryBand",
    "value" : "作业类型",
    "operator" : "<>"
  }, {
    "field" : "jobName",
    "value" : "任务名称",
    "operator" : "="
  }, {
    "field" : "jobInst",
    "value" : "任务实例",
    "operator" : "<>"
  }, {
    "field" : "clientHostname",
    "value" : "主机名称",
    "operator" : "="
  }, {
    "field" : "clientPort",
    "value" : "TCP端口",
    "operator" : "<>"
  }, {
    "field" : "waiting",
    "value" : "是否等待",
    "operator" : "="
  }, {
    "field" : "estimateTotalTime",
    "value" : "11",
    "operator" : "="
  }, {
    "field" : "estimateLeftTime",
    "value" : "12",
    "operator" : "<>"
  }, {
    "field" : "controlGroup",
    "value" : "cgroup",
    "operator" : "like"
  }, {
    "field" : "minPeakMemory",
    "value" : "13",
    "operator" : "="
  }, {
    "field" : "maxPeakMemory",
    "value" : "14",
    "operator" : "<>"
  }, {
    "field" : "averagePeakMemory",
    "value" : "15",
    "operator" : ">"
  }, {
    "field" : "memorySkewPercent",
    "value" : "16",
    "operator" : "<"
  }, {
    "field" : "estimateMemory",
    "value" : "17",
    "operator" : ">="
  }, {
    "field" : "minDnTime",
    "value" : "18",
    "operator" : "<="
  }, {
    "field" : "maxDnTime",
    "value" : "19",
    "operator" : "="
  }, {
    "field" : "averageDnTime",
    "value" : "20",
    "operator" : "<>"
  }, {
    "field" : "dntimeSkewPercent",
    "value" : "21",
    "operator" : ">"
  }, {
    "field" : "warning",
    "value" : "告警",
    "operator" : "="
  }, {
    "field" : "averagePeakIops",
    "value" : "22",
    "operator" : "<>"
  }, {
    "field" : "iopsSkewPercent",
    "value" : "23",
    "operator" : ">"
  }, {
    "field" : "wlmStatus",
    "value" : "语句运行状态",
    "operator" : "="
  }, {
    "field" : "wlmAttrib",
    "value" : "语句属性",
    "operator" : "not like"
  } ],
  "order_by" : "duration asc",
  "target" : "db_queries"
}

响应示例

状态码:200

查询成功。

{
  "code" : 0,
  "msg" : "OK",
  "count" : 0,
  "data" : {
    "queries" : [ {
      "ctime" : 1699062726000,
      "pid" : "140535026615872",
      "waiting" : false,
      "duration" : 0,
      "enqueue" : "",
      "warning" : "",
      "query" : "WLM fetch collect info from data nodes",
      "lane" : "",
      "priority" : null,
      "virtual_cluster_id" : 0,
      "inst_name" : "cn_5002",
      "db_name" : "postgres",
      "query_id" : "145522562959854219",
      "query_band" : "",
      "job_name" : "",
      "job_inst" : "",
      "user_name" : "Ruby",
      "application_name" : "workload",
      "client_address" : "",
      "client_hostname" : "",
      "client_port" : "",
      "start_time" : 0,
      "block_time" : 0,
      "estimate_total_time" : 0,
      "estimate_left_time" : 0,
      "resource_pool" : "default_pool",
      "control_group" : "",
      "min_peak_memory" : 0,
      "max_peak_memory" : 0,
      "average_peak_memory" : 0,
      "memory_skew_percent" : 0,
      "estimate_memory" : 0,
      "spill_info" : "",
      "min_spill_size" : 0,
      "max_spill_size" : 0,
      "average_spill_size" : 0,
      "spill_skew_percent" : 0,
      "min_dn_time" : 0,
      "max_dn_time" : 0,
      "average_dn_time" : 0,
      "dntime_skew_percent" : 0,
      "min_cpu_time" : 0,
      "max_cpu_time" : 0,
      "total_cpu_time" : 0,
      "cpu_skew_percent" : 0,
      "average_peak_iops" : 0,
      "iops_skew_percent" : 0,
      "max_peak_iops" : 0,
      "min_peak_iops" : 0,
      "query_plan" : null,
      "query_status" : "active",
      "wlm_status" : "",
      "wlm_attrib" : "",
      "system_query" : true,
      "backend_start" : 1698998138,
      "elapsed_time" : 64585,
      "curr_xact_start" : 1699062726,
      "state_change" : 1698998142,
      "query_start" : 1698998142,
      "query_elapsed_time" : -1
    } ],
    "status" : {
      "session_count" : 19,
      "average_time_consumption_of_sessions" : 51297.58,
      "queries_count" : 19,
      "average_time_consumption_of_queries" : 48799.8,
      "average_query_waiting_time" : 0
    }
  }
}

状态码

状态码

描述

200

查询成功。

400

请求错误。

401

鉴权失败。

403

没有操作权限。

404

找不到资源。

500

服务内部错误。

503

服务不可用。