question

Upvotes
Accepted
johan.lundquist avatar image
21 ●8 ●6 ●12

Websocket API Future finished exception code=1001, reason='Going Away'

Hi,

I am testing to receive underlying options from a chain using the WebSocketAPI with Python in Windows.

Error message:

"Future exception was never retrieved

future: <Future finished exception=ConnectionClosedOK(Close(code=1001, reason='Going Away'), Close(code=1000, reason=''), False)>

websockets.exceptions.ConnectionClosedOK: sent 1000 (OK); then received 1001 (going away) Going Away"

It fails each time on loop 977.


Any advise on the meaning of this error and a possible resolution is appreciated. Simple code enclosed below (removed connection details):

import asyncio
import json
import socket
import websockets

hostname = ''
port = ''
ws_address = "ws://{}:{}/WebSocket".format(hostname, port)
user = ''
app_id = ''
position = socket.gethostbyname(socket.gethostname())

login_json = {
    'ID': 1,
    'Domain': 'Login',
    'Key': {
        'Name': '',
        'Elements': {
            'ApplicationId': '',
            'Position': ''        }
    }
}
login_json['Key']['Name'] = user
login_json['Key']['Elements']['ApplicationId'] = app_id
login_json['Key']['Elements']['Position'] = position

async def hello(initial_name):
    store = []
    #websocket vs websockets
    async with websocket.connect(ws_address, extra_headers={'User-Agent': 'Python'},
                                  subprotocols=['tr_json2'], ping_timeout=None, ping_interval=5) as websocket:
        await websocket.send(json.dumps(login_json))
        await websocket.recv()
        async def get_data_for_name(message):
            await websocket.send(json.dumps({
                'ID': 2,
                'Key': {
                    'Name': message,
                    'Service': '$svc',
                },
                "Streaming": False            }))
            res = await websocket.recv()
            json_res = json.loads(res[1:-1])
            store.append(json_res)
            print(json_res)
            if len(json_res['Fields']['BR_NEXTLR']) > 0:
                await get_data_for_name(json_res['Fields']['BR_NEXTLR'])
        await get_data_for_name(initial_name)
asyncio.run(hello('0#$chain'))


Kind regards,

Johan

trep#productwebsockets
icon clock
10 |1500

Up to 2 attachments (including images) can be used with a maximum of 512.0 KiB each and 1.0 MiB total.

2 Answers

· Write an Answer
Upvotes
Accepted
Jirapongse avatar image
83.1k ●281 ●53 ●77

@johan.lundquist

Thanks for reaching out to us.

The Refinitiv Real-Time WebSocket has its own ping/pong mechanism. The application will receive a ping message and it needs to send a pong message back to the server. 

Recieved:
{
        "Type": "Ping"
}
Sent:
{
    "Type": "Pong"
}

Therefore, you need to remove the ping_timeout and ping_interval settings from the WebSocket connection. 

    async with websockets.connect(ws_address, extra_headers={'User-Agent': 'Python'},
                                  subprotocols=['tr_json2']) as websocket:

I am unable to replicate the error. Please share the chain RICs that you are using.

I hope that this information is of help.

icon clock
10 |1500

Up to 2 attachments (including images) can be used with a maximum of 512.0 KiB each and 1.0 MiB total.

Upvotes
johan.lundquist avatar image
21 ●8 ●6 ●12

Thank you @Jirapongse,

It didn't help instead I got:

"websockets.exceptions.ConnectionClosedError: sent 1011 (unexpected error) keepalive ping timeout; no close frame received"

Adding back ping_timeout=None and I get the other error:

future: <Future finished exception=ConnectionClosedOK(Close(code=1001, reason='Going Away'), Close(code=1000, reason=''), False)>

websockets.exceptions.ConnectionClosedOK: sent 1000 (OK); then received 1001 (going away) Going Away.

I guess this would be the same for any Chain RIC with more than 977 BR_NEXTLR? In my specific case it is actually towards Bloomberg's 0#bgBBG000H4FSM0 via Bloomberg MFA pipe to TREP.

Kind regards,

Johan

icon clock
10 |1500

Up to 2 attachments (including images) can be used with a maximum of 512.0 KiB each and 1.0 MiB total.

Jirapongse avatar image Jirapongse

@johan.lundquist

As I know, the Refinitiv Real-Time WebSocket has its own ping/pong mechanism. It doesn't rely on the ping mechanism in the WebSocket.

If I set "ping_interval=5" in the WebSocket, I get an error because the server doesn't recognize the WebSocket internal ping messages.

However, you may need to contact the server team to verify its settings and the reason for the disconnection.


Write an Answer

Hint: Notify or tag a user in this post by typing @username.

Up to 2 attachments (including images) can be used with a maximum of 512.0 KiB each and 1.0 MiB total.