Thanks, I rechecked my code after upgrading to streamer, here is the log.
(ai-ml-new) â nse-bse-scrapper git:(refactor-upstox-websocket-sdk) â /opt/anaconda3/envs/ai-ml-new/bin/python /Users/om/Documents/workspaces/rnd/nse-bse-scrapper/upstox/upstox_websocket.py
2025-10-09 19:04:39,428 - MainThread - INFO - â Upstox SDK WebSocket Subscriber Service Started â
2025-10-09 19:04:39,428 - MainThread - INFO - Attempting to get a single access token using app: ârnd1â
2025-10-09 19:04:39,428 - MainThread - INFO - Requesting token for app ârnd1â using cache file â/Users/om/Documents/workspaces/rnd/nse-bse-scrapper/cache/upstox_auth_rnd1.jsonâ
2025-10-09 19:04:39,560 - MainThread - INFO -
Todayâs token is valid. Reusing it.
2025-10-09 19:04:39,561 - MainThread - INFO -
Successfully obtained a single access token.
2025-10-09 19:04:39,573 - MainThread - INFO - Loading instruments from cache: cache/upstox_nfo_instruments.json
2025-10-09 19:04:39,989 - MainThread - INFO -
List of subscribed trading symbols saved to subscribed_options.log
2025-10-09 19:04:39,989 - MainThread - INFO -
Instrument Selection Summary: Total selected for subscription: 7890
2025-10-09 19:04:39,998 - MainThread - INFO - Distributing 7890 instruments into 4 chunks of max 1999 each.
2025-10-09 19:04:39,999 - MainThread - INFO -
â Starting 4 WebSocket streamer(s) (capped at 4) â
2025-10-09 19:04:40,007 - RabbitMQ-Publisher - INFO - Pika version 1.3.2 connecting to (â100.69.32.37â, 5672)
2025-10-09 19:04:40,017 - RabbitMQ-Publisher - INFO - Socket connected: <socket.socket fd=16, family=AddressFamily.AF_INET, type=SocketKind.SOCK_STREAM, proto=6, laddr=(â100.81.211.105â, 52084), raddr=(â100.69.32.37â, 5672)>
2025-10-09 19:04:40,017 - RabbitMQ-Publisher - INFO - Streaming transport linked up: (<pika.adapters.utils.io_services_utils._AsyncPlaintextTransport object at 0x1415891b0>, _StreamingProtocolShim: <SelectConnection PROTOCOL transport=<pika.adapters.utils.io_services_utils._AsyncPlaintextTransport object at 0x1415891b0> params=>).
2025-10-09 19:04:40,042 - RabbitMQ-Publisher - INFO - AMQPConnector - reporting success: <SelectConnection OPEN transport=<pika.adapters.utils.io_services_utils._AsyncPlaintextTransport object at 0x1415891b0> params=>
2025-10-09 19:04:40,042 - RabbitMQ-Publisher - INFO - AMQPConnectionWorkflow - reporting success: <SelectConnection OPEN transport=<pika.adapters.utils.io_services_utils._AsyncPlaintextTransport object at 0x1415891b0> params=>
2025-10-09 19:04:40,042 - RabbitMQ-Publisher - INFO - Connection workflow succeeded: <SelectConnection OPEN transport=<pika.adapters.utils.io_services_utils._AsyncPlaintextTransport object at 0x1415891b0> params=>
2025-10-09 19:04:40,042 - RabbitMQ-Publisher - INFO - Created channel=1
2025-10-09 19:04:40,053 - RabbitMQ-Publisher - INFO -
[RabbitMQ] Connection established. Exchange âangelone-tick-exchangeâ is ready.
2025-10-09 19:04:40,258 - Thread-14 (run_forever) - INFO - Websocket connected
2025-10-09 19:04:40,258 - Thread-14 (run_forever) - INFO -
[Streamer-1] Connection opened. Subscribing to 1999 instruments.
2025-10-09 19:04:40,529 - Thread-14 (run_forever) - INFO -
Received initial feed confirmation for 1999 instruments.
2025-10-09 19:04:42,465 - Thread-16 (run_forever) - INFO - Websocket connected
2025-10-09 19:04:42,465 - Thread-16 (run_forever) - INFO -
[Streamer-2] Connection opened. Subscribing to 1999 instruments.
2025-10-09 19:04:42,771 - Thread-16 (run_forever) - INFO -
Received initial feed confirmation for 1999 instruments.
2025-10-09 19:04:44,450 - Thread-17 (run_forever) - INFO - Websocket connected
2025-10-09 19:04:44,451 - Thread-17 (run_forever) - INFO -
[Streamer-3] Connection opened. Subscribing to 1999 instruments.
2025-10-09 19:04:44,746 - Thread-17 (run_forever) - INFO -
Received initial feed confirmation for 1999 instruments.
2025-10-09 19:04:46,258 - Thread-18 (run_forever) - ERROR -
[Streamer-4] An error occurred: Handshake status 403 Forbidden -±± {âdateâ: âThu, 09 Oct 2025 13:34:46 GMTâ, âtransfer-encodingâ: âchunkedâ, âconnectionâ: âkeep-aliveâ} -±± None
2025-10-09 19:04:46,260 - Thread-18 (run_forever) - ERROR - Handshake status 403 Forbidden -±± {âdateâ: âThu, 09 Oct 2025 13:34:46 GMTâ, âtransfer-encodingâ: âchunkedâ, âconnectionâ: âkeep-aliveâ} -±± None - goodbye
2025-10-09 19:04:46,260 - Thread-18 (run_forever) - WARNING -
[Streamer-4] Connection closed. Code: None, Reason: None
2025-10-09 19:04:46,494 - Thread-19 (run_forever) - ERROR -
[Streamer-4] An error occurred: Handshake status 403 Forbidden -±± {âdateâ: âThu, 09 Oct 2025 13:34:46 GMTâ, âtransfer-encodingâ: âchunkedâ, âconnectionâ: âkeep-aliveâ} -±± None
2025-10-09 19:04:47,503 - Thread-19 (run_forever) - ERROR - Handshake status 403 Forbidden -±± {âdateâ: âThu, 09 Oct 2025 13:34:46 GMTâ, âtransfer-encodingâ: âchunkedâ, âconnectionâ: âkeep-aliveâ} -±± None - goodbye
2025-10-09 19:04:47,730 - Thread-20 (run_forever) - ERROR -
[Streamer-4] An error occurred: Handshake status 403 Forbidden -±± {âdateâ: âThu, 09 Oct 2025 13:34:47 GMTâ, âtransfer-encodingâ: âchunkedâ, âconnectionâ: âkeep-aliveâ} -±± None
2025-10-09 19:04:48,020 - MainThread - INFO -
â All 4 WebSocket connections are running. â
2025-10-09 19:04:48,020 - MainThread - INFO - â Service is now in supervisor mode. Press CTRL+C to shut down. â
2025-10-09 19:04:48,735 - Thread-20 (run_forever) - ERROR - Handshake status 403 Forbidden -±± {âdateâ: âThu, 09 Oct 2025 13:34:47 GMTâ, âtransfer-encodingâ: âchunkedâ, âconnectionâ: âkeep-aliveâ} -±± None - goodbye
2025-10-09 19:04:49,093 - Thread-21 (run_forever) - ERROR -
[Streamer-4] An error occurred: Handshake status 403 Forbidden -±± {âdateâ: âThu, 09 Oct 2025 13:34:49 GMTâ, âtransfer-encodingâ: âchunkedâ, âconnectionâ: âkeep-aliveâ} -±± None
2025-10-09 19:04:50,100 - Thread-21 (run_forever) - ERROR - Handshake status 403 Forbidden -±± {âdateâ: âThu, 09 Oct 2025 13:34:49 GMTâ, âtransfer-encodingâ: âchunkedâ, âconnectionâ: âkeep-aliveâ} -±± None - goodbye
2025-10-09 19:04:50,451 - Thread-22 (run_forever) - ERROR -
[Streamer-4] An error occurred: Handshake status 403 Forbidden -±± {âdateâ: âThu, 09 Oct 2025 13:34:50 GMTâ, âtransfer-encodingâ: âchunkedâ, âconnectionâ: âkeep-aliveâ} -±± None
2025-10-09 19:04:51,459 - Thread-22 (run_forever) - ERROR - Handshake status 403 Forbidden -±± {âdateâ: âThu, 09 Oct 2025 13:34:50 GMTâ, âtransfer-encodingâ: âchunkedâ, âconnectionâ: âkeep-aliveâ} -±± None - goodbye
2025-10-09 19:04:51,817 - Thread-23 (run_forever) - ERROR -
[Streamer-4] An error occurred: Handshake status 403 Forbidden -±± {âdateâ: âThu, 09 Oct 2025 13:34:51 GMTâ, âtransfer-encodingâ: âchunkedâ, âconnectionâ: âkeep-aliveâ} -±± None
2025-10-09 19:04:51,818 - Thread-23 (run_forever) - ERROR - Handshake status 403 Forbidden -±± {âdateâ: âThu, 09 Oct 2025 13:34:51 GMTâ, âtransfer-encodingâ: âchunkedâ, âconnectionâ: âkeep-aliveâ} -±± None - goodbye
^C2025-10-09 19:04:53,051 - MainThread - INFO -
â Shutdown signal received. Exiting. â
2025-10-09 19:04:53,051 - MainThread - INFO - â Disconnecting all streamers⊠â
2025-10-09 19:04:53,076 - Thread-14 (run_forever) - WARNING -
[Streamer-1] Connection closed. Code: None, Reason: None
2025-10-09 19:04:53,105 - Thread-16 (run_forever) - WARNING -
[Streamer-2] Connection closed. Code: None, Reason: None
2025-10-09 19:04:53,129 - Thread-17 (run_forever) - WARNING -
[Streamer-3] Connection closed. Code: None, Reason: None
2025-10-09 19:04:53,130 - MainThread - INFO - â Service has been shut down. â
(ai-ml-new) â nse-bse-scrapper git:(refactor-upstox-websocket-sdk) â
I am unable to make 4th connection, upto 3 connections are getting established all the time