DolphinDB提供了流数据处理监控函数 getStreamingStat(),可以通过以下函数进行更详细的查询:
getStreamingStat().subWorkers //查询订阅状态
查询结果:
如果queueDepth没有堆积的情况,说明流数据的消费没有阻塞。
getStreamingStat().pubConns //发布链接情况
查询结果:
如果queueDepth没有堆积的情况,说明流数据的发布没有阻塞。
DolphinDB提供了流数据处理监控函数 getStreamingStat(),可以通过以下函数进行更详细的查询:
getStreamingStat().subWorkers //查询订阅状态
查询结果:
如果queueDepth没有堆积的情况,说明流数据的消费没有阻塞。
getStreamingStat().pubConns //发布链接情况
查询结果:
如果queueDepth没有堆积的情况,说明流数据的发布没有阻塞。