One post tagged with "REST API"

import ccxt
import pandas as pd
import numpy as np
from datetime import datetime

class TradingBot:
    def __init__(self, exchange_id, api_key, secret):
        self.exchange = getattr(ccxt, exchange_id)({
            'apiKey': api_key,
            'secret': secret
        })
        
    def analyze_market(self, symbol):
        # Lấy dữ liệu thị trường
        ohlcv = self.exchange.fetch_ohlcv(symbol, '1h', limit=100)
        df = pd.DataFrame(ohlcv, columns=['timestamp', 'open', 'high', 'low', 'close', 'volume'])
        
        # Tính toán chỉ báo
        df['SMA20'] = df['close'].rolling(window=20).mean()
        df['RSI'] = self.calculate_rsi(df['close'])
        
        return df
        
    def execute_trade(self, symbol, side, amount):
        try:
            if side == 'buy':
                order = self.exchange.create_market_buy_order(symbol, amount)
            else:
                order = self.exchange.create_market_sell_order(symbol, amount)
            return order
        except Exception as e:
            print(f"Lỗi khi thực hiện giao dịch: {e}")
            return None

import requests
import hmac
import hashlib
import time

class ExchangeAPI:
    def __init__(self, api_key, secret_key, base_url):
        self.api_key = api_key
        self.secret_key = secret_key
        self.base_url = base_url

    def _generate_signature(self, params):
        # Tạo chữ ký cho request
        query_string = '&'.join([f"{k}={v}" for k, v in params.items()])
        signature = hmac.new(
            self.secret_key.encode('utf-8'),
            query_string.encode('utf-8'),
            hashlib.sha256
        ).hexdigest()
        return signature

    def get_ticker(self, symbol):
        # Lấy giá hiện tại
        endpoint = f"/api/v3/ticker/price"
        params = {'symbol': symbol}
        response = requests.get(f"{self.base_url}{endpoint}", params=params)
        return response.json()

    def create_order(self, symbol, side, type, quantity, price=None):
        # Tạo lệnh giao dịch
        endpoint = "/api/v3/order"
        params = {
            'symbol': symbol,
            'side': side,
            'type': type,
            'quantity': quantity,
            'timestamp': int(time.time() * 1000)
        }
        if price:
            params['price'] = price

        params['signature'] = self._generate_signature(params)
        headers = {'X-MBX-APIKEY': self.api_key}
        
        response = requests.post(
            f"{self.base_url}{endpoint}",
            params=params,
            headers=headers
        )
        return response.json()