Перейти к публикации
Форум ботоводов

b1x2

Members
  • Публикации

    8
  • Зарегистрирован

  • Посещение

Сообщения, опубликованные пользователем b1x2

  1. у меня каждый стрим в отдельном потоке

    пока не понимаю как перезапускать стримы в этом случае. я конечно тот еще мамкинпрограммист. Помогите плз кто знает

     ws = websocket.WebSocketApp(
            "wss:.............
            on_message=on_message,
            on_error=on_error,
            on_close=on_close)
        ws.on_open = on_open

    threads.append(threading.Thread(target=ws.run_forever, args=(None, {"cert_reqs": ssl.CERT_NONE},)))

        for thread in threads:
            thread.start()
        for thread in threads:
            thread.join()
     

  2. Спасибо, все получилось! 

    Подскажите пожалуйста еще как грамотно пересоздавать коннект раз в сутки

    можно на базе вашего примера

    import json
    import websocket
    
    def on_message(ws, message):
        obj = json.loads(message)
        print(obj['s'], obj['p'])
    
    def on_error(ws, error):
        print(error)
    
    def on_close(ws):
        print("### closed ###")
    
    def on_open(ws):
        print("### connected ###")
    
    if __name__ == "__main__":
        ws = websocket.WebSocketApp("wss://stream.binance.com:9443/ws/ltcbtc@aggTrade/ethbtc@aggTrade",
                                  on_message = on_message,
                                  on_error = on_error,
                                  on_close = on_close)
        ws.on_open = on_open
        ws.run_forever()
  3. подскажите пож-ста что добавить в файл binance_api.py для использования 

    Dust Transfer (USER_DATA)

    Post /sapi/v1/asset/dust (HMAC SHA256)
    

    Convert dust assets to BNB.

    Weight: 1

    Parameters:

    Name Type Mandatory Description
    asset ARRAY YES The asset being converted. For example: asset=BTC&asset=USDT
    recvWindow LONG NO  
    timestamp LONG YES
×
×
  • Создать...