DolphinDB database的saveText函数支持追加数据,只要设置参数append=true即可。因此可以把分区数据一个个加载到内存,然后追加保存到csv文件。下面的例子是一个按月分区的数据库,用pipeline连续执行:login("admin","123456") v = 2015.01M..2016.12M def queryData(m){ return select * from loadTable("dfs://db1", "tb1") where TradingTime between datetime(date(m)) : datetime(date(m+1)) } def saveData(tb){ tb.saveText("/hdd/hdd0/data/gtatest.csv",',', true) } pipeline(each(partial{queryData}, v),saveData)
DolphinDB database的saveText函数支持追加数据,只要设置参数append=true即可。
因此可以把分区数据一个个加载到内存,然后追加保存到csv文件。下面的例子是一个按月分区的数据库,用pipeline连续执行: