如何解决可以订阅本地流媒体吗?
可以订阅本地流媒体吗?
代码如下
subscribeTable(tableName=`gpytest,actionName="judge",offset=0,handler=judge,msgAsTable=Ture)
错误提示
Can't complete subscription because subscription is not enabled
为什么
解决方法
您应该为流数据启用订阅功能。在single模式下在dolphindb.cfg文件中添加配置项,或者在集群模式下在cluster.cfg文件中添加配置项。具体配置项如下:
- subPort:订阅线程正在监听的端口号。必须指定此参数才能使节点成为订阅者。
- subExecutors:订阅者节点中的消息处理线程数。仅当启用订阅时,此参数才相关。如果设置为0,则表示该线程可以进行消息解析,也可以处理消息。
- maxSubConnections:订阅者节点可以连接的最大发布者数。默认值为 64。
- subExecutorPooling:一个布尔值,指示流式执行器是否使用池化模式。默认值为 false。
- maxSubQueueDepth:订阅者节点上消息队列的最大深度(记录数)。
可以参考流数据教程: https://github.com/dolphindb/Tutorials_eN/blob/master/streaming_tutorial.md
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。