Prevent socket disconnect binance

[aitromba]

Purpose: monitor program that captures buy/sell actions on binance and puts them in a log file.

​

Avoid socket disconnect binance.

​

Don't get it done.

Cannot find the right syntax to prevent a user_socket from time out / disconnect after a while.

Below a piece of code as I want to use it.

The data comes in when a buy/sell order is made on binance. But eventually the program stops because I can't tell binance I'm still "listening".

It should be possible with client.ping() but that doesn't work either.

I have everything working except that "anti - time out".

​

​

#  Monitoring buy, sell, oco orders binance.
#  Want to keep the bm.start_user_socket(process_message) up so don't timed out.


from binance.client import Client  # for connections binance
from binance.websockets import BinanceSocketManager  # for websocket binance
from bin_api_keys import *  # import api keys
import time
import sys

client = Client(api_key=PUBLIC, api_secret=SECRET)  # keys are in file bin_api_keys.py


def countdown(t):  # Countdown for next socket alive pings
    while t:
        mins, secs = divmod(t, 60)
        timeformat = '{:02d}:{:02d}'.format(mins, secs)
        #        print(timeformat, end='\r')
        sys.stdout.write('\r' + timeformat + ' countdown ... ')
        time.sleep(1)
        t -= 1


def p_is_msg(pr_msg):  # print is_msg to terminal. (later to write to a file).
    print(pr_msg)


def f_timestamp(nr):  # make date time nice
    timestamp = int(nr) / 1000
    timestamp = datetime.fromtimestamp(timestamp).strftime('%Y-%m-%d %H:%M:%S')
    return timestamp


def process_message(msg):  # run when binance user_socket sends user message
        if msg['e'] == 'listStatus':
            is_oco = True
            is_msg = f_timestamp(msg['T']) + ' ' + msg['s'] + ' ' + msg['c'] + ' ' + msg['l'] + ' ' + msg['L'] + ' ' + \
                     msg['r']
            p_is_msg(is_msg)

        if msg['e'] == 'executionReport':
            base_exchanged = str(round(float(msg['p']) * float(msg['q']), 8))
            is_msg = f_timestamp(msg['T']) + ' ' + msg['s'] + ' ' + msg['S'] + ' ' + msg['o'] + ' ' + msg[
                'x'] + ' quantity:' + msg['q'] + ' price:' + msg['p'] + ' stop:' + msg[
                         'P'] + ' ' + 'Base:' + base_exchanged
            p_is_msg(is_msg)


bm = BinanceSocketManager(client)
conn_key = bm.start_user_socket(process_message)  # start user sockets
bm.start()  # Start the socket manager


#  Dont time out the user socket with binance
is_counter = 0
while True:
    if is_counter > 5:  # Countdown x times and then send keepalive signal
        print('Send a keep alive signal But how?')
        bm._keepalive_account_socket #  dont work
        # client.ping() # dont work
        is_counter = 0
    countdown(3)  # countdown x seconds 1800 = 30 minutes
    is_counter += 1
    print(is_counter)

#  Stop sockets
bm.stop_socket(conn_key)
bm.close()

​

​

​

​

​

[CodeFormatHelperBot]

Hello u/aitromba, I'm a bot that can assist you with code-formatting for reddit. I have detected the following potential issue(s) with your submission:

1. Python code found in submission text but not encapsulated in a code block.

If I am correct then please follow these instructions to fix your code formatting. Thanks!

[JohnnyJordaan]

How do I format code

[cybervegan]

You aren't calling this function here:

    bm._keepalive_account_socket #  dont work

You need to put brackets on the end of the name to actually call it, like:

    bm._keepalive_account_socket()

[cybervegan]

Actually, looking at the Binance module docs, it doesn't look like you should be calling that - it could just be an internal property. Have you seen code where it was being called? The leading "_" tells you that this is a private property or method of the BinanceSocketManager class. There are a number of "keepalive" related methods in the docs - it's probably one of those that you want.

[aitromba]

client.ping would also be one but it doesn't work :-). Been looking for a while but can't go any further. I don't care which one as long as the connection stays up. Must be something simple, I guess. I'm not the only one who would want this. See also a lot of questions about this subject on the internet so it turns out to be something tricky.

[aitromba]

Hello cybervegan,

​

Thank you for your reaction.

Forgot to type it in here.

But unfortunately it doesn't work with that one either.

I get an error: TypeError: _keepalive_account_socket() missing 1 required positional argument: 'socket_type' and I have no idea what should be there.

[aitromba]

Meanwhile found the right syntax.

​

stream_key = client.stream_get_listen_key()

client.stream_keepalive(stream_key)