如何将CSV保存到其他dolphindb集群

 如题,我本地有些csv ,联本地节点时可以loadtext ,但怎么转到其他节点保存数据。一换连接,内存变量就清了。

请先 登录 后评论

最佳答案 2022-09-29 09:39

可以通过xdb,在集群之间同步数据。例如以下代码可以将集群A服务器上的csv文件同步至集群B:


def writeData(dbName, tableName, data){
loadTable(dbName, tableName).append!(data)
}

def loadCsv(filePath, remoteServer, remotePort, username, password){
        conn = xdb(remoteServer, remotePort, username, password)
t = loadText(filePath)
conn(writeData{"dfs://trade","trade", t})
}
loadCsv("/home/appadmin/hwf/trade.csv", "1.1.1.1", 8848, "admin", "111111")


filePath:服务器A上的文件路径

remoteServer/remotePort: 远端服务器连接信息

请先 登录 后评论

其它 0 个回答