بائن اینڈو کرنسی ویب ساکٹ مارکیٹ تک رسائی کی مثال - پطرون

ایف ایم زیڈ کے ساتھ تقریبا 2 ماہ ، کچھ حکمت عملیوں کی آمدنی اچھی طرح سے چل رہی ہے ، مجھے لگتا ہے کہ کمیونٹی میں تھوڑا سا حصہ ڈالنا ضروری ہے ، اب ویب ساکٹ کی مثالیں دیکھ کر بہت کم ہیں ، سبسکرائب کریں ملٹی اسٹریم ملٹی کرنسی ویب ساکٹ مارکیٹ کی مثال میں حصہ ڈالیں ، نسبتا آسان ، مارکیٹ حاصل کریں ، گردش میں مارکیٹ پرنٹ کریں json.

ایک ہی وقت میں کئی کرنسیوں کی تجارت کی جاتی ہے تو فرق بہت بڑا ہے، امید ہے کہ یہ مددگار ثابت ہو جائے گا.

#websocket 更新 行情
# {
#   "e":"bookTicker",     // 事件类型
#   "u":400900217,        // 更新ID
#   "E": 1568014460893,   // 事件推送时间
#   "T": 1568014460891,   // 撮合时间
#   "s":"BNBUSDT",        // 交易对
#   "b":"25.35190000",    // 买单最优挂单价格
#   "B":"31.21000000",    // 买单最优挂单数量
#   "a":"25.36520000",    // 卖单最优挂单价格
#   "A":"40.66000000"     // 卖单最优挂单数量
# }
def on_msg(msg) : #更新行情

    if msg is not None and len(msg)>0:
        bookTicker = json.loads(msg)
    else:
        # Log('book tick msg is none')
        return

    Log(bookTicker)

def main():
    SetErrorFilter("502:|503:|tcp|character|unexpected|network|timeout|WSARecv|Connect|GetAddr|no such|reset|http|received|EOF|reused|Unknown")
   
    trade_symbols = 'TRX,ZEC,DENT,BLZ,ENJ,ZIL,MANA,ONT,XMR,ICX,SC,THETA,CVC,BAT,STMX,VET,IOST,NEO,MTL,DASH,KNC,ZRX,IOTA'.split(',')

    ary_symbol_streams = []

    for i in range(len(trade_symbols)):
        symbol = trade_symbols[i].lower()
        stream_client = Dial(f"wss://fstream.binance.com/ws/{symbol}usdt@bookTicker|reconnect=true")
        ary_symbol_streams.append(stream_client)
    while (true):

        for item in ary_symbol_streams:
            #-2读取最新数据
            msg = item.read(-2)
            on_msg(msg)