dolphindb
目前使用的 是
pool = ddb.DBConnectionPool("0.0.0.0", 8903, 20, "admin", "123456")
appender = ddb.PartitionedTableAppender("dfs://dd", "dd", "instrument_id", pool)
多线程 线程池写入
问题是:
批量写入有重复 怎么去除重复呢 写入的时候去除重复
写入代码 appender.append(new_df)
目前是每次写入就有重复
怎么实现每次写入的时候去除重复呢?
数据写入后进行去重