第四层
dataPath1 = "dfs://tick"
dbDate = database(,VALUE, 2023.03.01..2030.12.31)
dbSymb = database(,VALUE,`ag2309`fu2305`eg2309)
db1 = database(dataPath1,COMPO,[dbDate,dbSymb],engine=`TSDB)
tick_columns = ["symbol", "exchange", "datetime", "name", "volume", "turnover", "open_interest", "last_price", "last_volume", "limit_up", "limit_down",
"open_price", "high_price", "low_price", "pre_close".......]
tick_type = [SYMBOL, SYMBOL, NANOTIMESTAMP, SYMBOL, DOUBLE, DOUBLE, DOUBLE, DOUBLE, DOUBLE, DOUBLE, DOUBLE,
DOUBLE, DOUBLE, DOUBLE, DOUBLE.......]
tick = table(1:0, tick_columns, tick_type)
tickt = db1.createPartitionedTable(
tick,
"tick",
partitionColumns=["datetime","symbol"],
sortColumns=["symbol", "exchange", "datetime"],
keepDuplicates=LAST)