if(existsDatabase("dfs://Daily_adj_price")){
	dropDatabase("dfs://Daily_adj_price")}
db = database("dfs://Daily_adj_price", VALUE, 2020.07M..2023.09M)
// # data = loadTextEx(db,'data','TRADE_DATE',"/home/data/mkt_equd_adj.csv")
data = loadTextEx(db,'data','TRADE_DATE',"/ssd/ssd3/data/mkt_equd_adj.csv")
data =loadTable("dfs://Daily_adj_price", "data")
timer{
// 閫氳繃绉诲姩骞冲潎璁＄畻鍙屽潎绾�
// year(TRADE_DATE) = 2023 
a = select SECURITY_ID, TRADE_DATE as date, CLOSE_PRICE_1 as close, mavg(CLOSE_PRICE_1, 5) as ma_5, mavg(CLOSE_PRICE, 20) as ma_20 from data context by SECURITY_ID 
// 鑾峰緱涓ゆ牴鍧囩嚎鐨勫墠涓€鏍圭嚎
update a set pre_ma5 = prev(ma_5), pre_ma20 = prev(ma_20) context by SECURITY_ID

// 鍒ゆ柇閲戝弶姝诲弶骞剁敓鎴愪俊鍙�
update a set signal = iif(pre_ma5 > pre_ma20 and ma_5< ma_20, -1 ,iif(pre_ma5 < pre_ma20 and ma_5> ma_20, 1 , 0)) context by SECURITY_ID}

//鍏ㄩ儴3501206鏉℃暟鎹紝鏈湴鑰楁椂 423 ms锛�228鏈嶅姟鍣ㄨ€楁椂556ms