import requests
import pandas as pd 
from datetime import datetime
from kiteconnect import KiteConnect
import time
from kiteconnect import KiteTicker


ticks_ = []
# Initialise
kws = KiteTicker("2*********", access_token)
tokens = [260105]
subscription_list = [12017410, 12019970]


def on_ticks(ws, ticks):
        print(ticks)


def on_connect(ws, response):  # noqa
    # Callback on successful connect.
    # Subscribe to a list of instrument_tokens (RELIANCE and ACC here).
    ws.subscribe(tokens)
    # Set RELIANCE to tick in `full` mode.
    ws.set_mode(ws.MODE_FULL, tokens)


# Callback when current connection is closed.
def on_close(ws, code, reason):
    logging.info("Connection closed: {code} - {reason}".format(code=code, reason=reason))


# Callback when connection closed with error.
def on_error(ws, code, reason):
    logging.info("Connection error: {code} - {reason}".format(code=code, reason=reason))


# Callback when reconnect is on progress
def on_reconnect(ws, attempts_count):
    logging.info("Reconnecting: {}".format(attempts_count))


# Callback when all reconnect failed (exhausted max retries)
def on_noreconnect(ws):
    logging.info("Reconnect failed.")

# Assign the callbacks.
kws.on_ticks = on_ticks
kws.on_connect = on_connect
kws.connect(threaded=True)

count = 0
while True:
  if kws.is_connected():
          kws.subscribe(subscription_list)
          kws.set_mode(kws.MODE_FULL,subscription_list)
  time.sleep(0.350)
  count = count + 1
  print(count)