如何快速定位流数据处理时有没有阻塞的情况?

整个集群中目前创建了多个流数据表、多个不同topic的订阅,但是有几个订阅的处理明显有延时,请问如何快速定位流数据处理时有没有阻塞的情况?

请先 登录 后评论

1 个回答

Jason Tang - 时序数据库技术支持

DolphinDB提供了流数据处理监控函数 getStreamingStat(),可以通过以下函数进行更详细的查询:

getStreamingStat().subWorkers  //查询订阅状态

查询结果:

attachments-2021-07-9axUG9BU60f7e099e726e.png如果queueDepth没有堆积的情况,说明流数据的消费没有阻塞。

getStreamingStat().pubConns   //发布链接情况

查询结果:


attachments-2021-07-Gmm4zWMI60f7e0e6b6847.png

如果queueDepth没有堆积的情况,说明流数据的发布没有阻塞。

请先 登录 后评论