The parameter sortColumns is not defined in function createPartitionedTable

def createSnapshotDbTable(dbName, tbName){
    if(existsDatabase(dbName)){
        dropDatabase(dbName)
    }
    dbTime = database(, VALUE, 2022.01.01..2022.12.31)
    dbSymbol = database(, HASH, [SYMBOL, 20])
    db = database(dbName, COMPO, [dbTime, dbSymbol],engine='TSDB')
    name = `UpdateTime`SecurityID`PreCloPrice`OpenPrice`HighPrice`LowPrice`LastPrice`InstruStatus`TradNumber`TradVolume`Turnover`TotalBidVol`WAvgBidPri`TotalAskVol`WAvgAskPri`IOPV`AskPrice1`AskVolume1`AskPrice2`AskVolume2`AskPrice3`AskVolume3`AskPrice4`AskVolume4`AskPrice5`AskVolume5`AskPrice6`AskVolume6`AskPrice7`AskVolume7`AskPrice8`AskVolume8`AskPrice9`AskVolume9`AskPrice10`AskVolume10`BidPrice1`BidVolume1`BidPrice2`BidVolume2`BidPrice3`BidVolume3`BidPrice4`BidVolume4`BidPrice5`BidVolume5`BidPrice6`BidVolume6`BidPrice7`BidVolume7`BidPrice8`BidVolume8`BidPrice9`BidVolume9`BidPrice10`BidVolume10`NumOrdersB1`NumOrdersB2`NumOrdersB3`NumOrdersB4`NumOrdersB5`NumOrdersB6`NumOrdersB7`NumOrdersB8`NumOrdersB9`NumOrdersB10`NumOrdersS1`NumOrdersS2`NumOrdersS3`NumOrdersS4`NumOrdersS5`NumOrdersS6`NumOrdersS7`NumOrdersS8`NumOrdersS9`NumOrdersS10`LocalTime`SeqNo
    type = `TIMESTAMP`SYMBOL`DOUBLE`DOUBLE`DOUBLE`DOUBLE`DOUBLE`SYMBOL`INT`DOUBLE`DOUBLE`DOUBLE`DOUBLE`DOUBLE`DOUBLE`DOUBLE`DOUBLE`DOUBLE`DOUBLE`DOUBLE`DOUBLE`DOUBLE`DOUBLE`DOUBLE`DOUBLE`DOUBLE`DOUBLE`DOUBLE`DOUBLE`DOUBLE`DOUBLE`DOUBLE`DOUBLE`DOUBLE`DOUBLE`DOUBLE`DOUBLE`DOUBLE`DOUBLE`DOUBLE`DOUBLE`DOUBLE`DOUBLE`DOUBLE`DOUBLE`DOUBLE`DOUBLE`DOUBLE`DOUBLE`DOUBLE`DOUBLE`DOUBLE`DOUBLE`DOUBLE`DOUBLE`DOUBLE`DOUBLE`DOUBLE`DOUBLE`DOUBLE`DOUBLE`DOUBLE`DOUBLE`DOUBLE`DOUBLE`DOUBLE`DOUBLE`DOUBLE`DOUBLE`DOUBLE`DOUBLE`DOUBLE`DOUBLE`DOUBLE`DOUBLE`DOUBLE`SYMBOL`INT

    tbTemp = table(1:0, name, type)
    db = database(dbName)
    createPartitionedTable(dbHandle=db, table=tbTemp, tableName=tbName, partitionColumns=`UpdateTime`SecurityID, compressMethods={UpdateTime:"delta"}, sortColumns=`UpdateTime`SecurityID, keepDuplicates=LAST)
}
请先 登录 后评论

1 个回答

Polly

根据你的报错信息:The parameter sortColumns is not defined in function createPartitionedTable

首先你需要检查一下 server 是否是 200 的版本,因为 130 的版本不支持 TSDB,而 sortColumns 是 TSDB 引擎下表特有的参数。

其次根据你的代码,sortColumns=`UpdateTime`SecurityID 指定不符合规范,因为 TSDB 引擎要求,sortColumns 指定多列时,最后一列需要是时间列,因此应该改写为 sortColumns=`SecurityID`UpdateTime。

请先 登录 后评论
  • 1 关注
  • 0 收藏,692 浏览
  • 潘超 提出于 2023-03-21 17:53

相似问题