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;