Compiled google protocol buffer files can be found here: client-python\compiledProto

https://mlink-live.nms.saturn.spiderrockconnect.com/rest/JSON?apikey=APIKEY&cmd=getmsgtypes&view=name|mnum

to get the messageNumber and Message Type

import MLinkStream_pb2
import spiderrock_common_pb2
import StockBookQuote_pb2
import MLinkAdmin_pb2
import MLinkSubscribeAck_pb2
import asyncio
import websockets

uri = 'wss://mlink-live.nms.saturn.spiderrockconnect.com/mlink/proto'  
authentication_key = 'Your Api Key' 

async def query_mlinkstream(uri, authentication_key):
    async with websockets.connect(uri, extra_headers={"Authorization": f"Bearer {authentication_key}"}) as websocket:
        full_admin_response = await websocket.recv()
        admin_proto_message = full_admin_response[14:]
        admin_response = MLinkAdmin_pb2.MLinkAdmin()
        admin_response.ParseFromString(admin_proto_message)
        print(admin_response)

        mlink_stream = MLinkStream_pb2.MLinkStream()
        mlink_stream.msg_name = "StockBookQuote"
        mlink_stream.view = "askPrice1|bidPrice1"
        mlink_stream.active_latency = 1
        mlink_stream.query_label = "Apple Stock"
        mlink_stream.where = 'ticker.tk:eq:AAPL' 

        mt = spiderrock_common_pb2.MessageMetadata()
        mlink_stream._meta.message_type = 'MLinkStream'

        serialized_msg = mlink_stream.SerializeToString()

        header = f'\r\nP{3380:05d}{len(serialized_msg):06d}'.encode()
        await websocket.send(header + serialized_msg)

        while True:
            response = await websocket.recv()

            parts = list(filter(None,response.split(b'\r\n')))
            for msg in parts:
                header, message = msg[:12], msg[12:]
                message_type = int(header[2:6])

                if message_type == 3000:  
                    StockBookQuote = StockBookQuote_pb2.StockBookQuote()
                    StockBookQuote.ParseFromString(message)
                    print("StockBookQuote:", StockBookQuote)
                elif message_type == 3387:
                    mlink_sub_ack = MLinkSubscribeAck_pb2.MLinkSubscribeAck()
                    mlink_sub_ack.ParseFromString(message)
                    print("MLinkSubscribeAck:", mlink_sub_ack)
                else:
                    print("Unknown message type:", message_type)


if __name__ == "__main__": 
    asyncio.run(query_mlinkstream(uri, authentication_key))
ClientStripesClientSubscribe