Ag&dZddlmZddlZddlZddlmZddlmZ ddl m Z ddl Z ddlZd dZd Zd Zed kr,ee d ee d dSdS)zv This script gets daily as well as new data for the stocks in the database "nse_data1" -> OHCL from Zerodha Demat API ) getNSEdataN) MongoClient)sleeplivezerodha\credentials.jsonc t|d5}tj|}dddn #1swxYwY||}|r|St d|#t $rt d|YdStj$rt d|YdSt$r}t d|Yd}~dSd}~wwxYw)a? Access credentials from a JSON file. Args: - env (str): Environment to fetch the credentials from ('local' or 'live'). Default is 'local'. - filepath (str): Path to the JSON file containing credentials. Default is 'creds.json'. Returns: - dict: Credentials for the specified environment. rNz&No credentials found for environment: zFile not found: zError decoding JSON in file: zAn error occurred: ) openjsonloadget ValueErrorFileNotFoundErrorprintJSONDecodeError Exception)envfilepathfdata credentialses 0e:\HARSH\Automation\J_Work\zerodha\zNSE_fetch.pyget_credentialsrs\) (C  A9Q<z'prev_close_updaterNSE..HsXEVE_E_`dfpEqEq)key prev_closezUpdated prev_close for date : closezWarning: Data for z is not a dictionary: _idz$setz5prev_close fields updated successfully where missing!) rr rfindsortedkeys isinstancedictr update_one)credsrconnection_urlmongo_databaserclientdb collection documentsdocprevious_closeupdated sorted_datesr%rs rprev_close_updaterNSEr>1s   EIIo..M"&&'788N"&&z22N"&&'788N ( (F  BN#JIt+< =>>I\\c(m00228q8qrrr ! O ODx=&D$%% Ot++%1-;\*"&UTUU^UUVVV"&'!2!2M4MMtMMNNNN  \  ! !5#e*"53x=@Y7Z [ [ [ ABBBBBr'c 8 t}|d}|d}|d}|d}|d}|d}|d}|d}|d} |d } t|} | |} | |} tj|||| | }|}|d |}| d }| d g d}dddd}tj d}tj |d}|tjdz }tjddd}|D]/}| d|di}|r~ t%d|dD}|tjdz}n#t($r|}YnwxYw||krt+d|ddn|}t+d|dd|d||d|dd |}|!|\}}}}d!|d"|d#|} t/jt3jd$| |i%j}!t+|! |!rd&|!vrzd'|!d&vroi}"|!d&d'D]}#tj |#d(d)d(d}$|#d|#d|#d*|#d+d,}%|%|"|$ d<|rs|d|"tj |d-<| d|di|t+d.|dnF|d||tA|tA|tj |"d/}&t+d0|dnt+d1|dd2#tB$r&}'t+d3|dd4|'Yd}'~'d}'~'wwxYwt+d5|d1t+d6| "|"dS)7Nrrrr sqlDB_credsuserhostpasswordport)rArBrCrrDaASELECT * FROM mytable WHERE tradingsymbol IN ('5PAISA', 'AAVAS', 'ADANIGREEN', 'AETHER', 'ALIVUS', 'AMBER', 'APOLLO', 'ASTERDM', 'ATGL', 'AVAX', 'BANDHANBNK', 'BDL', 'BRGIL', 'CAPACITE', 'CREDITACC', 'DALBHARAT', 'DAVIN', 'DELHIVERY', 'DIAMONDYD', 'DOLLAR', 'DYCL', 'EMUDHRA', 'ETHOSLTD', 'FABCLEAN', 'FINEORG', 'GALAXYSURF', 'GICRE', 'GODREJAGRO', 'GRSE', 'HAL', 'HARDWYN', 'HDFCAMC', 'HDFCLIFE', 'HGINFRA', 'ICICIGI', 'IEX', 'IFGLEXPOR', 'INDOBELL', 'INDOSTAR', 'IRCON', 'ISEC', 'LEMONTREE', 'LICI', 'MAHLOG', 'MANORAMA', 'MASFIN', 'MIDHANI', 'MVGJL', 'NAM-INDIA', 'NEWGEN', 'NIACL', 'ORIENTELEC', 'PARADEEP', 'PARMESHWAR', 'PRUDENT', 'QUADFUTURE', 'RAINBOW', 'RITES', 'RPSGVENT', 'SANDHAR', 'SBILIFE', 'SGLTL', 'SHALBY', 'SHAREINDIA', 'SOLARA', 'TECHNOE', 'TIINDIA', 'VANDU', 'VARROC', 'VENUSPIPES', 'YASHO') AND exchange = 'NSE';zerodha_credentials)r,z*/*zen-US,en;q=0.9zenctoken N7gCpFQYDbNMxGHTmhfsfvtUXbW+DQGX+L7LmbLFrkScL/u3pFiddt2+r99MqXdx1QvFPH7h2IDwZ9j/7mVlvX/stVTc8zcH+hVUfwh40vvHWFLbjU+jGA==)acceptzaccept-language authorizationr")daysisymbolc3zK|]6}tj|dV7dS)r"N)r#r$r%).0r%s r znse_fetcher..sZ D DX\ 1 : :4 L L Q Q S S D D D D D Dr'r z Data for z is up to date.z Processing z from z to zbSELECT instrument_token, segment, exchange_token, name FROM `mytable` WHERE `tradingsymbol` LIKE 'z' AND `exchange` LIKE 'NSE';z4https://kite.zerodha.com/oms/instruments/historical/z/day?user_id=GMG829&oi=0&from=z&to=GET)headersrrcandlesrT)r highlowr+ timestampzUpdated )rK company_name Instrumentexchange_tokeninstrument_tokenrXr zCompleted processing zNo new data available for .zError processing r*zNo instrument token found for z.Processing completed. Results saved to MongoDB)#rr rmcconnectcursorexecutefetchallr-sortlimitr#todaystrftimer$ timedeltar%find_onemaxr/rrfetchoner loadsrequestsrequesttextsplitupdatenow replace_oneintrr+)(r3rr4r5rr@rArBrC sql_databaserD mongo_clientr7r8connr` checkSymbolscreds_collection get_credsrQre yesterdaydefault_start_daterKexisting_document last_date from_datetoken instTokensegmentr[nameurlresponse new_pricescandle candle_dateohlc new_documentrs( r nse_fetcherrcsy   EIIo..M"&&'788N"&&z22N"&&'788N))M**K ??6 " "D ??6 " "Dz**H??:..L ??6 " "D~..L n %BN#J :4dX [_ ` ` `D [[]]F NNW X X X ??$$L/0 %%'',,k];;AA!DDI +^ G   # # % % . .z : :E   & &uj 9 9E+333399;;I!tQ22G@G@&//6!90EFF  + / D D`qrz`{aAaAaCaC D D DDD %(:(B(B(BB  / / /.  /9$$<&)<<<===% +I GF1IGGYGGIGGHHH d}CDE}Fddd e e e!!  7< 4IwMMMr{MMBKMMCz("25#wUW"X"X"X"]^^H (OOO$ <!E( 2 2yHVDT7T7T!#J"*6"29"=LL&.&7&@&@QTAUAUVWAXZd&e&e&j&j&l&l $*1I$*1I#)!9%+AY    HL ;#7#7 #C#CDD()(3:::FFF9A9J9N9N9P9P)+6"..&)/DFWXXX4445555'-Qi,0*1.1..A.A03I)1):)>)>)@)@&0(( =&)==>>>>CvayCCCDDD < < <:&)::q::;;;;;;;; < >6!9>> ? ? ? ? :;;;JJLLLLLs,A J J.-J.9FT U UU__main__rT)rr)__doc__ z_getNSEdatarr#r pymongormysql.connector connectorr^timerpandaspdrlrr>r__name__r'rrs $#####  ))))>0C0C0Cd{{{| zKMMM E!HHH E!HHHHH r'