Tick-by-Tick (TBT) Socket - Connection (50 Market Depth)

This WebSocket allows you to connect to the Tick-by-Tick socket and subscribe to 50-level market depth.

USE CASE

Stream 50-level depth for the few symbols you trade closely, such as a Nifty or Bank Nifty futures contract.

Currently, these are the features available on the socket:

Feature	Description	Status
TBT 50 Market Depth	TBT 50 Market Depth provides users with 50 levels of market depth. Learn more	Available

Mandatory connection parameters

To connect to the TBT WebSocket, the below input parameters are mandatory:

Parameter	Value
Endpoint	`wss://rtsocket-api.fyers.in/versova`
Header Key	`Authorization`
Header Format	`<appId:accessToken>`
Sample Header	`7ABXUX38S-100:eyJ0eXAi**********qiTnzd2lGwS17s`

Details

Tick-by-tick data is available only for NFO (NSE Futures & Options) and NSE equity symbols.
See Rate limits for connection and channel limits.
A subscribe request needs the symbols, the mode (depth) and a channel number. Data starts only after you resume that channel.
The first packet for a subscription is a snapshot. Later packets hold only the differences, which you apply to the snapshot. The SDKs do this for you.
Server errors come through the error-message callback (on_error_message in Python, servererror in Node). In a response, error is true, feeds is empty and msg mostly holds the error message.
In the Node SDK, call autoreconnect() before connect() to reconnect automatically after a disconnect. Send the string ping to keep the connection alive.
SDK support: TBT 50 depth is available from the Python SDK v3.1.7 (04 Mar 2025) and the Node SDK v1.4.1 (26 Mar 2025). See the Change Log.

Plan limits

Standard plan

1 symbol, counted per user across all connections
1 active connection

Prime plan

15 symbols, counted per user across all connections
Up to 3 active connections with 5 symbols each

For rate limits and all other plan details, see Plans & rate limits.

WSSwss://rtsocket-api.fyers.in/versova

Authorization: <appId:accessToken>

from fyers_apiv3.FyersWebsocket.tbt_ws import FyersTbtSocket, SubscriptionModes

def onopen():
    """
    Callback function to subscribe to data type and symbols upon WebSocket connection.

    """
    print("Connection opened")
    # Specify the data type and symbols you want to subscribe to
    mode = SubscriptionModes.DEPTH
    Channel = '1'
    # Subscribe to the specified symbols and data type
    symbols = ['NSE:NIFTY25MARFUT', 'NSE:BANKNIFTY25MARFUT']
    
    fyers.subscribe(symbol_tickers=symbols, channelNo=Channel, mode=mode)
    fyers.switchChannel(resume_channels=[Channel], pause_channels=[])

    # Keep the socket running to receive real-time data
    fyers.keep_running()

def on_depth_update(ticker, message):
    """
    Callback function to handle incoming messages from the FyersDataSocket WebSocket.

    Parameters:
        ticker (str): The ticker symbol of the received message.
        message (Depth): The received message from the WebSocket.

    """
    print("ticker", ticker)
    print("depth response:", message)
    print("total buy qty:", message.tbq)
    print("total sell qty:", message.tsq)
    print("bids:", message.bidprice)
    print("asks:", message.askprice)
    print("bidqty:", message.bidqty)
    print("askqty:", message.askqty)
    print("bids ord numbers:", message.bidordn)
    print("asks ord numbers:", message.askordn)
    print("issnapshot:", message.snapshot)
    print("tick timestamp:", message.timestamp)


def onerror(message):
    """
    Callback function to handle WebSocket errors.

    Parameters:
        message (dict): The error message received from the WebSocket.

    """
    print("Error:", message)


def onclose(message):
    """
    Callback function to handle WebSocket connection close events.
    """
    print("Connection closed:", message)

def onerror_message(message):
    """
    Callback function for error message events from the server

    Parameters:
        message (dict): The error message received from the Server.

    """
    print("Error Message:", message)

# Replace the sample access token with your actual access token obtained from Fyers
access_token = "XCXXXXXXM-100:eyJ0tHfZNSBoLo"


fyers = FyersTbtSocket(
    access_token=access_token,  # Your access token for authenticating with the Fyers API.
    write_to_file=False,        # A boolean flag indicating whether to write data to a log file or not.
    log_path="",                # The path to the log file if write_to_file is set to True (empty string means current directory).
    on_open=onopen,          # Callback function to be executed upon successful WebSocket connection.
    on_close=onclose,           # Callback function to be executed when the WebSocket connection is closed.
    on_error=onerror,           # Callback function to handle any WebSocket errors that may occur.
    on_depth_update=on_depth_update, # Callback function to handle depth-related events from the WebSocket
    on_error_message=onerror_message         # Callback function to handle server-related erros from the WebSocket.
)
# Establish a connection to the Fyers WebSocket
fyers.connect()

const { SubscriptionModes } = require("../tbtsocket/models.js")

var fyersOrderSocket= require("../index.js").fyersTbtSocket

var skt=new fyersOrderSocket("eyJ0eXAiOiJKV1QiLCJhbGciOiJIUzI1NiJ9.eyJpc3********************************************")

skt.on("error",function (errmsg) {
    console.log(errmsg)
})
skt.on('open', function() {
    skt.subscribe(['NSE:NIFTY25FEBFUT', 'NSE:IOC25FEBFUT', 'NSE:BANKNIFTY25FEBFUT', 'NSE:FINNIFTY25FEBFUT', 'NSE:TCS25FEBFUT'], '1', SubscriptionModes.DEPTH)
    skt.switchChannel([], ['1'])
})
skt.on('depth',function (ticker, data) {
    console.log('depth',ticker, data)
})
skt.on('close',function () {
    console.log('closed')
})
skt.on('servererror',function (msg) {
    console.log('serverr', msg)
})
skt.autoreconnect()
skt.connect()