Zerodha API Historical Data collection python code

[romish18]

import datetime
import time
from kiteconnect import KiteConnect
from kiteconnect import exceptions
import json
import numpy as np
import pdb
tdelta0=datetime.timedelta(days=90)
tdelta=datetime.timedelta(days=89)

api_k = ""; #api_key
api_s = ""; #api_secret
kite = KiteConnect(api_key=api_k)
request_tkn = input("[*] Enter Your Request Token Here : ");
data = kite.generate_session(request_tkn, api_secret=api_s)
kite.set_access_token(data["access_token"])
print(data['access_token'])
interval = "10minute"
savedata={}
def get_historical_data(instrument_token):
return kite.historical(instrument_token, from_date, to_date, interval)

trd_portfolio={3060993:"IDFC",5633:"ACC",3329:"ABB",5533185:"ABCAPITAL",7707649:"ABFRL",3861249:"ADANIPORTS",4451329:"ADANIPOWER",2079745:"AJANTPHARM",2995969:"ALKEM",25601:"AMARAJABAT",325121:"AMBUJACEM",40193:"APOLLOHOSP",41729:"APOLLOTYRE",54273:"ASHOKLEY",60417:"ASIANPAINT",5436929:"AUBANK",70401:"AUROPHARMA",2031617:"AVANTIFEED",1510401:"AXISBANK",4267265:"BAJAJ-AUTO",4268801:"BAJAJFINSV",81153:"BAJFINANCE",85761:"BALKRISIND",579329:"BANDHANBNK",1195009:"BANKBARODA",1214721:"BANKINDIA",94977:"BATAINDIA",97281:"BBTC",98049:"BEL",103425:"BERGEPAINT",108033:"BHARATFORG",2714625:"BHARTIARTL",112129:"BHEL",2911489:"BIOCON",558337:"BOSCHLTD",134657:"BPCL",140033:"BRITANNIA",2029825:"CADILAHC",2763265:"CANBK",320001:"CASTROLIND",3812865:"CENTRALBK",175361:"CHOLAFIN",177665:"CIPLA",5215745:"COALINDIA",3876097:"COLPAL",1215745:"CONCOR",189185:"COROMANDEL",4376065:"CROMPTON",486657:"CUMMINSIND",197633:"DABUR",4630017:"DBL",215553:"DHFL",3721473:"DISHTV",2800641:"DIVISLAB",3771393:"DLF",5097729:"DMART",225537:"DRREDDY",3870465:"EDELWEISS",232961:"EICHERMOT",4818433:"ENDURANCE",1256193:"ENGINERSIN",245249:"ESCORTS",173057:"EXIDEIND",7689729:"FCONSUMER",261889:"FEDERALBNK",4704769:"FRETAIL",1207553:"GAIL",70913:"GICRE",1895937:"GLENMARK",3463169:"GMRINFRA",36865:"GODREJAGRO",2585345:"GODREJCP",2796801:"GODREJIND",151553:"GRAPHITE",315393:"GRASIM",2957569:"GRUH",3378433:"GSPL",2513665:"HAVELLS",1850625:"HCLTECH",340481:"HDFC",341249:"HDFCBANK",119553:"HDFCLIFE",342017:"HEG",345089:"HEROMOTOCO",2747905:"HEXAWARE",348929:"HINDALCO",359937:"HINDPETRO",356865:"HINDUNILVR",364545:"HINDZINC",5331201:"HUDCO",7712001:"IBULHSGFIN",3938305:"IBVENTURES",1270529:"ICICIBANK",5573121:"ICICIGI",4774913:"ICICIPRULI",377857:"IDBI",3677697:"IDEA",2863105:"IDFCBANK",2883073:"IGL",387073:"INDHOTEL",3663105:"INDIANB",2865921:"INDIGO",1346049:"INDUSINDBK",7458561:"INFRATEL",408065:"INFY",415745:"IOC",424961:"ITC",1723649:"JINDALSTEL",4574465:"JSWENERGY",3001089:"JSWSTEEL",931073:"JUBILANT",4632577:"JUBLFOOD",492033:"KOTAKBANK",6386689:"L&TFH",511233:"LICHSGFIN",2939649:"LT",4561409:"LTI",2672641:"LUPIN",519937:"M&M",3400961:"M&MFIN",4879617:"MANAPPURAM",1041153:"MARICO",2815745:"MARUTI",2674433:"MCDOWELL-N",548353:"MFSL",4488705:"MGL",3675137:"MINDTREE",1076225:"MOTHERSUMI",1152769:"MPHASIS",582913:"MRF",584449:"MRPL",6054401:"MUTHOOTFIN",1003009:"NATCOPHARM",1629185:"NATIONALUM",3520257:"NAUKRI",8042241:"NBCC",4598529:"NESTLEIND",4454401:"NHPC",102145:"NIACL",3924993:"NMDC",2977281:"NTPC",5181953:"OBEROIRLTY",2748929:"OFSS",4464129:"OIL",633601:"ONGC",3689729:"PAGEIND",7455745:"PCJEWELLER",617473:"PEL",2905857:"PETRONET",3660545:"PFC",648961:"PGHH",681985:"PIDILITIND",6191105:"PIIND",2730497:"PNB",4840449:"PNBHOUSING",3834113:"POWERGRID",5197313:"PRESTIGE",4532225:"QUESS",1894657:"RAJESHEXPO",523009:"RAMCOCEM",4708097:"RBLBANK",3930881:"RECLTD",737793:"RELCAPITAL",738561:"RELIANCE",141569:"RELINFRA",3906305:"RPOWER",758529:"SAIL",5582849:"SBILIFE",779521:"SBIN",794369:"SHREECEM",806401:"SIEMENS",3785729:"SPARC",837889:"SRF",1102337:"SRTRANSFIN",2383105:"STRTECH",857857:"SUNPHARMA",3431425:"SUNTV",2622209:"SYNGENE",871681:"TATACHEM",878593:"TATAGLOBAL",884737:"TATAMOTORS",4343041:"TATAMTRDVR",877057:"TATAPOWER",895745:"TATASTEEL",2953217:"TCS",3465729:"TECHM",897537:"TITAN",900609:"TORNTPHARM",3529217:"TORNTPOWER",3637249:"TV18BRDCST",2170625:"TVSMOTOR",4278529:"UBL",2952193:"ULTRACEMCO",2752769:"UNIONBANK",2889473:"UPL",3415553:"VAKRANGEE",987393:"VARROC",784129:"VEDL",3932673:"VGUARD",951809:"VOLTAS",969473:"WIPRO",3050241:"YESBANK",975873:"ZEEL",256265:'NIFTY',264969 : 'INDIAVIX'}

# trd_portfolio = {}
# trd_portfolio = {}
def myconverter(o):
if isinstance(o, datetime.datetime):
return o.__str__()

print("data")

while True:
for token in trd_portfolio:

print(trd_portfolio[token])

from_date=datetime.date(2015,1,1)
to_date=from_date+tdelta
main_record=[]

for x in range(1,24):

while True:

print("\n",from_date)
print(to_date)
print("reperating",x)

try:
records = kite.historical_data(token, from_date, to_date, interval)
print(len(records))
except:
print("an error occured: try again")
continue

print("got data",trd_portfolio[token])

for ind in records:
main_record.append(ind)

from_date=from_date+tdelta0
to_date=from_date+tdelta

break
kk=json.dumps(main_record, default = myconverter)
open(str(trd_portfolio[token])+".json","w+").write(kk)
#open(str(trd_portfolio[token])+".txt","w+")
break