getClusterPerf

getClusterPerf([includeMaster=false])

includeMaster 表示获取的节点信息中是否包含控制节点的信息。

获取每个节点的多个配置和性能监控度量值。它只能在控制节点上执行。注意：代理节点的 connectionNum 是一个随机值，可以忽略。

返回一个表对象，包含以下几列：

• host：节点的主机名。

• port：节点的端口号。

• site：节点的局域网信息。

• mode：节点的类型。0 表示集群的数据节点，1 表示集群的代理节点，2 表示集群的控制节点，3 表示 single mode 的节点，4 表示计算节点。

• state：节点是否存活。

• agentSite：当前节点的代理节点信息。

• maxConnections：最多可以从多少个外部 GUI ，API 或其它节点连接到本地节点。

• maxMemSize：当前节点的内存空间上限（单位：GB）。

• workerNum：常规作业的工作线程的数量。默认值是 CPU 的内核数。

• executorNum：本地执行线程的数量。默认值是 CPU 内核数减1。

• connectionNum：连接到本地节点的连接数。

• name：节点别名。

• memoryUsed：节点的内存占用量（单位：字节）。

• memoryAlloc：系统已分配给当前节点的内存（单位：字节）。

• cpuUsage：CPU 使用率。

• avgLoad：CPU 平均负载。

• medLast10QueryTime：前 10 个完成的查询执行所耗费时间的中间值（单位：纳秒）。注意：必须指定 perfMonitoring=1 才会返回该字段。

• maxLast10QueryTime：前 10 个完成的查询执行所耗费时间的最大值（单位：纳秒）。注意：必须指定 perfMonitoring=1 才会返回该字段。

• medLast100QueryTime：前 100 个完成的查询执行所耗费时间的中间值（单位：纳秒）。注意：必须指定 perfMonitoring=1 才会返回该字段。

• maxLast100QueryTime：前100个完成的查询执行所耗费时间的最大值（单位：纳秒）。注意：必须指定 perfMonitoring=1 才会返回该字段。

• maxRunningQueryTime：当前正在执行的查询的耗费时间的最大值（单位：纳秒）。

• runningJobs：正在执行中的 Job 个数。

• queuedJobs：队列中的 Job 个数。

• runningTasks：正在执行中的 Task 个数。

• queuedTasks：队列中的 Task 个数。

• jobLoad：作业负载。

• diskCapacity：磁盘容量（单位：字节）。

• diskFreeSpace：磁盘剩余空间（单位：字节）。

• diskFreeSpaceRatio：磁盘可用空间占比。

• diskWriteRate：磁盘写速率 （单位：字节/秒）。

• diskReadRate：磁盘读速率（单位：字节/秒）。

• lastMinuteWriteVolume：前一分钟写磁盘容量（单位：字节）。

• lastMinuteReadVolume：前一分钟读磁盘容量（单位：字节）。

• networkSendRate：网络发送速率（单位：字节/秒）。

• networkRecvRate：网络接收速率（单位：字节/秒）。

• lastMinuteNetworkSend：前一分钟网络发送字节数（单位：字节）。

• lastMinuteNetworkRecv：前一分钟网络接收字节数 （单位：字节）。

• publicName：若为控制节点，且配置了 publicName，则显示 publicName；否则显示控制节点所在服务器的 网卡地址。若为数据节点或代理节点，则显示数据节点或代理节点所在服务器的网卡地址。

• lastMsgLatency：流数据订阅节点最后收到的消息的延时（单位：纳秒）。

• cumMsgLatency：流数据订阅节点所有已接收的消息的平均延时（单位：纳秒）。

• isLeader：是否是 raft 组的 leader，该字段仅在配置了控制节点高可用时才生效。请注意，若 raft 组存在宕机的节点，则该节点的 isLeader 将返回空值。

rpc(getControllerAlias(), getClusterPerf)

rpc(getControllerAlias(), getClusterPerf).keys()
# output
["host","port","site","mode","state","agentSite","maxConnections","maxMemSize","workerNum","executorNum","connectionNum","name","memoryUsed","memoryAlloc","cpuUsage","avgLoad","medLast10QueryTime","maxLast10QueryTime","medLast100QueryTime","maxLast100QueryTime","maxRunningQueryTime","runningJobs","queuedJobs","runningTasks","queuedTasks","jobLoad","diskCapacity","diskFreeSpace","diskFreeSpaceRatio","diskWriteRate","diskReadRate","lastMinuteWriteVolume","lastMinuteReadVolume","networkSendRate","networkRecvRate","lastMinuteNetworkSend","lastMinuteNetworkRecv","publicName","lastMsgLatency","cumMsgLatency"]

集群高可用环境下执行：

rpc(getControllerAlias(), getClusterPerf,true)