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