getStreamingStat
语法
getStreamingStat()
参数
无
详情
监控流计算的状态。返回的结果是一个字典，包含以下5个表：
表pubConns监控本地发布节点和它的所有订阅节点之间的连接状态。每一行表示一个订阅节点。它包含以下列：
列名 |
含义 |
|---|---|
client |
订阅节点的IP地址和端口号 |
queueDepthLimit |
发布节点上的消息队列深度的上限 |
queueDepth |
发布节点上的当前消息队列深度 |
tables |
发布节点上所有的共享流数据表 |
表subConns监控本地订阅节点和发布节点之间的连接状态。每一行表示一个发布节点。它包含以下列：
列名 |
含义 |
|---|---|
publisher |
发布节点的别名 |
cumMsgCount |
已经接收到的消息数量 |
cumMsgLatency |
所有已接收的消息的平均延迟 |
LastMsgLatency |
最后接收到的消息的延迟 |
lastUpdate |
最后接收到消息的时间 |
表pubTables监控流数据表状态。每一行表示一个流数据表的信息。它包含以下列：
列名 |
含义 |
|---|---|
tableName |
发布的流数据表名 |
subscriber |
订阅端的ip和端口信息 |
msgOffset |
已经发布的最后一条数据在总数据中的偏移量 |
actions |
订阅任务的名称 |
上表中的延迟表示从消息到达发布节点的消息队列开始，到消息到达订阅节点的消息队列所耗费的时间。
表persistWorkers监控负责持久化流数据表的工作线程的状态。它包含以下列：
列名 |
含义 |
|---|---|
workerId |
线程ID |
queueDepthLimit |
持久化的消息队列深度的上限 |
queueDepth |
持久化的当前消息队列深度 |
tables |
已经持久化的流数据表 |
表subWorkers监控订阅节点的工作线程的状态。工作线程状态信息会按照topic来展示。它包含以下列：
列名 |
含义 |
|---|---|
workerId |
线程ID |
topics |
订阅主题 |
queueDepthLimit |
订阅节点上的消息队列深度的上限 |
queueDepth |
订阅节点上的当前消息队列深度 |
processedMsgCount |
已经处理的消息数 |
lastMsgId |
最后一条消息的Id |
failedMsgCount |
处理失败的消息数 |
lastFailedMsgId |
最后一条错误消息的Id |
lastFailedTimestamp |
最后一条错误消息发生的时间 |
lastErrMsg |
最后一条错误消息的信息 |
msgAsTable |
布尔值，表示订阅的数据是否为表。true表示订阅的数据为表；false表示订阅的数据是由列组成的元组。 |
batchSize |
handler批量处理的消息数 |
throttle |
数值类型，单位为毫秒。表示继上次handler处理消息之后，若batchSize条件一直未达到，多久后再次处理消息 |
hash |
非负整数，指定某个订阅线程处理进来的消息 |
filter |
流数据表指定的过滤列 |
persistOffset |
布尔值，表示是否持久化保存最新一条已经处理的订阅数据的偏移量 |
timeTrigger |
布尔值，若为true，表示即使没有新的消息进入，handler也会在throttle参数所设定的时间间隔被触发 |
handlerNeedMsgId |
布尔值，默认值为false。若为true，handler必须支持两个参数：msgBody，msgId |
raftGroup |
高可用Raft组的ID |
例子
$ getStreamingStat().pubConns;
$ getStreamingStat().subConns;
$ getStreamingStat().pubTables;
$ getStreamingStat().persistWorkers;
$ getStreamingStat().subWorkers;