error code 99 是套接字错误码,表示EADDRNOTAVAIL,可参考类似问题 linux - Socket bind failed errno = 99 - Stack Overflow 。可能是端口不够用了
回答于 2024-03-08 15:29
这个跟订阅设置有关,subscribeTable有batchSize 和throttle这2个参数设置触发方式: batchSize 是一个整数。若为正数,表示未处理消息的数量达到 batchSize 时,handler 才会处理消息。若未指定或为非正数,每一批次的消息到达之后,handler 就会马上处理。 throttle 是一个浮点数,单位为秒,默认值为1。表示继上次 han...
回答于 2024-03-08 14:22
用响应式状态引擎和deltas函数,示例如下: share streamTable(1:0, `date`time`sym`market`price`qty, [DATE, TIME, SYMBOL, CHAR, DOUBLE, INT]) as trades outputTable = table(100:0, `date`sym`factor1, [DATE, STRING, DOUBLE]) engine = createReactiveStateEngine(name="test", metrics=<deltas(price)>, du...
回答于 2024-03-06 16:01
用响应式状态引擎和deltas函数,示例如下: share streamTable(1:0, `date`time`sym`market`price`qty, [DATE, TIME, SYMBOL, CHAR, DOUBLE, INT]) as trades outputTable = table(100:0, `date`sym`factor1, [DATE, STRING, DOUBLE]) engine = createReactiveStateEngine(name="test", metrics=<deltas(price)>, du...
回答于 2024-03-06 09:58
在 DolphinDB 中,Python 的 pass 占位语句并没有直接的对应实现。在 DolphinDB 中,您可以使用其他方式来实现类似的功能,例如使用空语句或注释来作为占位符。 例如,您可以在 DolphinDB 中使用空语句作为占位符,类似于 Python 中的 pass 语句。示例代码如下: if (condition, , ) // 使用空语句作为占位符{ // 这里...
回答于 2024-03-01 11:44
会排队处理。你可以用getStreamingStat().subWorkers观察一下queueDepth的大小。若一直降不下去,可以在流表侧设置过滤,分发到多个订阅者即多个线程来处理。
回答于 2024-01-29 09:49