参考这个方法:
1.先拿到所希望导入的数据的索引(比如股票代码、日期)
2.然后在导入前先把ddb中对应的记录用delect where trade_date=XXX and ts_code=XXX 删掉
3.最后再导入
dolphindb中的subscribeTable函数提供了persistOffset=true用于保留订阅中断时的位置,可以通过设置offset=-2自动获取断掉时候的位置再订阅。
所以上面的场景可以这样设计:创建键值流数据表keyedStreamTable,该表的主键不允许包含重复值。先把数据写入keyedStreamTable,然后订阅入库。订阅的时候设置offset=-2,persistOffset=true。