((import numpy as np
import websocket
import json
import pprint
import talib
import numpy
from binance.client import Client
from binance.enums import *
import config
SOCKET = "wss://stream.binance.com:9443/ws/bnbusdt@kline_30m"
#RSI Setup
RSI_PERIOD = 14
RSI_OVERBOUGHT = 70
RSI_OVERSOLD = 30
TRADE_SYMBOL = "BNBUSDT"
TRADE_QUANTITY = 0.05
closes =[]
in_position = False
api_key = ''
api_secret = ''
client = Client(api_key, api_secret)
def order(side, quantity, symbol, order_type=ORDER_TYPE_MARKET):
try:
print("sending order")
order = client.create_order(symbol=symbol,
side=side,
type=order_type,
quantity=quantity)
#print(order)
except Exception as e:
return False
return True
def on_open(ws):
print('open connection')
def on_close(ws):
print('close connection')
def on_message(ws, message):
global closes, in_position
#print('received message')
json_message = json.loads(message)
pprint.pprint(json_message)
candle = json_message['k']
is_candle_closed = candle['x']
close = candle['c']
closes.append(float(close))
np_closes = numpy.array(closes)
rsi = talib.RSI(np_closes, 14)
last_rsi = rsi[-1]
print("RSİ değeri =",last_rsi)
ws = websocket.WebSocketApp(SOCKET, on_open=on_open, on_close=on_close, on_message=on_message)
ws.run_forever()