springboot关于@RabbitListener以及@QueueBinding的路由键设置没效果?
我使用rabbitmq和springboot集成出现一个坑。那就是我发送消息时使用的是同一个消息队列以及同一个直连交换器，通过不同的key发给不同的消息监听器。…
某个字段的值某一时间段内不变，怎么自动把status变化时把新的状态写入keyedTable
使用keyedTable作为流计算的输出表，设备的运行状态一段时间内是不变的，然后如果写入keyedTable是自动更新的，那么我该如何再status变化时，把新的状…
在DolphinDB中使用subscribeTable函数时，参数设置的问题
在DolphinDB中的subscribeTable函数使用时，只有tableName和handler两个参数是必须的，执行如下代码：share streamTable(10000:0,`timestamp`temperat…
DolphinDB的数据回放功能和流计算引擎在多机集群中如何实现资源的高效利用
请问DolphinDB的数据回放功能和流计算引擎在多机集群中如何实现资源的高效利用？目前似乎replay和流数据表的订阅和聚合计算只能由指定节点运行，那这…
Failed to parse the incoming connection with IO error type=1
我这边python订阅流表可以成功订阅，但是在handler回调函数里不能被触发，也就是说没有数据推过来。查看dolphindb的log信息发现如下错误：我的dolphin…
分钟线汇总成半小时线时结果缺少数据
我想把我的分钟线汇总成半小时线：sessionsStart=09:30:00.000 13:00:00.000 barMinutes = 30 OHLC = select first(open) as open, max(high) as high…
在创建分布式表时提示A stream table does not support direct access
我想把从流数据表订阅的数据保存到DolphinDB分布式表，代码如下：share streamTable(1000000:0,`hardwareId`ts`temp1`temp2`temp3,[INT,TIMESTAMP,DOU…
python 订阅接口中的filter应该如何设置
假设我在DolphinDB发布端已设置了过滤列symbol，代码如下所示：share streamTable(10000:0,`time`symbol`price`id, [TIMESTAMP,SYMBOL,DOUBLE,INT]) a…
流数据表中插入10条记录，但handler中只得到3条
在DolphinDB database中创建流数据表，并插入10条数据：share streamTable(10000:0,`time`sym`price`id, [TIMESTAMP,SYMBOL,DOUBLE,INT]) as trades s…
如何优化流表订阅入库的性能
今天我压测了通过流表订阅的形式去写入DolphinDB database分布式表这块的逻辑，streamTable--data-->partitionTable的TPS只有100多点，请帮忙看看能…
用python API订阅流数据时收不到数据
我在DolphinDB中创建了一张流表，然后分别在本地节点中订阅和在python api订阅这张流表，本地节点中订阅能收到流数据，但python api订阅端收不到流数…
流数据订阅端的handler中怎么输出日志信息
我从DolphinDB database的流数据表订阅数据，请问在编写subscribeTable的handler（订阅函数）时，能不能print一些中间结果到屏幕上看看结果？…
在python中怎么把当前时间写入DolphinDB流表
我在DolphinDB databse中创建了如下流数据表： st=streamTable( array(LONG,0) as id, array(TIMESTAMP,0) as ts, array(DATETIME,0) as dt, array(D…
在定义函数时碰到不能覆盖已存在函数的异常
我想在DolphinDB database中实现历史数据回放功能，然后写了如下所示的代码： // 定义回放函数 def replayData(productCode, startTime, length, rat…
