import ccxt
import pandas as pd
import time
from datetime import datetime
Binance Futures API Bilgileri (Kendi API bilgilerinizle değiştirin!)
exchange = ccxt.binance({
‘apiKey’: ‘xxxxx’, # Buraya API anahtarınızı girin
‘secret’: ‘xxxxx’, # Buraya secret anahtarınızı girin
‘enableRateLimit’: True,
‘options’: {
‘defaultType’: ‘future’
}
})
Parametreler
rsi_period = 10
symbol = ‘1000PEPE/USDT’ # İşlem sembolü
timeframe = ‘1m’ # Dakikalık grafik (1 dakika)
divergence_period = 60 # Uyumsuzluk kontrolü için geçmiş periyot sayısı
leverage = 4 # Kaldıraç oranını belirleyin
def calculate_rsi(data, period):
“”“RSI (Göreceli Güç Endeksi) hesaplar.”“”
delta = data.diff()
up, down = delta.copy(), delta.copy()
up[up < 0] = 0
down[down > 0] = 0
roll_up = up.rolling(period).mean()
roll_down = down.abs().rolling(period).mean()
rs = roll_up / roll_down
rsi_val = 100.0 - (100.0 / (1.0 + rs))
return rsi_val
def check_divergence(df, divergence_period):
“”“Uyumsuzluk (Divergence) koşullarını kontrol eder.”“”
high_prices = df[‘high’].iloc[-divergence_period:].values
low_prices = df[‘low’].iloc[-divergence_period:].values
rsi_values = df[‘rsi’].iloc[-divergence_period:].values
bearish_divergence = False
bullish_divergence = False
# Ayı Uyumsuzluğu (Bearish Divergence) Kontrolü
if high_prices[-1] > max(high_prices[:-1]) and rsi_values[-1] < max(rsi_values[:-1]):
bearish_divergence = True
# Boğa Uyumsuzluğu (Bullish Divergence) Kontrolü
if low_prices[-1] < min(low_prices[:-1]) and rsi_values[-1] > min(rsi_values[:-1]):
bullish_divergence = True
return bullish_divergence, bearish_divergence
def run_strategy():
long_position = None # Long pozisyon durumunu takip etmek için
position_amount = 0
# Kaldıraç oranı ayarı
try:
exchange.set_leverage(leverage, symbol)
print(f"Kaldıraç {leverage}x olarak ayarlandı.")
except Exception as e:
print(f"Kaldıraç ayarlanırken hata oluştu: {e}")
# Başlangıçta açık pozisyon kontrolü
try:
positions = exchange.fetch_positions([symbol]) # Tek sembol için pozisyonları getir
for position in positions:
if position['symbol'] == symbol and position['side'] == 'long' and position['contracts'] > 0:
long_position = True # Açık pozisyon bulundu
position_amount = position['contracts'] # Pozisyon miktarını al
print(f"Başlangıçta açık long pozisyon bulundu. Miktar: {position_amount}")
break # Sembol için pozisyon bulunduğunda döngüden çık
except Exception as e:
print(f"Pozisyon kontrolü sırasında hata oluştu: {e}")
while True:
try:
ohlcv = exchange.fetch_ohlcv(symbol, timeframe, limit=rsi_period + divergence_period)
df = pd.DataFrame(ohlcv, columns=['timestamp', 'open', 'high', 'low', 'close', 'volume'])
df['rsi'] = calculate_rsi(df['close'], rsi_period)
bullish_divergence, bearish_divergence = check_divergence(df, divergence_period)
now = datetime.now()
current_time = now.strftime("%H:%M:%S")
if bullish_divergence:
if long_position is None: # long_position == None yerine long_position is None daha doğru
balance = exchange.fetch_balance()['USDT']['free']
print(f"Boğa Uyumsuzluğu Tespit Edildi. Saat: {current_time}, Mevcut bakiye (USDT): {balance}") # Debug print
if balance > 0:
# Kaldıraçlı bakiye, tüm bakiye kullanılıyor
amount_usdt = balance * leverage # Kaldıraçlı bakiye
amount = round(amount_usdt / df['close'].iloc[-1], 8) # Hassasiyet 8 basamak
current_price = df['close'].iloc[-1] # Debug print
print(f"Kullanılacak bakiye (USDT): {amount_usdt}, İşlem miktarı ({symbol}): {amount}, Anlık fiyat: {current_price}") # Debug print
print("Long pozisyon açılıyor...")
order = exchange.create_market_order(symbol, 'buy', amount)
long_position = order # order objesini tutmaya devam et, None kontrolü için yeterli
position_amount = amount
if bearish_divergence:
if long_position is not None: # long_position != None yerine long_position is not None daha doğru
if position_amount > 0: # position_amount > 0 kontrolü gereksiz gibi duruyor ama kalsın şimdilik
print(f"Ayı Uyumsuzluğu Tespit Edildi. Saat: {current_time}, Long pozisyon kapatılıyor... Miktar: {position_amount}")
order = exchange.create_market_order(symbol, 'sell', position_amount)
long_position = None
position_amount = 0
print("Long pozisyon tamamen kapatıldı.")
else:
print(f"Sat sinyali geldi (Long pozisyon yok). Saat: {current_time}") # Eklenen satır
except ccxt.NetworkError as e:
print(f"Ağ hatası oluştu: {e}")
except ccxt.ExchangeError as e:
print(f"Borsa hatası oluştu: {e}")
except Exception as e:
print(f"Hata oluştu: {e}")
time.sleep(10)
print("BEKLEME..........")
if name == ‘main’:
run_strategy()
