Llevo algunos meses aprendiendo Python y si bien soy un novato, normalmente luego de varias horas encuentro la manera correcta de desarrollar mi código.
Estoy trabajando en un proyecto Python para ser notificado via telegram cada vez que una criptomoneda supere cierto nivel de RSI (esa parte del codigo ya está lista), todo funciona bastante bien en una moneda específica, pero estoy buscando que el codigo se ejecute para todas las monedas del mercado y no hallo la forma de añadir el bucle para que el programa tome los nombres de las monedas desde un .txt y se ejecute al tiempo por cada una de ellas.
Adjunto código, cualquier aporte será de gran ayuda.
import websocket, json, pprint, talib, numpy, requests
from datetime import datetime
INTERVAL = '1m'
STREAM_NAME = 'ETHUSDT'
TIME_NOW = datetime.now()
SOCKET = (f'wss://stream.binance.com:9443/ws/{STREAM_NAME.lower()}@kline_{INTERVAL}')
RSI_PERIOD = 14
RSI_OVERBOUGHT = 70
RSI_OVERSOLD = 30
closes = []
def telegram_bot_sendtext(bot_message):
bot_token = 'token_here'
bot_chatID = 'chat_id_here'
send_text = 'https://api.telegram.org/bot' + bot_token + '/sendMessage?chat_id=' + bot_chatID + '&parse_mode=Markdown&text=' + bot_message
response = requests.get(send_text)
return response.json()
def on_open(ws):
print(f'{TIME_NOW} - opened connection for {STREAM_NAME}')
telegram_bot_sendtext(f'{STREAM_NAME} Connection opened at {TIME_NOW}')
def on_close(ws):
print(f'{TIME_NOW} - closed connection for {STREAM_NAME}')
telegram_bot_sendtext(f'{STREAM_NAME} Connection closed at {TIME_NOW}')
def on_message(ws, message):
global closes
print (f'{TIME_NOW} - received message')
print (message)
json_message = json.loads(message)
pprint.pprint(json_message)
candle = json_message ['k']
is_candle_closed = candle ['x']
close = candle ['c']
if is_candle_closed:
print(f'candle closed at{close}')
closes.append(float(close))
print ('closes')
print (closes)
if len(closes) > RSI_PERIOD:
np_closes = numpy.array(closes)
rsi = talib.RSI(np_closes, RSI_PERIOD)
print('All rsis calculated so far ')
print(rsi)
last_rsi = rsi[-1]
print(f'the current rsi is {last_rsi}')
if last_rsi > RSI_OVERBOUGHT:
print(f'{STREAM_NAME} RSI => 70 ')
telegram_bot_sendtext(f'{STREAM_NAME} RSI IS OVERBOUGHT => {RSI_OVERBOUGHT} ')
if last_rsi < RSI_OVERSOLD:
print(f'{STREAM_NAME} RSI =< 30')
telegram_bot_sendtext(f'{STREAM_NAME} RSI IS OVERSOLD =< {RSI_OVERSOLD} ')
ws = websocket.WebSocketApp(SOCKET, on_open = on_open, on_close = on_close, on_message = on_message)
ws.run_forever()
for i in STREAM_NAME:
. Pruébalo y nos cuentas.