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

Merge remote-tracking branch 'origin/master'

Browse Source
This commit is contained in:
dsyoon
2025-05-03 11:40:17 +09:00
parent f8c46a014f 3282b8dcf6
commit 5feecc4f0a
1 changed files with 34 additions and 31 deletions
Download Patch File Download Diff File Expand all files Collapse all files

65
stock_monitor.py
View File

@@ -25,10 +25,21 @@ def send_stock_msg(text):
asyncio.run(stock_client.send_message(chat_id=STOCK_TELEGRAM_CHAT_ID, text=text))
return
def send_stock_telegram_message(message):
pool = Pool(12)
pool.map(send_stock_msg, [message])
def send_stock_telegram_message(message_list, header):
pStr = header+"/n"
for i, message in enumerate(message_list):
pStr += message
if i+1 % 20 == 0:
pool = Pool(12)
pool.map(send_stock_msg, [pStr])
pStr = ''
if len(message_list) % 20 != 0:
pool = Pool(12)
pool.map(send_stock_msg, [pStr])
return
def calculate_bollinger_bands(data):
data['MA'] = data['Close'].rolling(window=BOLLINGER_PERIOD).mean()
@@ -254,7 +265,7 @@ def get_stock_data(symbol, retries=3):
return None
def monitor_us_stocks():
message = ""
message_list = []
print("US Stocks {}".format(datetime.now().strftime('%Y-%m-%d %H:%M:%S')))
for symbol in US_STOCKS:
@@ -268,17 +279,14 @@ def monitor_us_stocks():
if info['buy']:
#if info['buy'] or any(info['buy_signals'].values()):
if message == "":
message = "[US-STOCK]\n"
message += format_message(info, 'US')
message_list.append(format_message(info, 'US'))
except Exception as e:
print(f"Error processing data for {symbol}: {str(e)}")
time.sleep(0.5)
if message:
if len(message_list) > 0:
try:
send_stock_telegram_message(message)
send_stock_telegram_message(message_list, header="[US-STOCK]")
except Exception as e:
print(f"Error sending Telegram message: {str(e)}")
@@ -286,10 +294,9 @@ def monitor_us_stocks():
def monitor_kr_stocks():
message = ""
# 한국 ETF 모니터링
message_list = []
print("KR ETFs {}".format(datetime.now().strftime('%Y-%m-%d %H:%M:%S')))
for symbol in KR_ETFS:
data = get_stock_data(symbol)
if data is not None and not data.empty:
@@ -301,9 +308,7 @@ def monitor_kr_stocks():
if info['buy']:
#if info['buy'] or any(info['buy_signals'].values()):
if message == "":
message = "[KR-STOCK]\n"
message += format_message(info, 'KR')
message_list.append(format_message(info, 'KR'))
except Exception as e:
print(f"Error processing data for {symbol}: {str(e)}")
@@ -311,19 +316,19 @@ def monitor_kr_stocks():
print(f"Data for {symbol} is empty or None.")
time.sleep(0.5)
try:
send_stock_telegram_message(message)
except Exception as e:
print(f"Error sending Telegram message: {str(e)}")
if len(message_list) > 0:
try:
send_stock_telegram_message(message_list, header="[KR-STOCK]")
except Exception as e:
print(f"Error sending Telegram message: {str(e)}")
return
def monitor_coins():
message = ""
message_list = []
print("KRW COINs {}".format(datetime.now().strftime('%Y-%m-%d %H:%M:%S')))
# 코인 모니터링
print("KRW Coins {}".format(datetime.now().strftime('%Y-%m-%d %H:%M:%S')))
for symbol in KR_COINS:
data = get_coin_data(symbol)
if data is not None and not data.empty:
@@ -335,23 +340,21 @@ def monitor_coins():
if info['buy']:
#if info['buy'] or any(info['buy_signals'].values()):
if message == "":
message = "[KRW-Coin]\n"
message += format_message(info, 'KR')
message_list.append(format_message(info, 'KR'))
except Exception as e:
print(f"Error processing data for {symbol}: {str(e)}")
else:
print(f"Data for {symbol} is empty or None.")
time.sleep(0.5)
try:
send_coin_telegram_message(message)
except Exception as e:
print(f"Error sending Telegram message: {str(e)}")
if len(message_list) > 0:
try:
send_stock_telegram_message(message_list, header="[KRW-COIN]")
except Exception as e:
print(f"Error sending Telegram message: {str(e)}")
return
def run_schedule():
# 코인 모니터링 스케줄 (매시간 1분, 11분, 21분, 31분, 41분, 51분)