Golang cron으로 스케쥴링 이용해서 주기적으로 출력값이 뜨도록 했는데 같은 값만 계속 올라오네요.

Question

package main import ( "fmt" "time" "github.com/robfig/cron" "ㅁㅁㅁ/db" ) func main() { c := cron.New() var a *db.SWPRICE swp := a.GetMiniuteSWPrice() // fmt.Printf("%+v ", swp) c.AddFunc("* * * * *", func() { fmt.Printf("%+v ", swp) }) c.Start() time.Sleep(time.Minute * 30) c.Stop() } func (s *SWPRICE) GetMiniuteSWPrice() []SWPRICE { swp := []SWPRICE{} // sql.DB 객체 생성 db, err := sql.Open("mysql", "trade:mYtrading(12)@tcp(10.1.1.12:3306)/mytradinginfo") if err != nil { log.Fatal(err) } defer db.Close() // 하나의 Row를 갖는 SQL 쿼리 rows, err := db.Query(`SELECT symbol, unix_timestamp() AS unix_time, 0 AS volume, MAX(high_price) AS high_price, MIN(low_price) AS low_price, SUBSTRING_INDEX(MIN(CONCAT(unix_time, '_', open_price)), '_', - 1) AS open_price, SUBSTRING_INDEX(MAX(CONCAT(unix_time, '_', close_price)), '_',- 1) AS close_price FROM (SELECT * FROM mytradinginfo.SW_PRICE WHERE symbol = 'BTC/USD' and unix_time BETWEEN 1603670400 AND 1603670400 + 60 -1) a`) if err != nil { log.Fatal(err) } defer rows.Close() for rows.Next() { var swprice SWPRICE rows.Scan(&swprice.Symbol, &swprice.UnixTime, &swprice.Volume, &swprice.HighPrice, &swprice.LowPrice, &swprice.OpenPrice, &swprice.ClosePrice) swp = append(swp, swprice) } // fmt.Printf("%+v ", swp) return swp } AddFunc 함수로 GetMiniuteSWPrice()의 출력값을 매 시간 주기마다 출력 하려고 하는데요.쿼리에 보시면 실시간으로 뽑고 싶어서 unix_timestamp() AS unix_time이라고 했는데스케쥴링 걸지 않으면 UnixTIme값이 갱신되어 출력되는데 cron으로 주기마다 출력을 하면 UnixTIme값이 갱신되지 않고 같은 값을 계속 출력시켜주고 있습니다. 어떻게 해결하면 좋을까요?

Golang cron으로 스케쥴링 이용해서 주기적으로 출력값이 뜨도록 했는데 같은 값만 계속 올라오네요.

0개의 답변

Q&A 목록