| 상태 | 이벤트 명세 | 유형 / 주기 | 최종 실행 | 다음 실행까지 (Live) | 액션 |
|---|---|---|---|---|---|
| ENABLED |
ev_upbit_coin_1s 플랫폼_플랫폼 테이블을 1초 단위 테이블로 복사_복사 |
RECURRING EVERY 1 SECOND |
2026-04-19 20:41:21 | 계산 중... | |
|
INSERT INTO upbit_data.daemon_upbit_coin_1s (
id,
market,
trade_date,
trade_time,
trade_date_kst,
trade_time_kst,
opening_price,
high_price,
low_price,
trade_price,
prev_closing_price,
`change`,
change_price,
change_rate,
signed_change_price,
signed_change_rate,
trade_volume,
acc_trade_volume,
acc_trade_volume_24h,
acc_trade_price,
acc_trade_price_24h,
highest_52_week_price,
highest_52_week_date,
lowest_52_week_price,
lowest_52_week_date,
collected_at,
collected_ms,
ob_timestamp,
ob_total_ask_size,
ob_total_bid_size,
ob_units,
ob_collected_at,
ob_collected_ms,
tr_trade_timestamp,
tr_trade_price,
tr_trade_volume,
tr_ask_bid,
tr_trade_date_utc,
tr_trade_time_utc,
tr_trade_date_kst,
tr_trade_time_kst,
tr_collected_at,
tr_collected_ms,
day_of_week,
korean_name
)
SELECT
NULL,
market,
trade_date,
trade_time,
trade_date_kst,
trade_time_kst,
opening_price,
high_price,
low_price,
trade_price,
prev_closing_price,
`change`,
change_price,
change_rate,
signed_change_price,
signed_change_rate,
trade_volume,
acc_trade_volume,
acc_trade_volume_24h,
acc_trade_price,
acc_trade_price_24h,
highest_52_week_price,
highest_52_week_date,
lowest_52_week_price,
lowest_52_week_date,
collected_at,
collected_ms,
ob_timestamp,
ob_total_ask_size,
ob_total_bid_size,
ob_units,
ob_collected_at,
ob_collected_ms,
tr_trade_timestamp,
tr_trade_price,
tr_trade_volume,
tr_ask_bid,
tr_trade_date_utc,
tr_trade_time_utc,
tr_trade_date_kst,
tr_trade_time_kst,
tr_collected_at,
tr_collected_ms,
day_of_week,
korean_name
FROM upbit_data.daemon_upbit_Ticker
|
|||||
| ENABLED |
stats_bybit 통계_통계 플랫폼에 바이비트 통계값을 넣는다_실시간 |
RECURRING EVERY 1 SECOND |
2026-04-19 20:41:21 | 계산 중... | |
|
INSERT INTO stats_direction_01 (
market,
collected_at,
fundingRate,
nextFundingTime,
openInterest,
openInterestValue,
markPrice,
indexPrice,
fxRate,
bybit_change_rate,
bybit_current_price,
current_price
)
SELECT
t.symbol,
t.collected_at,
t.fundingRate,
t.nextFundingTime,
t.openInterest,
t.openInterestValue,
t.markPrice,
t.indexPrice,
t.fxRate,
t.price24hPcnt,
t.lastPrice,
t.lastPrice
FROM daemon_bybit_Ticker AS t
INNER JOIN stats_direction_01 AS s ON t.symbol = s.market
ON DUPLICATE KEY UPDATE
collected_at = VALUES(collected_at),
fundingRate = VALUES(fundingRate),
nextFundingTime = VALUES(nextFundingTime),
openInterest = VALUES(openInterest),
openInterestValue = VALUES(openInterestValue),
markPrice = VALUES(markPrice),
indexPrice = VALUES(indexPrice),
fxRate = VALUES(fxRate),
bybit_change_rate = VALUES(bybit_change_rate),
bybit_current_price = VALUES(bybit_current_price),
current_price = VALUES(current_price)
|
|||||
| ENABLED |
stats_direction_01_1s 방향_방향 통계 실시간을 1초 테이블에 실시간 복사_복사 |
RECURRING EVERY 1 SECOND |
2026-04-19 20:41:21 | 계산 중... | |
|
INSERT INTO upbit_data.stats_direction_01_1s (
market, wr_datetime,
side_plus, side_minus, side_total,
side_plus_cnt, side_minus_cnt, side_total_cnt,
side_avg, acc_bid_volume, acc_ask_volume, net_vol,
trade_price, change_rate,
chg_dir, chg_dir_sum,
chg_up_streak, chg_down_streak,
chg_up_streak_max, chg_down_streak_max,
chg_rate_avg, chg_rate_avg_cnt
)
SELECT
s.market,
s.wr_datetime,
s.side_plus, s.side_minus, s.side_total,
CASE WHEN (s.side_total_cnt - IFNULL(pm.side_total_cnt, s.side_total_cnt)) > 0 THEN 1 ELSE 0 END AS side_plus_cnt,
CASE WHEN (s.side_total_cnt - IFNULL(pm.side_total_cnt, s.side_total_cnt)) < 0 THEN -1 ELSE 0 END AS side_minus_cnt,
s.side_total_cnt,
s.side_avg, s.acc_bid_volume, s.acc_ask_volume, s.net_vol,
s.trade_price, s.change_rate,
CASE
WHEN (s.chg_dir_sum - IFNULL(pm.chg_dir_sum, s.chg_dir_sum)) > 0 THEN 1
WHEN (s.chg_dir_sum - IFNULL(pm.chg_dir_sum, s.chg_dir_sum)) < 0 THEN -1
ELSE 0
END AS chg_dir,
s.chg_dir_sum,
CASE
WHEN (s.chg_dir_sum - IFNULL(pm.chg_dir_sum, s.chg_dir_sum)) > 0 THEN IFNULL(pm.chg_up_streak, 0) + 1
ELSE 0
END AS chg_up_streak,
CASE
WHEN (s.chg_dir_sum - IFNULL(pm.chg_dir_sum, s.chg_dir_sum)) < 0 THEN IFNULL(pm.chg_down_streak, 0) + 1
ELSE 0
END AS chg_down_streak,
GREATEST(
IFNULL(pm.chg_up_streak_max, 0),
CASE
WHEN (s.chg_dir_sum - IFNULL(pm.chg_dir_sum, s.chg_dir_sum)) > 0 THEN IFNULL(pm.chg_up_streak, 0) + 1
ELSE 0
END
) AS chg_up_streak_max,
GREATEST(
IFNULL(pm.chg_down_streak_max, 0),
CASE
WHEN (s.chg_dir_sum - IFNULL(pm.chg_dir_sum, s.chg_dir_sum)) < 0 THEN IFNULL(pm.chg_down_streak, 0) + 1
ELSE 0
END
) AS chg_down_streak_max,
s.chg_rate_avg, s.chg_rate_avg_cnt
FROM upbit_data.stats_direction_01 s
LEFT JOIN (
SELECT market, MAX(wr_id) AS max_id
FROM upbit_data.stats_direction_01_1s
GROUP BY market
) last ON last.market = s.market
LEFT JOIN upbit_data.stats_direction_01_1s pm
ON pm.market = last.market AND pm.wr_id = last.max_id
WHERE s.wr_datetime >= NOW() - INTERVAL 10 SECOND
AND NOT EXISTS (
SELECT 1
FROM upbit_data.stats_direction_01_1s m
WHERE m.market = s.market
AND m.wr_datetime = s.wr_datetime
)
|
|||||
| ENABLED |
stats_upbit 통계_통계 플랫폼에 업비트 통계값을 넣는다_실시간 |
RECURRING EVERY 1 SECOND |
2026-04-19 20:41:21 | 계산 중... | |
|
INSERT INTO stats_direction_01 (
market,
collected_at,
upbit_change_rate,
current_price
)
SELECT
t.market,
t.collected_at,
t.change_rate,
t.trade_price
FROM daemon_upbit_Ticker AS t
INNER JOIN stats_direction_01 AS s ON t.market = s.market
ON DUPLICATE KEY UPDATE
collected_at = VALUES(collected_at),
upbit_change_rate = VALUES(upbit_change_rate),
current_price = VALUES(current_price)
|
|||||
| ENABLED |
ev_bybit_coin_1m 플랫폼_바이비트 플랫폼 테이블을 1분 단위 테이블로 복사_복사 |
RECURRING EVERY 1 MINUTE |
2026-04-19 20:41:00 | 계산 중... | |
|
INSERT INTO daemon_bybit_coin_1m (
symbol, korean_name, `time`,
status, baseCoin, quoteCoin, settleCoin, optionsType,
launchTime, priceScale,
minLeverage, maxLeverage, leverageStep,
minPrice, maxPrice, tickSize,
maxOrderQty, minOrderQty, qtyStep, postOnlyMaxOrderQty,
unifiedMarginTrade, fundingInterval, copyTrading,
upperLimitPrice, lowerLimitPrice,
lastPrice, indexPrice, markPrice,
prevPrice24h, price24hPcnt, highPrice24h, lowPrice24h, prevPrice1h,
openInterest, openInterestValue,
turnover24h, volume24h,
fundingRate, nextFundingTime,
ask1Size, bid1Price, ask1Price, bid1Size,
execId, price, size, side, isAdlTrade, mPnL, isBlockTrade,
start, `open`, high, low, `close`, volume, turnover,
m_close, i_close, p_close,
buyRatio, sellRatio, period,
riskId, isLowestRisk, maintenanceMargin, initialMargin, `limit`
)
SELECT
symbol, korean_name,
UNIX_TIMESTAMP(NOW(3))*1000,
status, baseCoin, quoteCoin, settleCoin, optionsType,
launchTime, priceScale,
minLeverage, maxLeverage, leverageStep,
minPrice, maxPrice, tickSize,
maxOrderQty, minOrderQty, qtyStep, postOnlyMaxOrderQty,
unifiedMarginTrade, fundingInterval, copyTrading,
upperLimitPrice, lowerLimitPrice,
lastPrice, indexPrice, markPrice,
prevPrice24h, price24hPcnt, highPrice24h, lowPrice24h, prevPrice1h,
openInterest, openInterestValue,
turnover24h, volume24h,
fundingRate, nextFundingTime,
ask1Size, bid1Price, ask1Price, bid1Size,
execId, price, size, side, isAdlTrade,
NULLIF(mPnL, ''),
isBlockTrade,
start, `open`, high, low, `close`, volume, turnover,
m_close, i_close, p_close,
buyRatio, sellRatio, period,
riskId, isLowestRisk, maintenanceMargin, initialMargin, `limit`
FROM daemon_bybit_Ticker
|
|||||
| ENABLED |
ev_cleanup_candle_1m_except_core7 플랫폼_1분 단위 데이터 수집 : 24시간 이후 데이터는 1시간 단위 삭제한다._삭제 |
RECURRING EVERY 1 MINUTE |
2026-04-19 20:41:00 | 계산 중... | |
|
DELETE FROM daemon_upbit_coin_1m
WHERE timestamp < (NOW() - INTERVAL 25 HOUR)
AND market NOT IN (
'KRW-BTC',
'KRW-ETH',
'KRW-XRP',
'KRW-ADA',
'KRW-SOL',
'KRW-DOGE',
'KRW-BCH'
)
|
|||||
| ENABLED |
ev_cleanup_candle_1s_except 플랫폼_1초 단위 데이터 수집 : 24시간 이후 데이터는 1시간 단위 삭제한다._삭제 |
RECURRING EVERY 1 MINUTE |
2026-04-19 20:41:00 | 계산 중... | |
|
DELETE FROM upbit_data.daemon_upbit_coin_1s
WHERE collected_at < (NOW() - INTERVAL 25 HOUR)
|
|||||
| ENABLED |
ev_cleanup_candle_5m_except_core7 플랫폼_5분 단위 데이터 수집 : 24시간 이후 데이터는 1시간 단위 삭제한다._삭제 |
RECURRING EVERY 1 MINUTE |
2026-04-19 20:41:00 | 계산 중... | |
|
DELETE FROM daemon_upbit_coin_5m
WHERE timestamp < (NOW() - INTERVAL 25 HOUR)
AND market NOT IN (
'KRW-BTC',
'KRW-ETH',
'KRW-XRP',
'KRW-ADA',
'KRW-SOL',
'KRW-DOGE',
'KRW-BCH'
)
|
|||||
| ENABLED |
ev_upbit_coin_1m 플랫폼_플랫폼 테이블을 1분 단위 테이블로 복사_복사 |
RECURRING EVERY 1 MINUTE |
2026-04-19 20:41:00 | 계산 중... | |
|
INSERT INTO upbit_data.daemon_upbit_coin_1m (
id,
market,
trade_date,
trade_time,
trade_date_kst,
trade_time_kst,
opening_price,
high_price,
low_price,
trade_price,
prev_closing_price,
`change`,
change_price,
change_rate,
signed_change_price,
signed_change_rate,
trade_volume,
acc_trade_volume,
acc_trade_volume_24h,
acc_trade_price,
acc_trade_price_24h,
highest_52_week_price,
highest_52_week_date,
lowest_52_week_price,
lowest_52_week_date,
collected_at,
collected_ms,
ob_timestamp,
ob_total_ask_size,
ob_total_bid_size,
ob_units,
ob_collected_at,
ob_collected_ms,
tr_trade_timestamp,
tr_trade_price,
tr_trade_volume,
tr_ask_bid,
tr_trade_date_utc,
tr_trade_time_utc,
tr_trade_date_kst,
tr_trade_time_kst,
tr_collected_at,
tr_collected_ms,
day_of_week,
korean_name
)
SELECT
NULL,
market,
trade_date,
trade_time,
trade_date_kst,
trade_time_kst,
opening_price,
high_price,
low_price,
trade_price,
prev_closing_price,
`change`,
change_price,
change_rate,
signed_change_price,
signed_change_rate,
trade_volume,
acc_trade_volume,
acc_trade_volume_24h,
acc_trade_price,
acc_trade_price_24h,
highest_52_week_price,
highest_52_week_date,
lowest_52_week_price,
lowest_52_week_date,
collected_at,
collected_ms,
ob_timestamp,
ob_total_ask_size,
ob_total_bid_size,
ob_units,
ob_collected_at,
ob_collected_ms,
tr_trade_timestamp,
tr_trade_price,
tr_trade_volume,
tr_ask_bid,
tr_trade_date_utc,
tr_trade_time_utc,
tr_trade_date_kst,
tr_trade_time_kst,
tr_collected_at,
tr_collected_ms,
day_of_week,
korean_name
FROM upbit_data.daemon_upbit_Ticker
|
|||||
| ENABLED |
ev_upbit_user_1m 개인키_플랫폼 테이블을 1분 단위 테이블로 복사_복사 |
RECURRING EVERY 1 MINUTE |
2026-04-19 20:41:00 | 계산 중... | |
|
INSERT INTO daemon_upbit_user_1m
(currency, balance, locked, avg_buy_price, avg_buy_price_modified, unit_currency,
collected_at, collected_ms, current_price, evaluation_amount, buy_amount,
profit_amount, profit_rate, total_asset_value, total_profit_amount,
total_profit_rate, cash_balance)
SELECT
currency, balance, locked, avg_buy_price, avg_buy_price_modified, unit_currency,
collected_at, collected_ms, current_price, evaluation_amount, buy_amount,
profit_amount, profit_rate, total_asset_value, total_profit_amount,
total_profit_rate, cash_balance
FROM daemon_upbit_Ticker_user
ON DUPLICATE KEY UPDATE
balance=VALUES(balance),
locked=VALUES(locked),
avg_buy_price=VALUES(avg_buy_price),
avg_buy_price_modified=VALUES(avg_buy_price_modified),
unit_currency=VALUES(unit_currency),
collected_at=VALUES(collected_at),
current_price=VALUES(current_price),
evaluation_amount=VALUES(evaluation_amount),
buy_amount=VALUES(buy_amount),
profit_amount=VALUES(profit_amount),
profit_rate=VALUES(profit_rate),
total_asset_value=VALUES(total_asset_value),
total_profit_amount=VALUES(total_profit_amount),
total_profit_rate=VALUES(total_profit_rate),
cash_balance=VALUES(cash_balance)
|
|||||
| ENABLED |
stats_direction_01_1m 방향_방향 통계 실시간을 1분 테이블에 실시간 복사_복사 |
RECURRING EVERY 1 MINUTE |
2026-04-19 20:41:00 | 계산 중... | |
|
INSERT INTO upbit_data.stats_direction_01_1m (
market, wr_datetime,
side_plus, side_minus, side_total,
side_plus_cnt, side_minus_cnt, side_total_cnt,
side_avg, acc_bid_volume, acc_ask_volume, net_vol,
trade_price, change_rate,
chg_dir, chg_dir_sum,
chg_up_streak, chg_down_streak,
chg_up_streak_max, chg_down_streak_max,
chg_rate_avg, chg_rate_avg_cnt
)
SELECT
s.market,
s.wr_datetime,
s.side_plus, s.side_minus, s.side_total,
CASE WHEN (s.side_total_cnt - IFNULL(pm.side_total_cnt, s.side_total_cnt)) > 0 THEN 1 ELSE 0 END AS side_plus_cnt,
CASE WHEN (s.side_total_cnt - IFNULL(pm.side_total_cnt, s.side_total_cnt)) < 0 THEN -1 ELSE 0 END AS side_minus_cnt,
s.side_total_cnt,
s.side_avg, s.acc_bid_volume, s.acc_ask_volume, s.net_vol,
s.trade_price, s.change_rate,
CASE
WHEN (s.chg_dir_sum - IFNULL(pm.chg_dir_sum, s.chg_dir_sum)) > 0 THEN 1
WHEN (s.chg_dir_sum - IFNULL(pm.chg_dir_sum, s.chg_dir_sum)) < 0 THEN -1
ELSE 0
END AS chg_dir,
s.chg_dir_sum,
CASE
WHEN (s.chg_dir_sum - IFNULL(pm.chg_dir_sum, s.chg_dir_sum)) > 0 THEN IFNULL(pm.chg_up_streak, 0) + 1
ELSE 0
END AS chg_up_streak,
CASE
WHEN (s.chg_dir_sum - IFNULL(pm.chg_dir_sum, s.chg_dir_sum)) < 0 THEN IFNULL(pm.chg_down_streak, 0) + 1
ELSE 0
END AS chg_down_streak,
GREATEST(
IFNULL(pm.chg_up_streak_max, 0),
CASE
WHEN (s.chg_dir_sum - IFNULL(pm.chg_dir_sum, s.chg_dir_sum)) > 0 THEN IFNULL(pm.chg_up_streak, 0) + 1
ELSE 0
END
) AS chg_up_streak_max,
GREATEST(
IFNULL(pm.chg_down_streak_max, 0),
CASE
WHEN (s.chg_dir_sum - IFNULL(pm.chg_dir_sum, s.chg_dir_sum)) < 0 THEN IFNULL(pm.chg_down_streak, 0) + 1
ELSE 0
END
) AS chg_down_streak_max,
s.chg_rate_avg, s.chg_rate_avg_cnt
FROM upbit_data.stats_direction_01 s
LEFT JOIN (
SELECT market, MAX(wr_id) AS max_id
FROM upbit_data.stats_direction_01_1m
GROUP BY market
) last ON last.market = s.market
LEFT JOIN upbit_data.stats_direction_01_1m pm
ON pm.market = last.market AND pm.wr_id = last.max_id
WHERE s.wr_datetime >= NOW() - INTERVAL 2 MINUTE
AND NOT EXISTS (
SELECT 1
FROM upbit_data.stats_direction_01_1m m
WHERE m.market = s.market
AND m.wr_datetime = s.wr_datetime
)
|
|||||
| ENABLED |
ev_bybit_coin_5m 플랫폼_바이비트 플랫폼 테이블을 5분 단위 테이블 복사_복사 |
RECURRING EVERY 5 MINUTE |
2026-04-19 20:40:00 | 계산 중... | |
|
INSERT INTO daemon_bybit_coin_5m (
symbol, korean_name, `time`,
status, baseCoin, quoteCoin, settleCoin, optionsType,
launchTime, priceScale,
minLeverage, maxLeverage, leverageStep,
minPrice, maxPrice, tickSize,
maxOrderQty, minOrderQty, qtyStep, postOnlyMaxOrderQty,
unifiedMarginTrade, fundingInterval, copyTrading,
upperLimitPrice, lowerLimitPrice,
lastPrice, indexPrice, markPrice,
prevPrice24h, price24hPcnt, highPrice24h, lowPrice24h, prevPrice1h,
openInterest, openInterestValue,
turnover24h, volume24h,
fundingRate, nextFundingTime,
ask1Size, bid1Price, ask1Price, bid1Size,
execId, price, size, side, isAdlTrade, mPnL, isBlockTrade,
start, `open`, high, low, `close`, volume, turnover,
m_close, i_close, p_close,
buyRatio, sellRatio, period,
riskId, isLowestRisk, maintenanceMargin, initialMargin, `limit`
)
SELECT
symbol, korean_name,
UNIX_TIMESTAMP(NOW(3))*1000,
status, baseCoin, quoteCoin, settleCoin, optionsType,
launchTime, priceScale,
minLeverage, maxLeverage, leverageStep,
minPrice, maxPrice, tickSize,
maxOrderQty, minOrderQty, qtyStep, postOnlyMaxOrderQty,
unifiedMarginTrade, fundingInterval, copyTrading,
upperLimitPrice, lowerLimitPrice,
lastPrice, indexPrice, markPrice,
prevPrice24h, price24hPcnt, highPrice24h, lowPrice24h, prevPrice1h,
openInterest, openInterestValue,
turnover24h, volume24h,
fundingRate, nextFundingTime,
ask1Size, bid1Price, ask1Price, bid1Size,
execId, price, size, side, isAdlTrade,
NULLIF(mPnL, ''),
isBlockTrade,
start, `open`, high, low, `close`, volume, turnover,
m_close, i_close, p_close,
buyRatio, sellRatio, period,
riskId, isLowestRisk, maintenanceMargin, initialMargin, `limit`
FROM daemon_bybit_Ticker
|
|||||
| ENABLED |
ev_upbit_coin_5m 플랫폼_플랫폼 테이블을 5분 단위 테이블 복사_복사 |
RECURRING EVERY 5 MINUTE |
2026-04-19 20:40:00 | 계산 중... | |
|
INSERT INTO upbit_data.daemon_upbit_coin_5m (
id,
market,
trade_date,
trade_time,
trade_date_kst,
trade_time_kst,
opening_price,
high_price,
low_price,
trade_price,
prev_closing_price,
`change`,
change_price,
change_rate,
signed_change_price,
signed_change_rate,
trade_volume,
acc_trade_volume,
acc_trade_volume_24h,
acc_trade_price,
acc_trade_price_24h,
highest_52_week_price,
highest_52_week_date,
lowest_52_week_price,
lowest_52_week_date,
collected_at,
collected_ms,
ob_timestamp,
ob_total_ask_size,
ob_total_bid_size,
ob_units,
ob_collected_at,
ob_collected_ms,
tr_trade_timestamp,
tr_trade_price,
tr_trade_volume,
tr_ask_bid,
tr_trade_date_utc,
tr_trade_time_utc,
tr_trade_date_kst,
tr_trade_time_kst,
tr_collected_at,
tr_collected_ms,
day_of_week,
korean_name
)
SELECT
NULL,
market,
trade_date,
trade_time,
trade_date_kst,
trade_time_kst,
opening_price,
high_price,
low_price,
trade_price,
prev_closing_price,
`change`,
change_price,
change_rate,
signed_change_price,
signed_change_rate,
trade_volume,
acc_trade_volume,
acc_trade_volume_24h,
acc_trade_price,
acc_trade_price_24h,
highest_52_week_price,
highest_52_week_date,
lowest_52_week_price,
lowest_52_week_date,
collected_at,
collected_ms,
ob_timestamp,
ob_total_ask_size,
ob_total_bid_size,
ob_units,
ob_collected_at,
ob_collected_ms,
tr_trade_timestamp,
tr_trade_price,
tr_trade_volume,
tr_ask_bid,
tr_trade_date_utc,
tr_trade_time_utc,
tr_trade_date_kst,
tr_trade_time_kst,
tr_collected_at,
tr_collected_ms,
day_of_week,
korean_name
FROM upbit_data.daemon_upbit_Ticker
|
|||||
| ENABLED |
ev_upbit_user_5m 개인키_플랫폼 테이블을 5분 단위 테이블로 복사_복사 |
RECURRING EVERY 5 MINUTE |
2026-04-19 20:40:00 | 계산 중... | |
|
INSERT INTO daemon_upbit_user_5m
(currency, balance, locked, avg_buy_price, avg_buy_price_modified, unit_currency,
collected_at, collected_ms, current_price, evaluation_amount, buy_amount,
profit_amount, profit_rate, total_asset_value, total_profit_amount,
total_profit_rate, cash_balance)
SELECT
currency, balance, locked, avg_buy_price, avg_buy_price_modified, unit_currency,
collected_at, collected_ms, current_price, evaluation_amount, buy_amount,
profit_amount, profit_rate, total_asset_value, total_profit_amount,
total_profit_rate, cash_balance
FROM daemon_upbit_Ticker_user
ON DUPLICATE KEY UPDATE
balance=VALUES(balance),
locked=VALUES(locked),
avg_buy_price=VALUES(avg_buy_price),
avg_buy_price_modified=VALUES(avg_buy_price_modified),
unit_currency=VALUES(unit_currency),
collected_at=VALUES(collected_at),
current_price=VALUES(current_price),
evaluation_amount=VALUES(evaluation_amount),
buy_amount=VALUES(buy_amount),
profit_amount=VALUES(profit_amount),
profit_rate=VALUES(profit_rate),
total_asset_value=VALUES(total_asset_value),
total_profit_amount=VALUES(total_profit_amount),
total_profit_rate=VALUES(total_profit_rate),
cash_balance=VALUES(cash_balance)
|
|||||
| ENABLED |
stats_direction_01_1s_clean 통계_통계.1 테이블 10분 보관 11분 단위 삭제_삭제 |
RECURRING EVERY 11 MINUTE |
2026-04-19 20:40:00 | 계산 중... | |
|
DELETE FROM upbit_data.stats_direction_01_1s
WHERE collected_at < (NOW() - INTERVAL 10 MINUTE)
|
|||||
| ENABLED |
stats_direction_01_5m 동계_방향 통계 실시간을 5분 테이블에 실시간 복사_복사 |
RECURRING EVERY 5 MINUTE |
2026-04-19 20:40:00 | 계산 중... | |
|
INSERT INTO upbit_data.stats_direction_01_5m (
market, wr_datetime,
side_plus, side_minus, side_total,
side_plus_cnt, side_minus_cnt, side_total_cnt,
side_avg, acc_bid_volume, acc_ask_volume, net_vol,
trade_price, change_rate,
chg_dir, chg_dir_sum,
chg_up_streak, chg_down_streak,
chg_up_streak_max, chg_down_streak_max,
chg_rate_avg, chg_rate_avg_cnt
)
SELECT
s.market,
s.wr_datetime,
s.side_plus, s.side_minus, s.side_total,
CASE WHEN (s.side_total_cnt - IFNULL(pm.side_total_cnt, s.side_total_cnt)) > 0 THEN 1 ELSE 0 END AS side_plus_cnt,
CASE WHEN (s.side_total_cnt - IFNULL(pm.side_total_cnt, s.side_total_cnt)) < 0 THEN -1 ELSE 0 END AS side_minus_cnt,
s.side_total_cnt,
s.side_avg, s.acc_bid_volume, s.acc_ask_volume, s.net_vol,
s.trade_price, s.change_rate,
CASE
WHEN (s.chg_dir_sum - IFNULL(pm.chg_dir_sum, s.chg_dir_sum)) > 0 THEN 1
WHEN (s.chg_dir_sum - IFNULL(pm.chg_dir_sum, s.chg_dir_sum)) < 0 THEN -1
ELSE 0
END AS chg_dir,
s.chg_dir_sum,
CASE
WHEN (s.chg_dir_sum - IFNULL(pm.chg_dir_sum, s.chg_dir_sum)) > 0 THEN IFNULL(pm.chg_up_streak, 0) + 1
ELSE 0
END AS chg_up_streak,
CASE
WHEN (s.chg_dir_sum - IFNULL(pm.chg_dir_sum, s.chg_dir_sum)) < 0 THEN IFNULL(pm.chg_down_streak, 0) + 1
ELSE 0
END AS chg_down_streak,
GREATEST(
IFNULL(pm.chg_up_streak_max, 0),
CASE
WHEN (s.chg_dir_sum - IFNULL(pm.chg_dir_sum, s.chg_dir_sum)) > 0 THEN IFNULL(pm.chg_up_streak, 0) + 1
ELSE 0
END
) AS chg_up_streak_max,
GREATEST(
IFNULL(pm.chg_down_streak_max, 0),
CASE
WHEN (s.chg_dir_sum - IFNULL(pm.chg_dir_sum, s.chg_dir_sum)) < 0 THEN IFNULL(pm.chg_down_streak, 0) + 1
ELSE 0
END
) AS chg_down_streak_max,
s.chg_rate_avg, s.chg_rate_avg_cnt
FROM upbit_data.stats_direction_01 s
LEFT JOIN (
SELECT market, MAX(wr_id) AS max_id
FROM upbit_data.stats_direction_01_5m
GROUP BY market
) last ON last.market = s.market
LEFT JOIN upbit_data.stats_direction_01_5m pm
ON pm.market = last.market AND pm.wr_id = last.max_id
WHERE s.wr_datetime >= NOW() - INTERVAL 10 MINUTE
AND NOT EXISTS (
SELECT 1
FROM upbit_data.stats_direction_01_5m m
WHERE m.market = s.market
AND m.wr_datetime = s.wr_datetime
)
|
|||||
| ENABLED |
ev_bybit_coin_15m 플랫폼_바이비트 플랫폼 테이블을 15분 단위 테이블 복사_복사 |
RECURRING EVERY 15 MINUTE |
2026-04-19 20:30:00 | 계산 중... | |
|
INSERT INTO daemon_bybit_coin_15m (
symbol, korean_name, `time`,
status, baseCoin, quoteCoin, settleCoin, optionsType,
launchTime, priceScale,
minLeverage, maxLeverage, leverageStep,
minPrice, maxPrice, tickSize,
maxOrderQty, minOrderQty, qtyStep, postOnlyMaxOrderQty,
unifiedMarginTrade, fundingInterval, copyTrading,
upperLimitPrice, lowerLimitPrice,
lastPrice, indexPrice, markPrice,
prevPrice24h, price24hPcnt, highPrice24h, lowPrice24h, prevPrice1h,
openInterest, openInterestValue,
turnover24h, volume24h,
fundingRate, nextFundingTime,
ask1Size, bid1Price, ask1Price, bid1Size,
execId, price, size, side, isAdlTrade, mPnL, isBlockTrade,
start, `open`, high, low, `close`, volume, turnover,
m_close, i_close, p_close,
buyRatio, sellRatio, period,
riskId, isLowestRisk, maintenanceMargin, initialMargin, `limit`
)
SELECT
symbol, korean_name,
UNIX_TIMESTAMP(NOW(3))*1000,
status, baseCoin, quoteCoin, settleCoin, optionsType,
launchTime, priceScale,
minLeverage, maxLeverage, leverageStep,
minPrice, maxPrice, tickSize,
maxOrderQty, minOrderQty, qtyStep, postOnlyMaxOrderQty,
unifiedMarginTrade, fundingInterval, copyTrading,
upperLimitPrice, lowerLimitPrice,
lastPrice, indexPrice, markPrice,
prevPrice24h, price24hPcnt, highPrice24h, lowPrice24h, prevPrice1h,
openInterest, openInterestValue,
turnover24h, volume24h,
fundingRate, nextFundingTime,
ask1Size, bid1Price, ask1Price, bid1Size,
execId, price, size, side, isAdlTrade,
NULLIF(mPnL, ''),
isBlockTrade,
start, `open`, high, low, `close`, volume, turnover,
m_close, i_close, p_close,
buyRatio, sellRatio, period,
riskId, isLowestRisk, maintenanceMargin, initialMargin, `limit`
FROM daemon_bybit_Ticker
|
|||||
| ENABLED |
ev_bybit_coin_30m 플랫폼_바이비트 플랫폼 테이블을 30분 단위 테이블 복사_복사 |
RECURRING EVERY 30 MINUTE |
2026-04-19 20:30:00 | 계산 중... | |
|
INSERT INTO daemon_bybit_coin_30m (
symbol, korean_name, `time`,
status, baseCoin, quoteCoin, settleCoin, optionsType,
launchTime, priceScale,
minLeverage, maxLeverage, leverageStep,
minPrice, maxPrice, tickSize,
maxOrderQty, minOrderQty, qtyStep, postOnlyMaxOrderQty,
unifiedMarginTrade, fundingInterval, copyTrading,
upperLimitPrice, lowerLimitPrice,
lastPrice, indexPrice, markPrice,
prevPrice24h, price24hPcnt, highPrice24h, lowPrice24h, prevPrice1h,
openInterest, openInterestValue,
turnover24h, volume24h,
fundingRate, nextFundingTime,
ask1Size, bid1Price, ask1Price, bid1Size,
execId, price, size, side, isAdlTrade, mPnL, isBlockTrade,
start, `open`, high, low, `close`, volume, turnover,
m_close, i_close, p_close,
buyRatio, sellRatio, period,
riskId, isLowestRisk, maintenanceMargin, initialMargin, `limit`
)
SELECT
symbol, korean_name,
UNIX_TIMESTAMP(NOW(3))*1000,
status, baseCoin, quoteCoin, settleCoin, optionsType,
launchTime, priceScale,
minLeverage, maxLeverage, leverageStep,
minPrice, maxPrice, tickSize,
maxOrderQty, minOrderQty, qtyStep, postOnlyMaxOrderQty,
unifiedMarginTrade, fundingInterval, copyTrading,
upperLimitPrice, lowerLimitPrice,
lastPrice, indexPrice, markPrice,
prevPrice24h, price24hPcnt, highPrice24h, lowPrice24h, prevPrice1h,
openInterest, openInterestValue,
turnover24h, volume24h,
fundingRate, nextFundingTime,
ask1Size, bid1Price, ask1Price, bid1Size,
execId, price, size, side, isAdlTrade,
NULLIF(mPnL, ''),
isBlockTrade,
start, `open`, high, low, `close`, volume, turnover,
m_close, i_close, p_close,
buyRatio, sellRatio, period,
riskId, isLowestRisk, maintenanceMargin, initialMargin, `limit`
FROM daemon_bybit_Ticker
|
|||||
| ENABLED |
ev_upbit_coin_15m 플랫폼_플랫폼 테이블을 15분 단위 테이블로 복사_복사 |
RECURRING EVERY 15 MINUTE |
2026-04-19 20:30:00 | 계산 중... | |
|
INSERT INTO upbit_data.daemon_upbit_coin_15m (
id,
market,
trade_date,
trade_time,
trade_date_kst,
trade_time_kst,
opening_price,
high_price,
low_price,
trade_price,
prev_closing_price,
`change`,
change_price,
change_rate,
signed_change_price,
signed_change_rate,
trade_volume,
acc_trade_volume,
acc_trade_volume_24h,
acc_trade_price,
acc_trade_price_24h,
highest_52_week_price,
highest_52_week_date,
lowest_52_week_price,
lowest_52_week_date,
collected_at,
collected_ms,
ob_timestamp,
ob_total_ask_size,
ob_total_bid_size,
ob_units,
ob_collected_at,
ob_collected_ms,
tr_trade_timestamp,
tr_trade_price,
tr_trade_volume,
tr_ask_bid,
tr_trade_date_utc,
tr_trade_time_utc,
tr_trade_date_kst,
tr_trade_time_kst,
tr_collected_at,
tr_collected_ms,
day_of_week,
korean_name
)
SELECT
NULL,
market,
trade_date,
trade_time,
trade_date_kst,
trade_time_kst,
opening_price,
high_price,
low_price,
trade_price,
prev_closing_price,
`change`,
change_price,
change_rate,
signed_change_price,
signed_change_rate,
trade_volume,
acc_trade_volume,
acc_trade_volume_24h,
acc_trade_price,
acc_trade_price_24h,
highest_52_week_price,
highest_52_week_date,
lowest_52_week_price,
lowest_52_week_date,
collected_at,
collected_ms,
ob_timestamp,
ob_total_ask_size,
ob_total_bid_size,
ob_units,
ob_collected_at,
ob_collected_ms,
tr_trade_timestamp,
tr_trade_price,
tr_trade_volume,
tr_ask_bid,
tr_trade_date_utc,
tr_trade_time_utc,
tr_trade_date_kst,
tr_trade_time_kst,
tr_collected_at,
tr_collected_ms,
day_of_week,
korean_name
FROM upbit_data.daemon_upbit_Ticker
|
|||||
| ENABLED |
ev_upbit_coin_30m 플랫폼_플랫폼 테이블을 30분 단위 테이블로 복사_복사 |
RECURRING EVERY 30 MINUTE |
2026-04-19 20:30:00 | 계산 중... | |
|
INSERT INTO upbit_data.daemon_upbit_coin_30m (
id,
market,
trade_date,
trade_time,
trade_date_kst,
trade_time_kst,
opening_price,
high_price,
low_price,
trade_price,
prev_closing_price,
`change`,
change_price,
change_rate,
signed_change_price,
signed_change_rate,
trade_volume,
acc_trade_volume,
acc_trade_volume_24h,
acc_trade_price,
acc_trade_price_24h,
highest_52_week_price,
highest_52_week_date,
lowest_52_week_price,
lowest_52_week_date,
collected_at,
collected_ms,
ob_timestamp,
ob_total_ask_size,
ob_total_bid_size,
ob_units,
ob_collected_at,
ob_collected_ms,
tr_trade_timestamp,
tr_trade_price,
tr_trade_volume,
tr_ask_bid,
tr_trade_date_utc,
tr_trade_time_utc,
tr_trade_date_kst,
tr_trade_time_kst,
tr_collected_at,
tr_collected_ms,
day_of_week,
korean_name
)
SELECT
NULL,
market,
trade_date,
trade_time,
trade_date_kst,
trade_time_kst,
opening_price,
high_price,
low_price,
trade_price,
prev_closing_price,
`change`,
change_price,
change_rate,
signed_change_price,
signed_change_rate,
trade_volume,
acc_trade_volume,
acc_trade_volume_24h,
acc_trade_price,
acc_trade_price_24h,
highest_52_week_price,
highest_52_week_date,
lowest_52_week_price,
lowest_52_week_date,
collected_at,
collected_ms,
ob_timestamp,
ob_total_ask_size,
ob_total_bid_size,
ob_units,
ob_collected_at,
ob_collected_ms,
tr_trade_timestamp,
tr_trade_price,
tr_trade_volume,
tr_ask_bid,
tr_trade_date_utc,
tr_trade_time_utc,
tr_trade_date_kst,
tr_trade_time_kst,
tr_collected_at,
tr_collected_ms,
day_of_week,
korean_name
FROM upbit_data.daemon_upbit_Ticker
|
|||||
| ENABLED |
ev_upbit_user_30m 개인키_플랫폼 테이블을 30분 단위 테이블로 복사_복사 |
RECURRING EVERY 30 MINUTE |
2026-04-19 20:30:00 | 계산 중... | |
|
INSERT INTO daemon_upbit_user_30m
(currency, balance, locked, avg_buy_price, avg_buy_price_modified, unit_currency,
collected_at, collected_ms, current_price, evaluation_amount, buy_amount,
profit_amount, profit_rate, total_asset_value, total_profit_amount,
total_profit_rate, cash_balance)
SELECT
currency, balance, locked, avg_buy_price, avg_buy_price_modified, unit_currency,
collected_at, collected_ms, current_price, evaluation_amount, buy_amount,
profit_amount, profit_rate, total_asset_value, total_profit_amount,
total_profit_rate, cash_balance
FROM daemon_upbit_Ticker_user
ON DUPLICATE KEY UPDATE
balance=VALUES(balance),
locked=VALUES(locked),
avg_buy_price=VALUES(avg_buy_price),
avg_buy_price_modified=VALUES(avg_buy_price_modified),
unit_currency=VALUES(unit_currency),
collected_at=VALUES(collected_at),
current_price=VALUES(current_price),
evaluation_amount=VALUES(evaluation_amount),
buy_amount=VALUES(buy_amount),
profit_amount=VALUES(profit_amount),
profit_rate=VALUES(profit_rate),
total_asset_value=VALUES(total_asset_value),
total_profit_amount=VALUES(total_profit_amount),
total_profit_rate=VALUES(total_profit_rate),
cash_balance=VALUES(cash_balance)
|
|||||
| ENABLED |
stats_direction_01_15m 동계_방향 통계 실시간을 15분 테이블에 실시간 복사_복사 |
RECURRING EVERY 15 MINUTE |
2026-04-19 20:30:00 | 계산 중... | |
|
INSERT INTO upbit_data.stats_direction_01_15m (
market, wr_datetime,
side_plus, side_minus, side_total,
side_plus_cnt, side_minus_cnt, side_total_cnt,
side_avg, acc_bid_volume, acc_ask_volume, net_vol,
trade_price, change_rate,
chg_dir, chg_dir_sum,
chg_up_streak, chg_down_streak,
chg_up_streak_max, chg_down_streak_max,
chg_rate_avg, chg_rate_avg_cnt
)
SELECT
s.market,
s.wr_datetime,
s.side_plus, s.side_minus, s.side_total,
CASE WHEN (s.side_total_cnt - IFNULL(pm.side_total_cnt, s.side_total_cnt)) > 0 THEN 1 ELSE 0 END AS side_plus_cnt,
CASE WHEN (s.side_total_cnt - IFNULL(pm.side_total_cnt, s.side_total_cnt)) < 0 THEN -1 ELSE 0 END AS side_minus_cnt,
s.side_total_cnt,
s.side_avg, s.acc_bid_volume, s.acc_ask_volume, s.net_vol,
s.trade_price, s.change_rate,
CASE
WHEN (s.chg_dir_sum - IFNULL(pm.chg_dir_sum, s.chg_dir_sum)) > 0 THEN 1
WHEN (s.chg_dir_sum - IFNULL(pm.chg_dir_sum, s.chg_dir_sum)) < 0 THEN -1
ELSE 0
END AS chg_dir,
s.chg_dir_sum,
CASE
WHEN (s.chg_dir_sum - IFNULL(pm.chg_dir_sum, s.chg_dir_sum)) > 0 THEN IFNULL(pm.chg_up_streak, 0) + 1
ELSE 0
END AS chg_up_streak,
CASE
WHEN (s.chg_dir_sum - IFNULL(pm.chg_dir_sum, s.chg_dir_sum)) < 0 THEN IFNULL(pm.chg_down_streak, 0) + 1
ELSE 0
END AS chg_down_streak,
GREATEST(
IFNULL(pm.chg_up_streak_max, 0),
CASE
WHEN (s.chg_dir_sum - IFNULL(pm.chg_dir_sum, s.chg_dir_sum)) > 0 THEN IFNULL(pm.chg_up_streak, 0) + 1
ELSE 0
END
) AS chg_up_streak_max,
GREATEST(
IFNULL(pm.chg_down_streak_max, 0),
CASE
WHEN (s.chg_dir_sum - IFNULL(pm.chg_dir_sum, s.chg_dir_sum)) < 0 THEN IFNULL(pm.chg_down_streak, 0) + 1
ELSE 0
END
) AS chg_down_streak_max,
s.chg_rate_avg, s.chg_rate_avg_cnt
FROM upbit_data.stats_direction_01 s
LEFT JOIN (
SELECT market, MAX(wr_id) AS max_id
FROM upbit_data.stats_direction_01_15m
GROUP BY market
) last ON last.market = s.market
LEFT JOIN upbit_data.stats_direction_01_15m pm
ON pm.market = last.market AND pm.wr_id = last.max_id
WHERE s.wr_datetime >= NOW() - INTERVAL 30 MINUTE
AND NOT EXISTS (
SELECT 1
FROM upbit_data.stats_direction_01_15m m
WHERE m.market = s.market
AND m.wr_datetime = s.wr_datetime
)
|
|||||
| ENABLED |
cleanup_upbit_Ticker_user 자산_개인자산 25시간 보유 이후 데이터 1시간 단위 삭제_삭제 |
RECURRING EVERY 1 HOUR |
2026-04-19 20:10:00 | 계산 중... | |
|
DELETE FROM daemon_bybit_coin_1s
WHERE collected_at < NOW() - INTERVAL 25 HOUR
|
|||||
| ENABLED |
ev_bybit_coin_1h 플랫폼_바이비트 플랫폼 테이블을 1시간 단위 테이블 복사_복사 |
RECURRING EVERY 1 HOUR |
2026-04-19 20:00:00 | 계산 중... | |
|
INSERT INTO daemon_bybit_coin_1h (
symbol, korean_name, `time`,
status, baseCoin, quoteCoin, settleCoin, optionsType,
launchTime, priceScale,
minLeverage, maxLeverage, leverageStep,
minPrice, maxPrice, tickSize,
maxOrderQty, minOrderQty, qtyStep, postOnlyMaxOrderQty,
unifiedMarginTrade, fundingInterval, copyTrading,
upperLimitPrice, lowerLimitPrice,
lastPrice, indexPrice, markPrice,
prevPrice24h, price24hPcnt, highPrice24h, lowPrice24h, prevPrice1h,
openInterest, openInterestValue,
turnover24h, volume24h,
fundingRate, nextFundingTime,
ask1Size, bid1Price, ask1Price, bid1Size,
execId, price, size, side, isAdlTrade, mPnL, isBlockTrade,
start, `open`, high, low, `close`, volume, turnover,
m_close, i_close, p_close,
buyRatio, sellRatio, period,
riskId, isLowestRisk, maintenanceMargin, initialMargin, `limit`
)
SELECT
symbol, korean_name,
UNIX_TIMESTAMP(NOW(3))*1000,
status, baseCoin, quoteCoin, settleCoin, optionsType,
launchTime, priceScale,
minLeverage, maxLeverage, leverageStep,
minPrice, maxPrice, tickSize,
maxOrderQty, minOrderQty, qtyStep, postOnlyMaxOrderQty,
unifiedMarginTrade, fundingInterval, copyTrading,
upperLimitPrice, lowerLimitPrice,
lastPrice, indexPrice, markPrice,
prevPrice24h, price24hPcnt, highPrice24h, lowPrice24h, prevPrice1h,
openInterest, openInterestValue,
turnover24h, volume24h,
fundingRate, nextFundingTime,
ask1Size, bid1Price, ask1Price, bid1Size,
execId, price, size, side, isAdlTrade,
NULLIF(mPnL, ''),
isBlockTrade,
start, `open`, high, low, `close`, volume, turnover,
m_close, i_close, p_close,
buyRatio, sellRatio, period,
riskId, isLowestRisk, maintenanceMargin, initialMargin, `limit`
FROM daemon_bybit_Ticker
|
|||||
| ENABLED |
ev_upbit_coin_1h 플랫폼_플랫폼 테이블을 1시간 단위 테이블로 복사_복사 |
RECURRING EVERY 1 HOUR |
2026-04-19 20:00:00 | 계산 중... | |
|
INSERT INTO upbit_data.daemon_upbit_coin_1h (
id,
market,
trade_date,
trade_time,
trade_date_kst,
trade_time_kst,
opening_price,
high_price,
low_price,
trade_price,
prev_closing_price,
`change`,
change_price,
change_rate,
signed_change_price,
signed_change_rate,
trade_volume,
acc_trade_volume,
acc_trade_volume_24h,
acc_trade_price,
acc_trade_price_24h,
highest_52_week_price,
highest_52_week_date,
lowest_52_week_price,
lowest_52_week_date,
collected_at,
collected_ms,
ob_timestamp,
ob_total_ask_size,
ob_total_bid_size,
ob_units,
ob_collected_at,
ob_collected_ms,
tr_trade_timestamp,
tr_trade_price,
tr_trade_volume,
tr_ask_bid,
tr_trade_date_utc,
tr_trade_time_utc,
tr_trade_date_kst,
tr_trade_time_kst,
tr_collected_at,
tr_collected_ms,
day_of_week,
korean_name
)
SELECT
NULL,
market,
trade_date,
trade_time,
trade_date_kst,
trade_time_kst,
opening_price,
high_price,
low_price,
trade_price,
prev_closing_price,
`change`,
change_price,
change_rate,
signed_change_price,
signed_change_rate,
trade_volume,
acc_trade_volume,
acc_trade_volume_24h,
acc_trade_price,
acc_trade_price_24h,
highest_52_week_price,
highest_52_week_date,
lowest_52_week_price,
lowest_52_week_date,
collected_at,
collected_ms,
ob_timestamp,
ob_total_ask_size,
ob_total_bid_size,
ob_units,
ob_collected_at,
ob_collected_ms,
tr_trade_timestamp,
tr_trade_price,
tr_trade_volume,
tr_ask_bid,
tr_trade_date_utc,
tr_trade_time_utc,
tr_trade_date_kst,
tr_trade_time_kst,
tr_collected_at,
tr_collected_ms,
day_of_week,
korean_name
FROM upbit_data.daemon_upbit_Ticker
|
|||||
| ENABLED |
ev_upbit_user_1h 개인키_플랫폼 테이블을 1시간 단위 테이블로 복사_복사 |
RECURRING EVERY 1 HOUR |
2026-04-19 20:00:00 | 계산 중... | |
|
INSERT INTO daemon_upbit_user_1h
(currency, balance, locked, avg_buy_price, avg_buy_price_modified, unit_currency,
collected_at, collected_ms, current_price, evaluation_amount, buy_amount,
profit_amount, profit_rate, total_asset_value, total_profit_amount,
total_profit_rate, cash_balance)
SELECT
currency, balance, locked, avg_buy_price, avg_buy_price_modified, unit_currency,
collected_at, collected_ms, current_price, evaluation_amount, buy_amount,
profit_amount, profit_rate, total_asset_value, total_profit_amount,
total_profit_rate, cash_balance
FROM daemon_upbit_Ticker_user
ON DUPLICATE KEY UPDATE
balance=VALUES(balance),
locked=VALUES(locked),
avg_buy_price=VALUES(avg_buy_price),
avg_buy_price_modified=VALUES(avg_buy_price_modified),
unit_currency=VALUES(unit_currency),
collected_at=VALUES(collected_at),
current_price=VALUES(current_price),
evaluation_amount=VALUES(evaluation_amount),
buy_amount=VALUES(buy_amount),
profit_amount=VALUES(profit_amount),
profit_rate=VALUES(profit_rate),
total_asset_value=VALUES(total_asset_value),
total_profit_amount=VALUES(total_profit_amount),
total_profit_rate=VALUES(total_profit_rate),
cash_balance=VALUES(cash_balance)
|
|||||
| ENABLED |
stats_direction_01_1h 방향_방향 통계 실시간을 1시간 테이블에 실시간 복사_복사 |
RECURRING EVERY 1 HOUR |
2026-04-19 20:00:00 | 계산 중... | |
|
INSERT INTO upbit_data.stats_direction_01_1h (
market, wr_datetime,
side_plus, side_minus, side_total,
side_plus_cnt, side_minus_cnt, side_total_cnt,
side_avg, acc_bid_volume, acc_ask_volume, net_vol,
trade_price, change_rate,
chg_dir, chg_dir_sum,
chg_up_streak, chg_down_streak,
chg_up_streak_max, chg_down_streak_max,
chg_rate_avg, chg_rate_avg_cnt
)
SELECT
s.market,
s.wr_datetime,
s.side_plus, s.side_minus, s.side_total,
CASE WHEN (s.side_total_cnt - IFNULL(pm.side_total_cnt, s.side_total_cnt)) > 0 THEN 1 ELSE 0 END AS side_plus_cnt,
CASE WHEN (s.side_total_cnt - IFNULL(pm.side_total_cnt, s.side_total_cnt)) < 0 THEN -1 ELSE 0 END AS side_minus_cnt,
s.side_total_cnt,
s.side_avg, s.acc_bid_volume, s.acc_ask_volume, s.net_vol,
s.trade_price, s.change_rate,
CASE
WHEN (s.chg_dir_sum - IFNULL(pm.chg_dir_sum, s.chg_dir_sum)) > 0 THEN 1
WHEN (s.chg_dir_sum - IFNULL(pm.chg_dir_sum, s.chg_dir_sum)) < 0 THEN -1
ELSE 0
END AS chg_dir,
s.chg_dir_sum,
CASE
WHEN (s.chg_dir_sum - IFNULL(pm.chg_dir_sum, s.chg_dir_sum)) > 0 THEN IFNULL(pm.chg_up_streak, 0) + 1
ELSE 0
END AS chg_up_streak,
CASE
WHEN (s.chg_dir_sum - IFNULL(pm.chg_dir_sum, s.chg_dir_sum)) < 0 THEN IFNULL(pm.chg_down_streak, 0) + 1
ELSE 0
END AS chg_down_streak,
GREATEST(
IFNULL(pm.chg_up_streak_max, 0),
CASE
WHEN (s.chg_dir_sum - IFNULL(pm.chg_dir_sum, s.chg_dir_sum)) > 0 THEN IFNULL(pm.chg_up_streak, 0) + 1
ELSE 0
END
) AS chg_up_streak_max,
GREATEST(
IFNULL(pm.chg_down_streak_max, 0),
CASE
WHEN (s.chg_dir_sum - IFNULL(pm.chg_dir_sum, s.chg_dir_sum)) < 0 THEN IFNULL(pm.chg_down_streak, 0) + 1
ELSE 0
END
) AS chg_down_streak_max,
s.chg_rate_avg, s.chg_rate_avg_cnt
FROM upbit_data.stats_direction_01 s
LEFT JOIN (
SELECT market, MAX(wr_id) AS max_id
FROM upbit_data.stats_direction_01_1h
GROUP BY market
) last ON last.market = s.market
LEFT JOIN upbit_data.stats_direction_01_1h pm
ON pm.market = last.market AND pm.wr_id = last.max_id
WHERE s.wr_datetime >= NOW() - INTERVAL 2 HOUR
AND NOT EXISTS (
SELECT 1
FROM upbit_data.stats_direction_01_1h m
WHERE m.market = s.market
AND m.wr_datetime = s.wr_datetime
)
|
|||||
| ENABLED |
ev_bybit_coin_4h 플랫폼_바이비트 플랫폼 테이블을 4시간 단위 테이블 복사_복사 |
RECURRING EVERY 4 HOUR |
2026-04-19 17:00:00 | 계산 중... | |
|
INSERT INTO daemon_bybit_coin_4h (
symbol, korean_name, `time`,
status, baseCoin, quoteCoin, settleCoin, optionsType,
launchTime, priceScale,
minLeverage, maxLeverage, leverageStep,
minPrice, maxPrice, tickSize,
maxOrderQty, minOrderQty, qtyStep, postOnlyMaxOrderQty,
unifiedMarginTrade, fundingInterval, copyTrading,
upperLimitPrice, lowerLimitPrice,
lastPrice, indexPrice, markPrice,
prevPrice24h, price24hPcnt, highPrice24h, lowPrice24h, prevPrice1h,
openInterest, openInterestValue,
turnover24h, volume24h,
fundingRate, nextFundingTime,
ask1Size, bid1Price, ask1Price, bid1Size,
execId, price, size, side, isAdlTrade, mPnL, isBlockTrade,
start, `open`, high, low, `close`, volume, turnover,
m_close, i_close, p_close,
buyRatio, sellRatio, period,
riskId, isLowestRisk, maintenanceMargin, initialMargin, `limit`
)
SELECT
symbol, korean_name,
UNIX_TIMESTAMP(NOW(3))*1000,
status, baseCoin, quoteCoin, settleCoin, optionsType,
launchTime, priceScale,
minLeverage, maxLeverage, leverageStep,
minPrice, maxPrice, tickSize,
maxOrderQty, minOrderQty, qtyStep, postOnlyMaxOrderQty,
unifiedMarginTrade, fundingInterval, copyTrading,
upperLimitPrice, lowerLimitPrice,
lastPrice, indexPrice, markPrice,
prevPrice24h, price24hPcnt, highPrice24h, lowPrice24h, prevPrice1h,
openInterest, openInterestValue,
turnover24h, volume24h,
fundingRate, nextFundingTime,
ask1Size, bid1Price, ask1Price, bid1Size,
execId, price, size, side, isAdlTrade,
NULLIF(mPnL, ''),
isBlockTrade,
start, `open`, high, low, `close`, volume, turnover,
m_close, i_close, p_close,
buyRatio, sellRatio, period,
riskId, isLowestRisk, maintenanceMargin, initialMargin, `limit`
FROM daemon_bybit_Ticker
|
|||||
| ENABLED |
ev_upbit_coin_4h 플랫폼_플랫폼 테이블을 4시간 단위 테이블로복사_복사 |
RECURRING EVERY 4 HOUR |
2026-04-19 17:00:00 | 계산 중... | |
|
INSERT INTO upbit_data.daemon_upbit_coin_4h (
id,
market,
trade_date,
trade_time,
trade_date_kst,
trade_time_kst,
opening_price,
high_price,
low_price,
trade_price,
prev_closing_price,
`change`,
change_price,
change_rate,
signed_change_price,
signed_change_rate,
trade_volume,
acc_trade_volume,
acc_trade_volume_24h,
acc_trade_price,
acc_trade_price_24h,
highest_52_week_price,
highest_52_week_date,
lowest_52_week_price,
lowest_52_week_date,
collected_at,
collected_ms,
ob_timestamp,
ob_total_ask_size,
ob_total_bid_size,
ob_units,
ob_collected_at,
ob_collected_ms,
tr_trade_timestamp,
tr_trade_price,
tr_trade_volume,
tr_ask_bid,
tr_trade_date_utc,
tr_trade_time_utc,
tr_trade_date_kst,
tr_trade_time_kst,
tr_collected_at,
tr_collected_ms,
day_of_week,
korean_name
)
SELECT
NULL,
market,
trade_date,
trade_time,
trade_date_kst,
trade_time_kst,
opening_price,
high_price,
low_price,
trade_price,
prev_closing_price,
`change`,
change_price,
change_rate,
signed_change_price,
signed_change_rate,
trade_volume,
acc_trade_volume,
acc_trade_volume_24h,
acc_trade_price,
acc_trade_price_24h,
highest_52_week_price,
highest_52_week_date,
lowest_52_week_price,
lowest_52_week_date,
collected_at,
collected_ms,
ob_timestamp,
ob_total_ask_size,
ob_total_bid_size,
ob_units,
ob_collected_at,
ob_collected_ms,
tr_trade_timestamp,
tr_trade_price,
tr_trade_volume,
tr_ask_bid,
tr_trade_date_utc,
tr_trade_time_utc,
tr_trade_date_kst,
tr_trade_time_kst,
tr_collected_at,
tr_collected_ms,
day_of_week,
korean_name
FROM upbit_data.daemon_upbit_Ticker
|
|||||
| ENABLED |
ev_upbit_user_4h 개인키_플랫폼 테이블을 4시간 단위 테이블로 복사_복사 |
RECURRING EVERY 4 HOUR |
2026-04-19 17:00:00 | 계산 중... | |
|
INSERT INTO daemon_upbit_user_4h
(currency, balance, locked, avg_buy_price, avg_buy_price_modified, unit_currency,
collected_at, collected_ms, current_price, evaluation_amount, buy_amount,
profit_amount, profit_rate, total_asset_value, total_profit_amount,
total_profit_rate, cash_balance)
SELECT
currency, balance, locked, avg_buy_price, avg_buy_price_modified, unit_currency,
collected_at, collected_ms, current_price, evaluation_amount, buy_amount,
profit_amount, profit_rate, total_asset_value, total_profit_amount,
total_profit_rate, cash_balance
FROM daemon_upbit_Ticker_user
ON DUPLICATE KEY UPDATE
balance=VALUES(balance),
locked=VALUES(locked),
avg_buy_price=VALUES(avg_buy_price),
avg_buy_price_modified=VALUES(avg_buy_price_modified),
unit_currency=VALUES(unit_currency),
collected_at=VALUES(collected_at),
current_price=VALUES(current_price),
evaluation_amount=VALUES(evaluation_amount),
buy_amount=VALUES(buy_amount),
profit_amount=VALUES(profit_amount),
profit_rate=VALUES(profit_rate),
total_asset_value=VALUES(total_asset_value),
total_profit_amount=VALUES(total_profit_amount),
total_profit_rate=VALUES(total_profit_rate),
cash_balance=VALUES(cash_balance)
|
|||||
| ENABLED |
ev_bybit_coin_8h 플랫폼_바이비트 플랫폼 테이블을 8시간 단위 펀딩 테이블로 복사_복사 |
RECURRING EVERY 8 HOUR |
2026-04-19 16:59:00 | 계산 중... | |
|
INSERT INTO daemon_bybit_coin_8h (
symbol, korean_name, `time`,
status, baseCoin, quoteCoin, settleCoin, optionsType,
launchTime, priceScale,
minLeverage, maxLeverage, leverageStep,
minPrice, maxPrice, tickSize,
maxOrderQty, minOrderQty, qtyStep, postOnlyMaxOrderQty,
unifiedMarginTrade, fundingInterval, copyTrading,
upperLimitPrice, lowerLimitPrice,
lastPrice, indexPrice, markPrice,
prevPrice24h, price24hPcnt, highPrice24h, lowPrice24h, prevPrice1h,
openInterest, openInterestValue,
turnover24h, volume24h,
fundingRate, nextFundingTime,
ask1Size, bid1Price, ask1Price, bid1Size,
execId, price, size, side, isAdlTrade, mPnL, isBlockTrade,
start, `open`, high, low, `close`, volume, turnover,
m_close, i_close, p_close,
buyRatio, sellRatio, period,
riskId, isLowestRisk, maintenanceMargin, initialMargin, `limit`
)
SELECT
symbol, korean_name,
UNIX_TIMESTAMP(NOW(3))*1000,
status, baseCoin, quoteCoin, settleCoin, optionsType,
launchTime, priceScale,
minLeverage, maxLeverage, leverageStep,
minPrice, maxPrice, tickSize,
maxOrderQty, minOrderQty, qtyStep, postOnlyMaxOrderQty,
unifiedMarginTrade, fundingInterval, copyTrading,
upperLimitPrice, lowerLimitPrice,
lastPrice, indexPrice, markPrice,
prevPrice24h, price24hPcnt, highPrice24h, lowPrice24h, prevPrice1h,
openInterest, openInterestValue,
turnover24h, volume24h,
fundingRate, nextFundingTime,
ask1Size, bid1Price, ask1Price, bid1Size,
execId, price, size, side, isAdlTrade,
NULLIF(mPnL, ''),
isBlockTrade,
start, `open`, high, low, `close`, volume, turnover,
m_close, i_close, p_close,
buyRatio, sellRatio, period,
riskId, isLowestRisk, maintenanceMargin, initialMargin, `limit`
FROM daemon_bybit_Ticker
|
|||||
| ENABLED |
ev_upbit_coin_8h 플랫폼_플랫폼 테이블을 8시간 단위 펀딩 테이블로 복사_복사 |
RECURRING EVERY 8 HOUR |
2026-04-19 16:59:00 | 계산 중... | |
|
INSERT INTO upbit_data.daemon_upbit_coin_8h (
id,
market,
trade_date,
trade_time,
trade_date_kst,
trade_time_kst,
opening_price,
high_price,
low_price,
trade_price,
prev_closing_price,
`change`,
change_price,
change_rate,
signed_change_price,
signed_change_rate,
trade_volume,
acc_trade_volume,
acc_trade_volume_24h,
acc_trade_price,
acc_trade_price_24h,
highest_52_week_price,
highest_52_week_date,
lowest_52_week_price,
lowest_52_week_date,
collected_at,
collected_ms,
ob_timestamp,
ob_total_ask_size,
ob_total_bid_size,
ob_units,
ob_collected_at,
ob_collected_ms,
tr_trade_timestamp,
tr_trade_price,
tr_trade_volume,
tr_ask_bid,
tr_trade_date_utc,
tr_trade_time_utc,
tr_trade_date_kst,
tr_trade_time_kst,
tr_collected_at,
tr_collected_ms,
day_of_week,
korean_name
)
SELECT
NULL,
market,
trade_date,
trade_time,
trade_date_kst,
trade_time_kst,
opening_price,
high_price,
low_price,
trade_price,
prev_closing_price,
`change`,
change_price,
change_rate,
signed_change_price,
signed_change_rate,
trade_volume,
acc_trade_volume,
acc_trade_volume_24h,
acc_trade_price,
acc_trade_price_24h,
highest_52_week_price,
highest_52_week_date,
lowest_52_week_price,
lowest_52_week_date,
collected_at,
collected_ms,
ob_timestamp,
ob_total_ask_size,
ob_total_bid_size,
ob_units,
ob_collected_at,
ob_collected_ms,
tr_trade_timestamp,
tr_trade_price,
tr_trade_volume,
tr_ask_bid,
tr_trade_date_utc,
tr_trade_time_utc,
tr_trade_date_kst,
tr_trade_time_kst,
tr_collected_at,
tr_collected_ms,
day_of_week,
korean_name
FROM upbit_data.daemon_upbit_Ticker
|
|||||
| ENABLED |
ev_bybit_coin_12h 플랫폼_바이비트 플랫폼 테이블을 12시간 단위 테이블로 복사_복사 |
RECURRING EVERY 12 HOUR |
2026-04-19 09:00:00 | 계산 중... | |
|
INSERT INTO daemon_bybit_coin_12h (
symbol, korean_name, `time`,
status, baseCoin, quoteCoin, settleCoin, optionsType,
launchTime, priceScale,
minLeverage, maxLeverage, leverageStep,
minPrice, maxPrice, tickSize,
maxOrderQty, minOrderQty, qtyStep, postOnlyMaxOrderQty,
unifiedMarginTrade, fundingInterval, copyTrading,
upperLimitPrice, lowerLimitPrice,
lastPrice, indexPrice, markPrice,
prevPrice24h, price24hPcnt, highPrice24h, lowPrice24h, prevPrice1h,
openInterest, openInterestValue,
turnover24h, volume24h,
fundingRate, nextFundingTime,
ask1Size, bid1Price, ask1Price, bid1Size,
execId, price, size, side, isAdlTrade, mPnL, isBlockTrade,
start, `open`, high, low, `close`, volume, turnover,
m_close, i_close, p_close,
buyRatio, sellRatio, period,
riskId, isLowestRisk, maintenanceMargin, initialMargin, `limit`
)
SELECT
symbol, korean_name,
UNIX_TIMESTAMP(NOW(3))*1000,
status, baseCoin, quoteCoin, settleCoin, optionsType,
launchTime, priceScale,
minLeverage, maxLeverage, leverageStep,
minPrice, maxPrice, tickSize,
maxOrderQty, minOrderQty, qtyStep, postOnlyMaxOrderQty,
unifiedMarginTrade, fundingInterval, copyTrading,
upperLimitPrice, lowerLimitPrice,
lastPrice, indexPrice, markPrice,
prevPrice24h, price24hPcnt, highPrice24h, lowPrice24h, prevPrice1h,
openInterest, openInterestValue,
turnover24h, volume24h,
fundingRate, nextFundingTime,
ask1Size, bid1Price, ask1Price, bid1Size,
execId, price, size, side, isAdlTrade,
NULLIF(mPnL, ''),
isBlockTrade,
start, `open`, high, low, `close`, volume, turnover,
m_close, i_close, p_close,
buyRatio, sellRatio, period,
riskId, isLowestRisk, maintenanceMargin, initialMargin, `limit`
FROM daemon_bybit_Ticker
|
|||||
| ENABLED |
ev_upbit_coin_12h 플랫폼_플랫폼 테이블을 12시간 단위 테이블로 복사_복사 |
RECURRING EVERY 12 HOUR |
2026-04-19 09:00:00 | 계산 중... | |
|
INSERT INTO upbit_data.daemon_upbit_coin_12h (
id,
market,
trade_date,
trade_time,
trade_date_kst,
trade_time_kst,
opening_price,
high_price,
low_price,
trade_price,
prev_closing_price,
`change`,
change_price,
change_rate,
signed_change_price,
signed_change_rate,
trade_volume,
acc_trade_volume,
acc_trade_volume_24h,
acc_trade_price,
acc_trade_price_24h,
highest_52_week_price,
highest_52_week_date,
lowest_52_week_price,
lowest_52_week_date,
collected_at,
collected_ms,
ob_timestamp,
ob_total_ask_size,
ob_total_bid_size,
ob_units,
ob_collected_at,
ob_collected_ms,
tr_trade_timestamp,
tr_trade_price,
tr_trade_volume,
tr_ask_bid,
tr_trade_date_utc,
tr_trade_time_utc,
tr_trade_date_kst,
tr_trade_time_kst,
tr_collected_at,
tr_collected_ms,
day_of_week,
korean_name
)
SELECT
NULL,
market,
trade_date,
trade_time,
trade_date_kst,
trade_time_kst,
opening_price,
high_price,
low_price,
trade_price,
prev_closing_price,
`change`,
change_price,
change_rate,
signed_change_price,
signed_change_rate,
trade_volume,
acc_trade_volume,
acc_trade_volume_24h,
acc_trade_price,
acc_trade_price_24h,
highest_52_week_price,
highest_52_week_date,
lowest_52_week_price,
lowest_52_week_date,
collected_at,
collected_ms,
ob_timestamp,
ob_total_ask_size,
ob_total_bid_size,
ob_units,
ob_collected_at,
ob_collected_ms,
tr_trade_timestamp,
tr_trade_price,
tr_trade_volume,
tr_ask_bid,
tr_trade_date_utc,
tr_trade_time_utc,
tr_trade_date_kst,
tr_trade_time_kst,
tr_collected_at,
tr_collected_ms,
day_of_week,
korean_name
FROM upbit_data.daemon_upbit_Ticker
|
|||||
| ENABLED |
ev_upbit_user_24h 개인키_플랫폼 테이블을 24시간 단위 테이블로 복사_복사 |
RECURRING EVERY 24 HOUR |
2026-04-19 09:00:00 | 계산 중... | |
|
INSERT INTO daemon_upbit_user_24h
(currency, balance, locked, avg_buy_price, avg_buy_price_modified, unit_currency,
collected_at, collected_ms, current_price, evaluation_amount, buy_amount,
profit_amount, profit_rate, total_asset_value, total_profit_amount,
total_profit_rate, cash_balance)
SELECT
currency, balance, locked, avg_buy_price, avg_buy_price_modified, unit_currency,
collected_at, collected_ms, current_price, evaluation_amount, buy_amount,
profit_amount, profit_rate, total_asset_value, total_profit_amount,
total_profit_rate, cash_balance
FROM daemon_upbit_Ticker_user
ON DUPLICATE KEY UPDATE
balance=VALUES(balance),
locked=VALUES(locked),
avg_buy_price=VALUES(avg_buy_price),
avg_buy_price_modified=VALUES(avg_buy_price_modified),
unit_currency=VALUES(unit_currency),
collected_at=VALUES(collected_at),
current_price=VALUES(current_price),
evaluation_amount=VALUES(evaluation_amount),
buy_amount=VALUES(buy_amount),
profit_amount=VALUES(profit_amount),
profit_rate=VALUES(profit_rate),
total_asset_value=VALUES(total_asset_value),
total_profit_amount=VALUES(total_profit_amount),
total_profit_rate=VALUES(total_profit_rate),
cash_balance=VALUES(cash_balance)
|
|||||
| ENABLED |
stats_direction_01_24h 통계_방향 통계 실시간을 24시간 테이블에 실시간 복사_복사 |
RECURRING EVERY 24 HOUR |
2026-04-19 09:00:00 | 계산 중... | |
|
INSERT INTO upbit_data.stats_direction_01_24h (
market, wr_datetime,
side_plus, side_minus, side_total,
side_plus_cnt, side_minus_cnt, side_total_cnt,
side_avg, acc_bid_volume, acc_ask_volume, net_vol,
trade_price, change_rate,
chg_dir, chg_dir_sum,
chg_up_streak, chg_down_streak,
chg_up_streak_max, chg_down_streak_max,
chg_rate_avg, chg_rate_avg_cnt
)
SELECT
s.market,
s.wr_datetime,
s.side_plus, s.side_minus, s.side_total,
CASE WHEN (s.side_total_cnt - IFNULL(pm.side_total_cnt, s.side_total_cnt)) > 0 THEN 1 ELSE 0 END AS side_plus_cnt,
CASE WHEN (s.side_total_cnt - IFNULL(pm.side_total_cnt, s.side_total_cnt)) < 0 THEN -1 ELSE 0 END AS side_minus_cnt,
s.side_total_cnt,
s.side_avg, s.acc_bid_volume, s.acc_ask_volume, s.net_vol,
s.trade_price, s.change_rate,
CASE
WHEN (s.chg_dir_sum - IFNULL(pm.chg_dir_sum, s.chg_dir_sum)) > 0 THEN 1
WHEN (s.chg_dir_sum - IFNULL(pm.chg_dir_sum, s.chg_dir_sum)) < 0 THEN -1
ELSE 0
END AS chg_dir,
s.chg_dir_sum,
CASE
WHEN (s.chg_dir_sum - IFNULL(pm.chg_dir_sum, s.chg_dir_sum)) > 0 THEN IFNULL(pm.chg_up_streak, 0) + 1
ELSE 0
END AS chg_up_streak,
CASE
WHEN (s.chg_dir_sum - IFNULL(pm.chg_dir_sum, s.chg_dir_sum)) < 0 THEN IFNULL(pm.chg_down_streak, 0) + 1
ELSE 0
END AS chg_down_streak,
GREATEST(
IFNULL(pm.chg_up_streak_max, 0),
CASE
WHEN (s.chg_dir_sum - IFNULL(pm.chg_dir_sum, s.chg_dir_sum)) > 0 THEN IFNULL(pm.chg_up_streak, 0) + 1
ELSE 0
END
) AS chg_up_streak_max,
GREATEST(
IFNULL(pm.chg_down_streak_max, 0),
CASE
WHEN (s.chg_dir_sum - IFNULL(pm.chg_dir_sum, s.chg_dir_sum)) < 0 THEN IFNULL(pm.chg_down_streak, 0) + 1
ELSE 0
END
) AS chg_down_streak_max,
s.chg_rate_avg, s.chg_rate_avg_cnt
FROM upbit_data.stats_direction_01 s
LEFT JOIN (
SELECT market, MAX(wr_id) AS max_id
FROM upbit_data.stats_direction_01_24h
GROUP BY market
) last ON last.market = s.market
LEFT JOIN upbit_data.stats_direction_01_24h pm
ON pm.market = last.market AND pm.wr_id = last.max_id
WHERE s.wr_datetime >= NOW() - INTERVAL 48 HOUR
AND NOT EXISTS (
SELECT 1
FROM upbit_data.stats_direction_01_24h m
WHERE m.market = s.market
AND m.wr_datetime = s.wr_datetime
)
|
|||||
| ENABLED |
ev_bybit_coin_24h 플랫폼_바이비트 플랫폼 테이블을 24시간 단위 테이블 복사_복사 |
RECURRING EVERY 24 HOUR |
2026-04-19 08:59:00 | 계산 중... | |
|
INSERT INTO daemon_bybit_coin_24h (
symbol, korean_name, `time`,
status, baseCoin, quoteCoin, settleCoin, optionsType,
launchTime, priceScale,
minLeverage, maxLeverage, leverageStep,
minPrice, maxPrice, tickSize,
maxOrderQty, minOrderQty, qtyStep, postOnlyMaxOrderQty,
unifiedMarginTrade, fundingInterval, copyTrading,
upperLimitPrice, lowerLimitPrice,
lastPrice, indexPrice, markPrice,
prevPrice24h, price24hPcnt, highPrice24h, lowPrice24h, prevPrice1h,
openInterest, openInterestValue,
turnover24h, volume24h,
fundingRate, nextFundingTime,
ask1Size, bid1Price, ask1Price, bid1Size,
execId, price, size, side, isAdlTrade, mPnL, isBlockTrade,
start, `open`, high, low, `close`, volume, turnover,
m_close, i_close, p_close,
buyRatio, sellRatio, period,
riskId, isLowestRisk, maintenanceMargin, initialMargin, `limit`
)
SELECT
symbol, korean_name,
UNIX_TIMESTAMP(NOW(3))*1000,
status, baseCoin, quoteCoin, settleCoin, optionsType,
launchTime, priceScale,
minLeverage, maxLeverage, leverageStep,
minPrice, maxPrice, tickSize,
maxOrderQty, minOrderQty, qtyStep, postOnlyMaxOrderQty,
unifiedMarginTrade, fundingInterval, copyTrading,
upperLimitPrice, lowerLimitPrice,
lastPrice, indexPrice, markPrice,
prevPrice24h, price24hPcnt, highPrice24h, lowPrice24h, prevPrice1h,
openInterest, openInterestValue,
turnover24h, volume24h,
fundingRate, nextFundingTime,
ask1Size, bid1Price, ask1Price, bid1Size,
execId, price, size, side, isAdlTrade,
NULLIF(mPnL, ''),
isBlockTrade,
start, `open`, high, low, `close`, volume, turnover,
m_close, i_close, p_close,
buyRatio, sellRatio, period,
riskId, isLowestRisk, maintenanceMargin, initialMargin, `limit`
FROM daemon_bybit_Ticker
|
|||||
| ENABLED |
ev_upbit_coin_24h 플랫폼_플랫폼 테이블을 24시간 단위 테이블로 복사_복사 |
RECURRING EVERY 24 HOUR |
2026-04-19 08:59:00 | 계산 중... | |
|
INSERT INTO upbit_data.daemon_upbit_coin_24h (
id,
market,
trade_date,
trade_time,
trade_date_kst,
trade_time_kst,
opening_price,
high_price,
low_price,
trade_price,
prev_closing_price,
`change`,
change_price,
change_rate,
signed_change_price,
signed_change_rate,
trade_volume,
acc_trade_volume,
acc_trade_volume_24h,
acc_trade_price,
acc_trade_price_24h,
highest_52_week_price,
highest_52_week_date,
lowest_52_week_price,
lowest_52_week_date,
collected_at,
collected_ms,
ob_timestamp,
ob_total_ask_size,
ob_total_bid_size,
ob_units,
ob_collected_at,
ob_collected_ms,
tr_trade_timestamp,
tr_trade_price,
tr_trade_volume,
tr_ask_bid,
tr_trade_date_utc,
tr_trade_time_utc,
tr_trade_date_kst,
tr_trade_time_kst,
tr_collected_at,
tr_collected_ms,
day_of_week,
korean_name
)
SELECT
NULL,
market,
trade_date,
trade_time,
trade_date_kst,
trade_time_kst,
opening_price,
high_price,
low_price,
trade_price,
prev_closing_price,
`change`,
change_price,
change_rate,
signed_change_price,
signed_change_rate,
trade_volume,
acc_trade_volume,
acc_trade_volume_24h,
acc_trade_price,
acc_trade_price_24h,
highest_52_week_price,
highest_52_week_date,
lowest_52_week_price,
lowest_52_week_date,
collected_at,
collected_ms,
ob_timestamp,
ob_total_ask_size,
ob_total_bid_size,
ob_units,
ob_collected_at,
ob_collected_ms,
tr_trade_timestamp,
tr_trade_price,
tr_trade_volume,
tr_ask_bid,
tr_trade_date_utc,
tr_trade_time_utc,
tr_trade_date_kst,
tr_trade_time_kst,
tr_collected_at,
tr_collected_ms,
day_of_week,
korean_name
FROM upbit_data.daemon_upbit_Ticker
|
|||||