dsyoon/Bithumb
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

init

Browse Source
This commit is contained in:
dsyoon
2025-08-07 02:07:03 +09:00
parent 0d97a0574e
commit 6ae88b56ee
1 changed files with 11 additions and 25 deletions
Download Patch File Download Diff File Expand all files Collapse all files

36
stock_monitor.py
View File

@@ -40,14 +40,14 @@ def send_coin_telegram_message(message_list, header):
def buy_ticker(symbole, data): def buy_ticker(symbole, data):
try: try:
BUY_AMOUNT = 5000 BUY_AMOUNT = 6000
if data['buy_signal'].iloc[-1] == 'movingaverage': if data['buy_signal'].iloc[-1] == 'movingaverage':
BUY_AMOUNT = 50000 BUY_AMOUNT = 50000
elif data['buy_signal'].iloc[-1] == 'deviation40': elif data['buy_signal'].iloc[-1] == 'deviation40':
BUY_AMOUNT = 6000 BUY_AMOUNT = 7000
elif data['buy_signal'].iloc[-1] == 'deviation240': elif data['buy_signal'].iloc[-1] == 'deviation240':
BUY_AMOUNT = 5000 BUY_AMOUNT = 6000
_ = hts.buyCoinMarket(symbole, BUY_AMOUNT) _ = hts.buyCoinMarket(symbole, BUY_AMOUNT)
except Exception as e: except Exception as e:
@@ -322,6 +322,7 @@ def get_coin_some_data(symbol, interval):
saved_data = get_coin_saved_data(symbol, interval, data) saved_data = get_coin_saved_data(symbol, interval, data)
data = pd.concat([data, saved_data, data_1.iloc[[-1]]], ignore_index=True) data = pd.concat([data, saved_data, data_1.iloc[[-1]]], ignore_index=True)
#data = pd.concat([data, saved_data], ignore_index=True)
data['datetime'] = pd.to_datetime(data['datetime'], format='%Y-%m-%d %H:%M:%S') data['datetime'] = pd.to_datetime(data['datetime'], format='%Y-%m-%d %H:%M:%S')
data = data.set_index('datetime') data = data.set_index('datetime')
data = data.sort_index() data = data.sort_index()
@@ -373,8 +374,8 @@ def monitor_us_stocks():
recent_data = check_buy_point(data) # Changed to check_buy_point recent_data = check_buy_point(data) # Changed to check_buy_point
if recent_data['buy_point'].iloc[-1] != 1: if recent_data['buy_point'].iloc[-1] != 1:
continue continue
print(f" - {US_STOCKS[symbol]} ({symbol}): {recent_data['Close'][-1]:.2f}") print(f" - {US_STOCKS[symbol]} ({symbol}): {recent_data['Close'].iloc[-1]:.2f}")
message_list.append(format_message('US', symbol, US_STOCKS[symbol], recent_data['Close'][-1], recent_data['buy_signal'][-1])) message_list.append(format_message('US', symbol, US_STOCKS[symbol], recent_data['Close'].iloc[-1], recent_data['buy_signal'].iloc[-1]))
except Exception as e: except Exception as e:
print(f"Error processing data for {symbol}: {str(e)}") print(f"Error processing data for {symbol}: {str(e)}")
time.sleep(0.5) time.sleep(0.5)
@@ -404,8 +405,8 @@ def monitor_kr_stocks():
recent_data = check_buy_point(data) # Changed to check_buy_point recent_data = check_buy_point(data) # Changed to check_buy_point
if recent_data['buy_point'].iloc[-1] != 1: if recent_data['buy_point'].iloc[-1] != 1:
continue continue
print(f" - {KR_ETFS[symbol]} ({symbol}): {recent_data['Close'][-1]:.2f}") print(f" - {KR_ETFS[symbol]} ({symbol}): {recent_data['Close'].iloc[-1]:.2f}")
message_list.append(format_message('KR', symbol, KR_ETFS[symbol], recent_data['Close'][-1])) message_list.append(format_message('KR', symbol, KR_ETFS[symbol], recent_data['Close'].iloc[-1], recent_data['buy_signal'].iloc[-1]))
except Exception as e: except Exception as e:
print(f"Error processing data for {symbol}: {str(e)}") print(f"Error processing data for {symbol}: {str(e)}")
@@ -444,8 +445,8 @@ def monitor_coins():
recent_data = check_buy_point(data) # Changed to check_buy_point recent_data = check_buy_point(data) # Changed to check_buy_point
if recent_data['buy_point'].iloc[-1] != 1: if recent_data['buy_point'].iloc[-1] != 1:
continue continue
print(f" - {KR_COINS[symbol]} ({symbol}): {recent_data['Close'][-1]:.2f}") print(f" - {KR_COINS[symbol]} ({symbol}): {recent_data['Close'].iloc[-1]:.2f}")
message_list.append(format_message('COIN', symbol, KR_COINS[symbol], recent_data['Close'][-1], recent_data['buy_signal'][-1])) message_list.append(format_message('COIN', symbol, KR_COINS[symbol], recent_data['Close'].iloc[-1], recent_data['buy_signal'].iloc[-1]))
# buy # buy
buy_ticker(symbol, recent_data) buy_ticker(symbol, recent_data)
@@ -465,20 +466,6 @@ def monitor_coins():
return return
# ----------------------
# Turnaround Detector v6
# ----------------------
def detect_turnaround_signal(symbol, data, interval=0, params=None):
if len(data) < 7:
return None
# 이동평균을 기반으로 매수 신호 결정
cur = data.iloc[-1]
prev = data.iloc[-2]
return None
def run_schedule(): def run_schedule():
# 코인 모니터링 스케줄 (매시간 1분, 11분, 21분, 31분, 41분, 51분) # 코인 모니터링 스케줄 (매시간 1분, 11분, 21분, 31분, 41분, 51분)
@@ -501,5 +488,4 @@ def run_schedule():
if __name__ == "__main__": if __name__ == "__main__":
#run_schedule() run_schedule()
monitor_coins()