You will not receive a response like HTTP API call. You need to set callback on_connect and then call connect. You can refer to the Websocket API usage here.
from kiteconnect import KiteConnect from kiteconnect import KiteConnect, KiteTicker import json import time import pandas as pd
def load_api_keys(): try: with open('Zerodha credentials.json', 'r') as file: config = json.load(file) api_key = config['api_key'] api_secret = config['api_secret'] return api_key, api_secret except FileNotFoundError: print( "Config file not found. Please create a 'config.json' file with your API key and API secret." ) exit(1) except KeyError as e: print(f"Config file is missing the key: {e}") exit(1) api_key, api_secret = load_api_keys() kite = KiteConnect(api_key=api_key) request_token_url = kite.login_url() print(request_token_url) try: data = kite.generate_session(request_token, api_secret) if 'access_token' in data: access_token = data['access_token'] kite.set_access_token(access_token) def on_ticks(ws, ticks): if not ticks: print("No response from Kite for data.") else: for tick in ticks: if tick['instrument_type'] == 'NFO': print("NFO Stock Tick Data:", tick) with open('tick_data.json', 'a') as file: json.dump(tick, file) file.write('\n') # Add a new line after each tick else: print("No tick data received from the API or Kite server.") if not ticks and "Connection closed: 1006" in str(ws): print("Connection is closed because the market is closed.") def on_connect(ws, response): ws = KiteTicker(api_key, access_token) kws.on_ticks = on_ticks kws.on_connect = on_connect
while True: try: print("Connecting to WebSocket...") kws.connect() print("WebSocket connection successful.") break # Exit the loop if connection is successful except Exception as e: print("Error connecting to WebSocket:", e) print("Retrying in 5 seconds...") time.sleep(5) # Retry after 5 seconds
while True: try: print("Waiting for ticks...") time.sleep(1) except KeyboardInterrupt: # Close the WebSocket connection when interrupted kws.close() print("WebSocket connection closed.") break
Here is my complete syntax. but i am not getting the tick information and it is not getting printed on the terminal. Can you please help. i am thinking the information is not getting from kite.
on_connectand then call connect. You can refer to the Websocket API usage here.from kiteconnect import KiteConnect, KiteTicker
import json
import time
import pandas as pd
def load_api_keys():
try:
with open('Zerodha credentials.json', 'r') as file:
config = json.load(file)
api_key = config['api_key']
api_secret = config['api_secret']
return api_key, api_secret
except FileNotFoundError:
print(
"Config file not found. Please create a 'config.json' file with your API key and API secret."
)
exit(1)
except KeyError as e:
print(f"Config file is missing the key: {e}")
exit(1)
api_key, api_secret = load_api_keys()
kite = KiteConnect(api_key=api_key)
request_token_url = kite.login_url()
print(request_token_url)
try:
data = kite.generate_session(request_token, api_secret)
if 'access_token' in data:
access_token = data['access_token']
kite.set_access_token(access_token)
def on_ticks(ws, ticks):
if not ticks:
print("No response from Kite for data.")
else:
for tick in ticks:
if tick['instrument_type'] == 'NFO':
print("NFO Stock Tick Data:", tick)
with open('tick_data.json', 'a') as file:
json.dump(tick, file)
file.write('\n') # Add a new line after each tick
else:
print("No tick data received from the API or Kite server.")
if not ticks and "Connection closed: 1006" in str(ws):
print("Connection is closed because the market is closed.")
def on_connect(ws, response):
ws = KiteTicker(api_key, access_token)
kws.on_ticks = on_ticks
kws.on_connect = on_connect
while True:
try:
print("Connecting to WebSocket...")
kws.connect()
print("WebSocket connection successful.")
break # Exit the loop if connection is successful
except Exception as e:
print("Error connecting to WebSocket:", e)
print("Retrying in 5 seconds...")
time.sleep(5) # Retry after 5 seconds
while True:
try:
print("Waiting for ticks...")
time.sleep(1)
except KeyboardInterrupt:
# Close the WebSocket connection when interrupted
kws.close()
print("WebSocket connection closed.")
break
Here is my complete syntax. but i am not getting the tick information and it is not getting printed on the terminal. Can you please help. i am thinking the information is not getting from kite.
ws = websocket.WebSocketApp("wss://ws.kite.trade", on_message=on_message)
If no, What changes i need to make.