ভূমিকা:

সম্প্রতি, Xiaocao শিক্ষকের একজন ব্যবহারকারীFMZ আপগ্রেডের পরে কীভাবে দ্রুত একটি সর্বজনীন বহু-মুদ্রা ট্রেডিং কৌশল তৈরি করবেনএই কৌশল কাঠামোর একটি পাইথন বাস্তবায়ন প্রদানের আশায়, এই নিবন্ধের মন্তব্য বিভাগে একটি মন্তব্য করুন। পাইথন ডেভেলপারদের চাহিদা পূরণের জন্য, এই নিবন্ধটি Xiaocao-এর মূল ধারণাগুলির উপর ভিত্তি করে তৈরি করা হবে এবং Binance সিমুলেটেড ট্রেডিং পরিবেশের সাথে সেগুলিকে একত্রিত করে একটি সর্বজনীন বহু-মুদ্রা পরিমাণগত ট্রেডিং কাঠামো কীভাবে তৈরি করা যায় তা বিস্তারিতভাবে ব্যাখ্যা করবে।

এই কাঠামোর নিম্নলিখিত বৈশিষ্ট্য রয়েছে:

• পাইথন ভাষার উপর ভিত্তি করে, বোঝা এবং প্রসারিত করা সহজ
• বহু-মুদ্রা সমসাময়িক লেনদেন সমর্থন করুন
• নিরাপত্তা পরীক্ষার জন্য Binance সিমুলেটেড এক্সচেঞ্জ ব্যবহার করা
• সম্পূর্ণ কোড উদাহরণ এবং বিস্তারিত মন্তব্য প্রদান করে

আমরা আশা করি এই নিবন্ধটি আপনাকে দ্রুত বহু-মুদ্রা পরিমাণগত ট্রেডিং শুরু করতে সাহায্য করবে। আমরা ডেভেলপারদের এই অভিজ্ঞতার উপর ভিত্তি করে উদ্ভাবন এবং অপ্টিমাইজ করার জন্য স্বাগত জানাই, আরও ব্যাপক এবং ব্যক্তিগতকৃত ট্রেডিং কৌশল তৈরি করে। আসুন আমরা একসাথে পরিমাণগত ট্রেডিংয়ের পথ অন্বেষণ চালিয়ে যাই!

আরম্ভের কৌশল

ট্রেডিং কৌশলের প্রাথমিক পর্যায়ে, আমরা প্রথমে বিশ্বব্যাপী ভেরিয়েবলগুলিকে সংজ্ঞায়িত করিSYMBOLS，QUOTO，INTERVAL, লক্ষ্য লেনদেন মুদ্রা, মূল মুদ্রা এবং ব্যবধান সময় প্রতিনিধিত্ব করে,Infoকৌশল পরিচালনার সময় প্রয়োজনীয় সমস্ত গুরুত্বপূর্ণ তথ্য সংরক্ষণের জন্য ভেরিয়েবল ব্যবহার করা হয়।InitInfoএই ফাংশনটি এই ডেটা ইনিশিয়ালাইজ করে, যার মধ্যে রয়েছে অ্যাকাউন্টের তথ্য, সময় ব্যবস্থাপনা, প্রতিটি ট্রেডিং মুদ্রার বাজারের ডেটা, অর্ডারের তথ্য, অবস্থানের তথ্য ইত্যাদি। এই ইনিশিয়ালাইজেশন ধাপগুলি নিশ্চিত করে যে কৌশলটি চলমান অবস্থায় একটি স্পষ্ট ডেটা কাঠামো এবং প্রাথমিক অবস্থা রয়েছে, যা পরবর্তী কৌশল বাস্তবায়নের ভিত্তি স্থাপন করে।

import time
import json 

SYMBOLS = 'LINK,ETH,TRB'
QUOTO = 'USDT'
INTERVAL = 5

# 全局变量，储存数据
# SYMBOLS代表要交易的币种，格式如"BTC,ETH,LTC"
# QUOTO为基础货币，永续合约常见的有USDT，USDC
# INTERVAL代表循环的间隔
Info = {
    'trade_symbols': SYMBOLS.split(','),  # 交易币种
    'base_coin': QUOTO,                   # 基础货币
    'ticker': {},                         # 行情数据
    'order': {},                          # 订单信息
    'account': {},                        # 账户信息
    'precision': {},                      # 精度信息
    'position': {},                       # 仓位信息
    'time': {},                           # 时间相关数据
    'count': {},                          # 计数器
    'interval': INTERVAL                  # 循环的间隔时间
}

# 初始化策略
def InitInfo():

    # 初始化账户信息，初始余额为0
    Info['account'] = {
        'init_balance': 0,  # 初始余额
        'wallet_balance': 0,  # 钱包余额
        'margin_balance': 0,  # 保证金余额
        'margin_used': 0,  # 已用保证金
        'margin_free': 0,  # 可用保证金
        'profit': 0,  # 总收益
        'profit_rate': 0,  # 收益率
        'unrealised_profit': 0,  # 未实现收益
    }

    # 初始化时间数据，控制更新的时间
    Info['time'] = {
        'update_ticker_time': 0,    # 更新行情的时间
        'update_pos_time': 0,       # 更新仓位的时间
        'update_profit_time': 0,    # 更新利润的时间
        'update_account_time': 0,   # 更新账户信息的时间
        'update_status_time': 0,    # 更新状态的时间
        'last_loop_time': 0,        # 上一次主循环的时间
        'loop_delay': 0,             # 循环延迟
        'start_time': time.time()
    }

    # 初始化每个交易币种的数据
    for symbol in Info['trade_symbols']:
        Info['ticker'][symbol] = {'last': 0, 'ask': 0, 'bid': 0}  # 行情
        Info['order'][symbol] = {                                 # 订单信息
            'buy': {'id': 0, 'price': 0, 'amount': 0},
            'sell': {'id': 0, 'price': 0, 'amount': 0}
        }
        Info['position'][symbol] = {                              # 仓位信息
            'amount': 0, 'hold_price': 0, 'unrealised_profit': 0, 'open_time': 0, 'value': 0
        }
        Info['precision'][symbol] = {}  # 精度信息初始化为空
        Info['position'][symbol] = {                              # 仓位信息
            'amount': 0, 'hold_price': 0, 'unrealised_profit': 0, 'open_time': 0, 'value': 0
        }

বাজারের তথ্য এবং নির্ভুলতা সেটিংস পান

এই পদক্ষেপটি নিশ্চিত করে যে আমরা যে মুদ্রাগুলি প্রক্রিয়া করি তার দাম, পরিমাণ এবং অন্যান্য দিকগুলির নির্ভুলতা, সেইসাথে অর্ডারের পরিমাণ, এক্সচেঞ্জের মান পূরণ করে। বিভিন্ন ট্রেডিং জোড়ার (যেমন BTC/USD বা ETH/USDT) মূল্য এবং পরিমাণের জন্য বিভিন্ন ন্যূনতম নির্ভুলতার প্রয়োজনীয়তা রয়েছে, তাই অ-সম্মতিমূলক অর্ডার এড়াতে আমাদের এক্সচেঞ্জের API থেকে এই নির্ভুলতার তথ্য পেতে হবে। উদাহরণস্বরূপ, ETH/USDT দুটি দশমিক স্থান অনুমোদন করতে পারে, যেখানে BTC/USDT আট দশমিক স্থান অনুমোদন করতে পারে।

উদ্দেশ্যঃ

• অর্ডার ডেটার নির্ভুলতা নিশ্চিত করতে প্রতিটি মুদ্রার মূল্য এবং পরিমাণের নির্ভুলতা পান।
• নির্ভুল ত্রুটির কারণে অর্ডার ব্যর্থতা প্রতিরোধ করুন।

# 获取精度信息
def GetPrecision():
    # 获取交易所的市场信息
    for presym in Info['trade_symbols']:
        curcontract = presym + '_USDT.swap'
        exchange.GetTicker(curcontract)
    exchange_info = exchange.GetMarkets()
    
    # 遍历市场中的所有交易对
    for pair, data in exchange_info.items():
        symbol = pair.split('_')[0]  # 永续合约交易对的格式为 BTC_USDT.swap
        
        # 检查该交易对是否为我们要交易的币种，基础货币是否匹配，且是永续合约
        if symbol in Info['trade_symbols'] and pair.split('.')[0].endswith(Info['base_coin']) and pair.endswith('swap'):
            # 获取该交易对的精度信息
            Info['precision'][symbol] = {
                'tick_size': data['TickSize'],                  # 价格精度
                'amount_size': data['AmountSize'],              # 数量精度
                'price_precision': data['PricePrecision'],      # 价格小数位精度
                'amount_precision': data['AmountPrecision'],    # 数量小数位精度
                'min_qty': data['MinQty'],                      # 最小下单数量
                'max_qty': data['MaxQty'],                      # 最大下单数量
                'min_notional': data['MinNotional'],            # 最小交易额
                'ctVal': data['CtVal']                          # 合约价值，如1张代表0.01个币
            }
            
            # 检查合约价值的计价货币是否为symbol，避免币本位情况
            if data['CtValCcy'] != symbol:
                raise Exception("不支持币本位")

GetPrecisionফাংশন：

• API-এর মাধ্যমে এক্সচেঞ্জ থেকে বাজারের তথ্য সংগ্রহ করুন, যার মধ্যে ট্রেডিং পেয়ারের জন্য নির্ভুলতা সেটিংস অন্তর্ভুক্ত রয়েছে।
• যোগ্য ট্রেডিং জোড়ার জন্য, মূল্য নির্ভুলতা, পরিমাণ নির্ভুলতা, সর্বনিম্ন এবং সর্বোচ্চ লেনদেনের পরিমাণ এবং চুক্তির মূল্যের মতো তথ্য রেকর্ড করুন।
• এটি একটি মুদ্রা-মার্জিন লেনদেন কিনা তা পরীক্ষা করে এবং যদি তাই হয় তবে একটি ব্যতিক্রম দেয়।

উদ্ধৃতি পান

API এর মাধ্যমে বর্তমান বাজারের তথ্য অ্যাক্সেস করুন, যেমন সর্বশেষ মূল্য, সেরা বিড, সেরা জিজ্ঞাসা এবং অর্ডার বইয়ের গভীরতা। পরবর্তী ট্রেডিং সিদ্ধান্তের জন্য এই তথ্য অত্যন্ত গুরুত্বপূর্ণ। কৌশলের উপর নির্ভর করে, এই তথ্য ক্যান্ডেলস্টিক চার্ট (OHLC ডেটা) অথবা টিক-বাই-টিক ডেটার উপর ভিত্তি করে তৈরি করা যেতে পারে।

উদ্দেশ্যঃ

• বর্তমান বাজারের সর্বশেষ ট্রেডিং ডেটা পান যাতে কৌশলটি এই ডেটার উপর ভিত্তি করে ক্রয়-বিক্রয়ের সিদ্ধান্ত নিতে পারে।
• প্রযুক্তিগত সূচক গণনার জন্য রিয়েল-টাইম এবং ঐতিহাসিক তথ্য অর্জন রয়েছে।

# 更新行情信息
def UpdateTicker():
    
    # 记录当前更新时间戳
    Info['time']['update_ticker_time'] = time.time() * 1000 # 使用time.time()获取当前时间的时间戳
    
    # 遍历获取到的行情数据
    for ticpre in Info['trade_symbols']:
        
        curcontract = ticpre + '_' + QUOTO + '.swap'
        data = exchange.GetTicker(curcontract)
        
        if not data:
            Log("获取行情失败", GetLastError())
            return
        # 提取交易币种，永续合约格式如 'BTC_USDT.swap'，这里取币种名 'BTC'
        symbol = data['Symbol'].split('_')[0]
        
        # 过滤掉不是基础货币(Info['base_coin'])的交易对或不是永续合约的交易对
        if not data['Symbol'].split('.')[0].endswith(Info['base_coin']) or symbol not in Info['trade_symbols'] or not data['Symbol'].endswith('swap'):
            continue
        
        # 更新行情的卖出价、买入价和最后成交价
        Info['ticker'][symbol]['ask'] = float(data['Sell'])  # 卖出价
        Info['ticker'][symbol]['bid'] = float(data['Buy'])   # 买入价
        Info['ticker'][symbol]['last'] = float(data['Last']) # 最后成交价

1. বাজারের তথ্য পান：

   • ব্যবহারexchange.GetTickersসমস্ত ট্রেডিং জোড়ার জন্য রিয়েল-টাইম বাজার তথ্য পান।tickerচলকটি লেনদেন জোড়ার সমস্ত তথ্য সংরক্ষণ করে।

2. ত্রুটি হ্যান্ডলিং：

   • যদি বাজারের তথ্য সফলভাবে প্রাপ্ত না করা যায়, তাহলে প্রোগ্রামটি পাস হয়Logফাংশন লগ এবং আউটপুট রেকর্ড করেGetLastErrorত্রুটি বার্তাটি ফিরে এসেছে।

3. আপডেটের সময়：

   • ব্যবহারtime.timeবর্তমান সময়ের টাইমস্ট্যাম্প রেকর্ড করতে, যা বাজার আপডেট হওয়ার সময় চিহ্নিত করতে ব্যবহৃত হয়।

4. ডেটা ফিল্টারিং：

   • বাজারের তথ্য থেকে ট্রেডিং মুদ্রার নাম বের করুন।
   • যেসব ট্রেডিং পেয়ার প্রয়োজনীয়তা পূরণ করে না, যেমন যেসব ট্রেডিং পেয়ার বেস কারেন্সিতে সেটেল হয় না অথবা যেসব ট্রেডিং পেয়ার চিরস্থায়ী চুক্তি নয়, সেগুলো ফিল্টার করে ফেলুন।

5. বাজারের তথ্য আপডেট করুন：

   • যোগ্য ট্রেডিং মুদ্রার জন্য, তাদের ক্রয় মূল্য, বিক্রয় মূল্য এবং শেষ ট্রেড করা মূল্য আপডেট করুন।

এই ফাংশনের মাধ্যমে, সিস্টেমটি রিয়েল টাইমে লক্ষ্য ট্রেডিং মুদ্রার সর্বশেষ বাজার তথ্য পেতে এবং আপডেট করতে পারে।

অ্যাকাউন্টের অবস্থানের তথ্য পান

আপনার অ্যাকাউন্টের ব্যালেন্স এবং বর্তমান হোল্ডিং (মুদ্রা, পরিমাণ, খরচ, ইত্যাদি) পুনরুদ্ধার করতে API ব্যবহার করুন। উপলব্ধ তহবিল মূল্যায়ন, ঝুঁকি গণনা এবং অবস্থান পরিচালনার জন্য এই পদক্ষেপটি অত্যন্ত গুরুত্বপূর্ণ। উদাহরণস্বরূপ, আপনার বর্তমান হোল্ডিংগুলি নির্ধারণ করবে যে আপনার অবস্থান বৃদ্ধি বা হ্রাস করা হবে কিনা।

উদ্দেশ্যঃ

• লেনদেন সম্পাদনের জন্য আপনার অ্যাকাউন্টে পর্যাপ্ত তহবিল বা খোলা অবস্থান রয়েছে তা নিশ্চিত করুন।
• অ্যাকাউন্টের বর্তমান অবস্থান এবং তহবিলের উপর ভিত্তি করে লেনদেনের আকার এবং দিক নির্ধারণ করুন।

# 更新账户信息
def UpdateAccount():
   
    # 如果上次更新时间距现在不到1分钟，直接返回
    if time.time() - Info['time']['update_account_time'] < 60:
        return
    
    # 记录账户信息更新时间
    Info['time']['update_account_time'] = time.time() * 1000
    
    # 获取账户信息
    account = exchange.GetAccount()
    
    # 如果账户信息获取失败，记录日志并返回
    if account is None:
        Log("更新账户失败")
        return
    
    # 计算账户信息
    Info['account']['margin_used'] = round(account['Equity'] - account['Balance'], 2)  # 使用的保证金
    Info['account']['margin_balance'] = round(account['Equity'], 2)  # 当前账户余额
    Info['account']['margin_free'] = round(account['Balance'], 2)  # 可用余额
    Info['account']['wallet_balance'] = round(account['Equity'] - account['UPnL'], 2)  # 钱包余额
    Info['account']['unrealised_profit'] = round(account['UPnL'], 2)  # 未实现盈亏

    # 初始化账户初始余额
    if not Info['account']['init_balance']:
        if _G("init_balance") and _G("init_balance") > 0:
            Info['account']['init_balance'] = round(_G("init_balance"), 2)
        else:
            Info['account']['init_balance'] = Info['account']['margin_balance']
            _G("init_balance", Info['account']['init_balance'])
    
    # 计算账户利润及利润率
    Info['account']['profit'] = round(Info['account']['margin_balance'] - Info['account']['init_balance'], 2)
    Info['account']['profit_rate'] = round((100 * Info['account']['profit']) / Info['account']['init_balance'], 2)

    # 计算仓位总价值和杠杆率
    Info['count']['total'] = round(Info['count']['long'] + Info['count']['short'], 2)
    Info['count']['leverage'] = round(Info['count']['total'] / Info['account']['margin_balance'], 2)


# 更新仓位信息
def UpdatePosition():
    
    # 获取永续合约的仓位信息
    pos = exchange.GetPositions(Info['base_coin'] + ".swap")
    
    # 记录仓位信息更新时间
    Info['time']['update_pos_time'] = time.time() * 1000

    # 初始化仓位信息
    position_info = {symbol: {'amount': 0, 'hold_price': 0, 'unrealised_profit': 0} for symbol in Info['trade_symbols']}

    # 遍历仓位信息，更新相应币种的仓位
    for data in pos:
        symbol = data['Symbol'].split("_")[0]
        
        # 过滤掉不符合条件的币种
        if not data['Symbol'].split(".")[0].endswith(Info['base_coin']) or symbol not in Info['trade_symbols']:
            continue
        
        # 如果仓位不为零，则需要单向持仓
        if position_info[symbol]['amount'] != 0:
            raise Exception("需要单向持仓")
        
        # 更新仓位信息
        position_info[symbol] = {
            'amount': data['Amount'] * Info['precision'][symbol]['ctVal'] if data['Type'] == 0 else -data['Amount'] * Info['precision'][symbol]['ctVal'],
            'hold_price': data['Price'],
            'unrealised_profit': data['Profit']
        }

    # 初始化仓位统计数据
    Info['count'] = {'long': 0, 'short': 0, 'total': 0, 'leverage': 0}

    # 遍历更新后的仓位信息
    for symbol, info in position_info.items():
        deal_volume = abs(info['amount'] - Info['position'][symbol]['amount'])
        direction = 1 if info['amount'] - Info['position'][symbol]['amount'] > 0 else -1
        
        # 如果仓位发生变化，记录成交信息
        if deal_volume:
            deal_price = Info['order'][symbol]['buy']['price'] if direction == 1 else Info['order'][symbol]['sell']['price']
            Log(
                symbol,
                "仓位更新：",
                round(Info['position'][symbol]['value'], 1),
                " -> ",
                round(info['amount'] * Info['ticker'][symbol]['last'], 1),
                ", 买" if direction == 1 else ", 卖",
                ", 成交价:",
                deal_price,
                ", 成本价：",
                round(Info['position'][symbol]['hold_price'], Info['precision'][symbol]['price_precision']),
            )

        # 更新仓位信息
        Info['position'][symbol]['amount'] = info['amount']
        Info['position'][symbol]['hold_price'] = info['hold_price']
        Info['position'][symbol]['value'] = round(Info['position'][symbol]['amount'] * Info['ticker'][symbol]['last'], 2)
        Info['position'][symbol]['unrealised_profit'] = info['unrealised_profit']

        # 统计多头和空头仓位价值
        if Info['position'][symbol]['amount'] > 0:
            Info['count']['long'] += abs(Info['position'][symbol]['value'])
        else:
            Info['count']['short'] += abs(Info['position'][symbol]['value'])

1. UpdateAccountফাংশন：

   • চেক ব্যবধান: প্রতিবার আপনার অ্যাকাউন্ট আপডেট করার সময়, নিশ্চিত করুন যে শেষ আপডেটটি ১ মিনিটের বেশি সময় পরে আছে যাতে ঘন ঘন আপডেট না হয়।
   • অ্যাকাউন্টের তথ্য আপডেট করুন: কল করুনexchange.GetAccountঅ্যাকাউন্টের তথ্য পান এবং বিভিন্ন অ্যাকাউন্ট প্যারামিটার গণনা করুন, যেমনmargin_used、wallet_balance、unrealised_profitঅপেক্ষা করুন
   • ব্যালেন্স শুরু করুন: অ্যাকাউন্টটি প্রথমবার চালানোর সময় এর প্রাথমিক ব্যালেন্স শুরু করুন এবং এটিকে গ্লোবাল ভ্যারিয়েবলে সংরক্ষণ করুন।Info['account']['init_balance']মধ্যম
   • লাভের হিসাব করা: বর্তমান ব্যালেন্স এবং প্রাথমিক ব্যালেন্সের উপর ভিত্তি করে লাভ এবং লাভের মার্জিন গণনা করে।

2. UpdatePositionফাংশন：

   • অবস্থানের তথ্য পান: কল করুনexchange.GetPositions()বর্তমান অবস্থানের অবস্থা জানুন।
   • অবস্থান আপডেট করুন： অর্জিত অবস্থানের তথ্যের উপর ভিত্তি করে লক্ষ্য মুদ্রার অবস্থানের তথ্য আপডেট করুন (যেমনamount、hold_price、unrealised_profitঅপেক্ষা করুন)।
   • লিভারেজ গণনা করা হচ্ছেবর্তমান লং এবং শর্ট পজিশনের মান এবং মার্জিন ব্যালেন্সের উপর ভিত্তি করে সামগ্রিক লিভারেজ অনুপাত গণনা করে।

এই দুটি ফাংশনের মাধ্যমে, কৌশলটি অ্যাকাউন্টের অবস্থা এবং অবস্থানের পরিবর্তনগুলি ক্রমাগত পর্যবেক্ষণ করতে পারে, পরবর্তী ট্রেডিং সিদ্ধান্তগুলির জন্য রিয়েল-টাইম ডেটা সহায়তা প্রদান করে।

বাণিজ্য

কৌশলগত যুক্তির উপর ভিত্তি করে ক্রয় বা বিক্রয় অর্ডার কার্যকর করুন। এগুলি বাজার আদেশ, সীমা আদেশ, অথবা অন্যান্য ধরণের অর্ডার হতে পারে। এই ধাপে ক্রয় বা বিক্রয় অনুরোধ পাঠানোর জন্য এক্সচেঞ্জের API এর সাথে ইন্টারঅ্যাক্ট করা জড়িত। সফল অর্ডার কার্যকরকরণ অ্যাকাউন্টের ব্যালেন্স এবং ওপেন ইন্টারেস্টকে প্রভাবিত করে।

উদ্দেশ্যঃ

• ক্রয়-বিক্রয় কার্যক্রম সম্পন্ন করার জন্য API এর মাধ্যমে ট্রেডিং নির্দেশাবলী জারি করুন।
• অর্ডারের ধরণ এবং পরিমাণ কৌশলগত প্রয়োজনীয়তা এবং বিনিময় বিধি মেনে চলছে কিনা তা নিশ্চিত করুন।

# 订单函数
def Order(symbol, direction, price, amount, msg):
    pair = f"{symbol}_{Info['base_coin']}.swap"  # 构造交易对名称
    ret = exchange.CreateOrder(pair, direction, price, amount, msg)  # 执行下单操作
    
    # 判断是否下单成功
    if ret:
        Info['order'][symbol][direction]['id'] = ret  # 记录订单ID
        Info['order'][symbol][direction]['price'] = price  # 记录下单价格
    else:
        Log(f"{symbol} {direction} {price} {amount} 下单异常")  # 输出异常信息

# 交易函数
def Trade(symbol, direction, price, amount, msg):
    
    # 根据最小价格变动调整价格
    price = round(price - (price % Info['precision'][symbol]['tick_size']), Info['precision'][symbol]['price_precision'])
    
    # 计算调整后的交易数量
    amount = amount / Info['precision'][symbol]['ctVal']  # 计算真实合约数量
    amount = round(amount - (amount % Info['precision'][symbol]['amount_size']), Info['precision'][symbol]['amount_precision'])

    # 限制最大交易数量
    if Info['precision'][symbol]['max_qty'] > 0:
        amount = min(amount, Info['precision'][symbol]['max_qty'])
    
    new_order = False
    
    # 如果新价格与之前的订单价格差异大于0.0001，则重新下单

    if Info['order'][symbol][direction]['price'] > 0 and abs(price - Info['order'][symbol][direction]['price']) / price > 0.0001:
        Log('已持订单，订单价格发生变化')
        new_order = True
    
    # 如果交易数量为0或者当前订单ID为0，则撤单
    if amount <= 0 or Info['order'][symbol][direction]['id'] == 0:
        Log('新订单产生')
        new_order = True
    
    # 如果需要新订单
    if new_order:
        # 如果有原有订单，撤销它
        if Info['order'][symbol][direction]['id'] != 0:
            exchange.CancelOrder(Info['order'][symbol][direction]['id'])
            Info['order'][symbol][direction]['id'] = 0
            Info['order'][symbol][direction]['price'] = 0
            Log('撤单成功：', symbol)
        
        
        # 如果更新仓位或ticker的延迟太高，则不下单
        if (time.time() * 1000 - Info['time']['update_pos_time'] > 2 * Info['interval'] * 1000 or 
            time.time() * 1000 - Info['time']['update_ticker_time'] > 2 * Info['interval'] * 1000):
            Log(time.time() * 1000, Info['time']['update_pos_time'], time.time() * 1000 - Info['time']['update_pos_time'])
            Log(time.time() * 1000, Info['time']['update_ticker_time'], time.time() * 1000 - Info['time']['update_ticker_time'])
            Log('延迟过高')
            return
        
        # 如果订单金额或数量过低，不执行下单操作
        if price * amount <= Info['precision'][symbol]['min_notional'] or amount < Info['precision'][symbol]['min_qty']:
            Log(f"{symbol} 下单量太低", price * amount)
            return
        
        # 执行下单操作
        Log('order下单:', symbol)
        Order(symbol, direction, price, amount, msg)

1. Orderফাংশন：

   • অর্ডার তৈরির জন্য দায়িত্বপ্রাপ্ত। সফল হলে, এটি অর্ডার আইডি এবং মূল্য রেকর্ড করবে। ব্যর্থ হলে, এটি একটি ত্রুটি বার্তা আউটপুট করবে।

2. Tradeফাংশন：

   • অর্ডার কার্যকর করার ত্রুটি বা পুনরাবৃত্তিমূলক ক্রিয়াকলাপ এড়াতে বাজার মূল্য এবং পরিমাণের উপর ভিত্তি করে সামঞ্জস্য করুন যাতে অর্ডারটি বাতিল করে নতুন অর্ডার দেওয়া যায় কিনা তা নির্ধারণ করা যায়।

3. CancelOrderফাংশন：

   • এটি একটি কাস্টমাইজড অর্ডার বাতিলকরণ অপারেশন, যা বর্তমান মুলতুবি থাকা অর্ডার বাতিল করার জন্য দায়ী।

স্থিতি প্রদর্শন

কৌশলটির অপারেটিং স্ট্যাটাস রিয়েল টাইমে প্রদর্শিত হয়, যার মধ্যে অ্যাকাউন্ট ব্যালেন্স, বর্তমান অবস্থান, ট্রেড এক্সিকিউশন স্ট্যাটাস, বর্তমান বাজার মূল্য ইত্যাদি অন্তর্ভুক্ত। এই পদক্ষেপটি কেবল কৌশলটির কার্যকারিতা পর্যবেক্ষণের জন্য নয়, বরং কৌশল অপ্টিমাইজেশন এবং ডিবাগিংয়ের সময় কৌশলটির কার্যকারিতা দ্রুত বোঝার জন্যও।

উদ্দেশ্যঃ

• ব্যবহারকারীর পর্যবেক্ষণ সহজতর করার জন্য কৌশলগত কার্যক্রমের মূল তথ্য সময়মত প্রদর্শন করুন।
• লেনদেন সফলভাবে সম্পাদিত হয়েছে কিনা বা কোনও ত্রুটি ছিল কিনা তা দেখানোর জন্য একটি প্রতিক্রিয়া ব্যবস্থা প্রদান করে।

# 更新状态函数
def UpdateStatus():
    
    # 如果距离上次更新的时间小于4秒，则直接返回
    if time.time() * 1000 - Info['time']['update_status_time'] < 4000:
        return
    
    # 更新状态时间
    Info['time']['update_status_time'] = time.time() * 1000

    # 账户信息表格
    table1 = {
        "type": "table",
        "title": "账户信息",
        "cols": [
            "初始余额", "钱包余额", "保证金余额", "已用保证金", "可用保证金",
            "总收益", "收益率", "未实现收益", "总持仓", "已用杠杆", "循环延时"
        ],
        "rows": [
            [
                Info['account']['init_balance'],  # 初始余额
                Info['account']['wallet_balance'],  # 钱包余额
                Info['account']['margin_balance'],  # 保证金余额
                Info['account']['margin_used'],  # 已用保证金
                Info['account']['margin_free'],  # 可用保证金
                Info['account']['profit'],  # 总收益
                str(Info['account']['profit_rate']) + "%",  # 收益率
                round(Info['account']['unrealised_profit'], 2),  # 未实现收益
                round(Info['count']['total'], 2),  # 总持仓
                Info['count']['leverage'],  # 已用杠杆
                str(Info['time']['loop_delay']) + "ms",  # 循环延时
            ],
        ],
    }
    
    # 交易对信息表格
    table2 = {
        "type": "table",
        "title": "交易对信息",
        "cols": [
            "币种", "方向", "数量", "持仓价格", "持仓价值", 
            "现价", "挂单买价", "挂单卖价", "未实现盈亏"
        ],
        "rows": [],
    }

    # 遍历每个交易对，填充交易对信息
    for symbol in Info['trade_symbols']:
        table2['rows'].append([
            symbol,  # 币种
            "LONG" if Info['position'][symbol]['amount'] > 0 else "SHORT",  # 方向
            round(Info['position'][symbol]['amount'], Info['precision'][symbol]['amount_precision'] + 2),  # 数量
            round(Info['position'][symbol]['hold_price'], Info['precision'][symbol]['price_precision']),  # 持仓价格
            round(Info['position'][symbol]['value'], 2),  # 持仓价值
            round(Info['ticker'][symbol]['last'], Info['precision'][symbol]['price_precision']),  # 现价
            Info['order'][symbol]['buy']['price'],  # 挂单买价
            Info['order'][symbol]['sell']['price'],  # 挂单卖价
            round(Info['position'][symbol]['unrealised_profit'], 2),  # 未实现盈亏
        ])

    # 输出状态日志
    LogStatus(
        f"初始化时间: {time.strftime('%Y-%m-%d %H:%M:%S', time.localtime(Info['time']['start_time']))}\n",
        f"`{json.dumps(table1)}`\n" + f"`{json.dumps(table2)}`\n",
        f"最后执行时间: {time.strftime('%Y-%m-%d %H:%M:%S', time.localtime())}\n"
    )

    # 每10秒钟更新一次账户信息
    if time.time() * 1000 - Info['time']['update_profit_time'] > 10 * 1000:
        UpdateAccount()  # 更新账户信息
        LogProfit(round(Info['account']['profit'], 3), '&')  # 输出收益日志
        Info['time']['update_profit_time'] = time.time() * 1000  # 更新收益时间

লেনদেনের যুক্তি

মূল ট্রেডিং সিদ্ধান্ত গ্রহণ প্রক্রিয়া। বাজারের তথ্য, অ্যাকাউন্টের তথ্য এবং অবস্থানের উপর ভিত্তি করে, প্রযুক্তিগত সূচক বা পরিমাণগত মডেলের সাথে মিলিত হয়ে, অবস্থান কেনা, বিক্রি করা, বৃদ্ধি করা বা হ্রাস করা হবে কিনা সে বিষয়ে সিদ্ধান্ত নেওয়া হয়। ট্রেডিং যুক্তি কৌশলের উপর নির্ভর করে পরিবর্তিত হয়, যেমন ট্রেন্ড-অনুসরণ, গড় রিভার্সন, বা ব্রেকআউট কৌশল।

উদ্দেশ্যঃ

• বাজারের তথ্য এবং অ্যাকাউন্টের স্থিতির উপর ভিত্তি করে বুদ্ধিমান ট্রেডিং সিদ্ধান্ত নিন।
• বিভিন্ন বাজার পরিস্থিতি পরিচালনা করুন এবং নিশ্চিত করুন যে কৌশলগুলি বিভিন্ন বাজার পরিবেশে যুক্তিসঙ্গতভাবে কাজ করতে পারে।

এই কাঠামোর প্রযোজ্যতা প্রদর্শনের জন্য, এই প্রবন্ধে ট্রেডিং কৌশলটি সহজ যুক্তি ব্যবহার করে। প্রতিটি অর্ডার ৫০ USDT এ স্থির করা হয়েছে, এবং ট্রেড সম্পাদনের সময়, বর্তমান বাজারের বিড এবং জিজ্ঞাসা মূল্যের উপর ভিত্তি করে সংশ্লিষ্ট ক্রয় বা বিক্রয় পরিমাণ গণনা করা হয়। এই কৌশলটির কার্যকরকরণ নিয়মগুলি খুবই মৌলিক, যা একটি লাইভ ট্রেডিং পরিবেশে মাল্টি-কারেন্সি ফিউচার ট্রেডিং কৌশল কাঠামো কীভাবে প্রয়োগ করতে হয় তা প্রদর্শনের উদ্দেশ্যে তৈরি। সরলতা এবং কার্যকারিতা নিশ্চিত করার জন্য, একটি স্টপিং শর্ত সেট করা হয়েছে: যখন একটি ট্রেডিং জোড়ার মোট ওপেন ইন্টারেস্ট মূল্য ২০০০ USDT এ পৌঁছায়, তখন আরও অর্ডার বন্ধ হয়ে যায়। এটি আমাদের কৌশলটির মৌলিক কাঠামো এবং এক্সচেঞ্জ থেকে প্রাপ্ত বাজারের ডেটার সাথে কাঠামো কীভাবে ইন্টারঅ্যাক্ট করে তা সুবিধাজনকভাবে প্রদর্শন করতে দেয়।

def MakeOrder():
    
    # 遍历所有交易对
    for symbol in Info['trade_symbols']:
        
        # 获取买价（挂单买价）
        buy_price = Info['ticker'][symbol]['bid']
        
        # 计算买入数量，根据买入金额除以买价
        buy_amount = 50 / buy_price

        # 获取卖价（挂单卖价）
        sell_price = Info['ticker'][symbol]['ask']
        
        # 计算买入数量，根据买入金额除以买价
        sell_amount = 50 / sell_price

        
        # 如果当前持仓的总价值小于2000，则进行买入操作
        if Info['position'][symbol]['value'] < 2000:
            Log('进入交易')
            Log('设定价格：', Info['ticker'][symbol]['bid'])
            Trade(symbol, "buy", buy_price, buy_amount, symbol)  # 执行买入操作
        
        #if Info['position'][symbol]['value'] < 3000:
        #    Trade(symbol, "sell", sell_price, sell_amount, symbol)  # 执行买入操作

প্রধান লুপ

মূল লুপ হল কৌশল কাঠামোর মূল অংশ, যা বাজারে কৌশলটির ধারাবাহিক এবং স্থিতিশীল কর্মক্ষমতা নিশ্চিত করার জন্য দায়ী। এটি নিয়মিতভাবে নির্দিষ্ট বিরতিতে বিভিন্ন ক্রিয়াকলাপ সম্পাদন করে, যেমন সর্বশেষ বাজার তথ্য প্রাপ্তি, অবস্থানের তথ্য আপডেট করা এবং ট্রেডিং সিদ্ধান্ত কার্যকর করা। প্রধান লুপের মাধ্যমে, কৌশলটি রিয়েল টাইমে বাজারের পরিবর্তনের প্রতিক্রিয়া জানাতে পারে এবং নিশ্চিত করতে পারে যে প্রতিটি কার্যকরকরণ সর্বশেষ বাজার তথ্যের উপর ভিত্তি করে করা হয়েছে। সাধারণত, মূল লুপটি প্রতি নতুন সময়কালে একবার ট্রিগার করা হয় (যেমন প্রতি মিনিটে, প্রতি ঘন্টায়, অথবা যখন একটি নতুন ক্যান্ডেলস্টিক তৈরি করা হয়)।

উদ্দেশ্যঃ

• কৌশলটির ধারাবাহিক এবং স্থিতিশীল কার্যকারিতা নিশ্চিত করুন, রিয়েল টাইমে বাজারের তথ্য সংগ্রহ করুন এবং ট্রেডিং সিদ্ধান্ত নিন।
• প্রতিটি চক্র কৌশল বাস্তবায়নের বাস্তব-সময় এবং নির্ভুলতা নিশ্চিত করে।

def OnTick():
    try:
        # 更新市场行情信息
        UpdateTicker()
        # 更新持仓信息
        UpdatePosition()
        # 执行下单操作
        MakeOrder()
        # 更新状态信息
        UpdateStatus()
    except Exception as error:
        # 记录循环中发生的错误
        Log("循环出错: " + str(error))

def main():
    LogReset(0)  
    apiBase = "https://testnet.binancefuture.com"  # 币安期货仿真交易所        
    exchange.SetBase(apiBase)  # 设置仿真交易所基站
    # 初始化信息
    exchange.IO('dual', False)  # 单向持仓
    InitInfo()
    GetPrecision()
    
    while True:  # 无限循环
        loop_start_time = time.time() * 1000  # 获取当前时间（毫秒）
        
        # 检查上次循环时间与设定的间隔时间是否已过
        if time.time() * 1000 - Info['time']['last_loop_time'] > Info['interval'] * 1000:
            OnTick()  # 调用 OnTick 函数
            
            # 更新最后一次循环时间
            Info['time']['last_loop_time'] = time.time() * 1000
            # 计算当前循环的延迟时间
            Info['time']['loop_delay'] = time.time() * 1000 - loop_start_time
        
        # 暂停5毫秒，避免过度消耗CPU资源
        Sleep(5000)

কোড ব্যাখ্যা:

1. OnTickফাংশনএই ফাংশনটি মূল লুপের মধ্যে প্রতিবার সম্পাদিত মূল কাজ। এটি বাজারের তথ্য, অবস্থানের তথ্য আপডেট করার, ট্রেড সম্পাদন করার এবং কৌশলগত অবস্থা আপডেট করার জন্য দায়ী। সমস্ত ট্রেডিং এবং তথ্য আপডেট এই ফাংশনের মধ্যে সম্পাদিত হয়। সম্পাদনের সময় যেকোনো ত্রুটি ক্যাপচার এবং লগ করা হয়।

2. mainফাংশন：প্রধান ফাংশনটি প্রাসঙ্গিক তথ্য শুরু করে, এক্সচেঞ্জ বেস স্টেশন সেট করে এবং একটি অসীম লুপ শুরু করে। প্রতিটি লুপে, প্রোগ্রামটি পরীক্ষা করে যে নির্ধারিত সময় ব্যবধানটি অতিক্রম করেছে কিনা। যদি তাই হয়,OnTickকৌশলটি কার্যকর করার জন্য ফাংশনটি ডাকা হবে। যদি সময়ের ব্যবধান এখনও না আসে, তাহলে প্রোগ্রামটি অপেক্ষা করবে এবং লুপটি চালিয়ে যাবে যাতে পূর্বনির্ধারিত সময়ের ব্যবধান অনুসারে কৌশলটি কার্যকর হয়।

3. বিলম্ব নিয়ন্ত্রণ: প্রতিটি লুপের পরে, প্রোগ্রামটি CPU লোড কমাতে 5 মিলিসেকেন্ডের জন্য বিরতি দেয়। এটি উচ্চ-ফ্রিকোয়েন্সি লুপের কারণে কম্পিউটিং রিসোর্সের অত্যধিক ব্যবহার এড়াতে।

অপারেশন লজিক

• আরম্ভের পর্যায়: প্রথমে API এবং অন্যান্য প্রয়োজনীয় প্যারামিটার সেট করুন, তারপর তথ্য শুরু করুন এবং মুদ্রার নির্ভুলতা পান।
• প্রধান লুপ ফেজ：একটি অসীম লুপ প্রবেশ করান, প্রতিটি লুপ সময়ের ব্যবধান পরীক্ষা করবে যাতে নিশ্চিত করা যায় যে নীতি কার্যকর করার জন্য সময়ের ব্যবধান প্রিসেট সেটিংস পূরণ করে।
• কার্যকরকরণ পর্যায়：সময় ব্যবধানের শর্ত পূরণের পর,OnTickএই ফাংশনটি বাজার তথ্য আপডেট, বাণিজ্য সম্পাদন ইত্যাদি সহ সমস্ত কৌশলগত ক্রিয়াকলাপ সম্পাদনের জন্য ডাকা হবে।

এই প্রধান লুপ ডিজাইনটি নিশ্চিত করে যে কৌশলটি রিয়েল-টাইম বাজারের পরিস্থিতিতে চলতে থাকে এবং সময়োপযোগী ট্রেডিং সিদ্ধান্ত নেয়, যার ফলে কৌশলটির স্থিতিশীলতা এবং নির্ভুলতা উন্নত হয়।

সারসংক্ষেপ

এই কৌশল কাঠামোটি মডুলারালিটি এবং স্কেলেবিলিটি মাথায় রেখে তৈরি করা হয়েছে। প্রতিটি ধাপের স্পষ্ট দায়িত্ব রয়েছে, যা ভবিষ্যতের সম্প্রসারণ এবং অপ্টিমাইজেশনকে সহজতর করার সাথে সাথে দৃঢ়তা নিশ্চিত করে। এক্সচেঞ্জ API ব্যবহার করে, কৌশলগুলিকে সুবিন্যস্ত করা যেতে পারে এবং ব্যাকটেস্টিং এবং রিয়েল-টাইম ট্রেডিংয়ের সাথে আরও সামঞ্জস্যপূর্ণ করা যেতে পারে।

প্রয়োজনলক্ষ্য করুনমনে রাখবেন যে এই ডেমোনস্ট্রেশন ফ্রেমওয়ার্কটি Binance সিমুলেটেড এক্সচেঞ্জকে উদাহরণ হিসেবে ব্যবহার করে, যার লক্ষ্য কৌশল উন্নয়ন এবং পরিচালনার জন্য একটি মৌলিক কাঠামো প্রদান করা। বাস্তবে, প্রকৃত কৌশলগত যুক্তির উপর ভিত্তি করে অপ্টিমাইজেশন প্রয়োজন হবে, যেমন বাজারের অবস্থার উপর ভিত্তি করে গতিশীলভাবে পরামিতিগুলি সামঞ্জস্য করা, ঝুঁকি নিয়ন্ত্রণ প্রক্রিয়া অপ্টিমাইজ করা এবং ব্যতিক্রম পরিচালনা যোগ করা। তদুপরি, API ইন্টারফেস, ট্রেডিং নিয়ম, নির্ভুলতা সেটিংস এবং এক্সচেঞ্জ জুড়ে ফি কাঠামোর পার্থক্যের কারণে, কৌশলগত স্থিতিশীলতা এবং সামঞ্জস্য নিশ্চিত করার জন্য প্রকৃত বাস্তবায়নে লক্ষ্য এক্সচেঞ্জের নির্দিষ্ট প্রয়োজনীয়তার উপর ভিত্তি করে বিস্তারিত অপ্ট�