'iddlmZmZmZmZddlZddlmZmZddlZddl Z ddl m Z m Z m Z mZmZddlmZddlmZdd gZGd dej*ZGd d eZy) )absolute_importdivisionprint_functionunicode_literalsN)datedatetime)urlopenurlquote ProxyHandler build_openerinstall_opener)feed)date2num QuandlCSVQuandlc0eZdZdZdZdZfdZdZxZS)ra Parses pre-downloaded Quandl CSV Data Feeds (or locally generated if they comply to the Quandl format) Specific parameters: - ``dataname``: The filename to parse or a file-like object - ``reverse`` (default: ``False``) It is assumed that locally stored files have already been reversed during the download process - ``adjclose`` (default: ``True``) Whether to use the dividend/split adjusted close and adjust all values according to it. - ``round`` (default: ``False``) Whether to round the values to a specific number of decimals after having adjusted the close - ``decimals`` (default: ``2``) Number of decimals to round to F))reverseF)adjcloseT)roundF)decimalsr ctt| |jjsy|j ryt j}|jD]}|j|tjd}|j||jd|jj||_y)Nnewliner)superrstartparamsr_online collectionsdequef appendleftioStringIO writelinesseekclose)selfdqliner! __class__s U/var/www/app/trading-bot/venv/lib/python3.12/site-packages/backtrader/feeds/quandl.pyrzQuandlCSV.startLs i$&{{""  \\    FF D MM$   KK % R q   c tjd}|t|}tt |ddt |ddt |dd}t t j||jj}||jj d<|jjrtdD] }t|t|t|}t|t|}t|t|} t|t|} t|t|} d|jjd<|jjrR|jj } t|| }t|| }t| | } t| | } t| | } ||jj"d<||jj$d<| |jj&d<| |jj(d<| |jj*d<y) Nr gT) itertoolscountnextrintrrcombinep sessionendlinesrrangefloat openinterestrropenhighlowr'volume) r( linetokensidttxtdtdtnum_ohlcvrs r, _loadlinezQuandlCSV._loadline_s OOA 47# #eAaj/3uQqz?Ca 4D E))"dff.?.?@A!& A 66??1X Q  *T!W% & *T!W% & *T!W% & *T!W% & *T!W% &%( " 66<<vvHa"Aa"Aa"Aa"Aa"A   q   !r-) __name__ __module__ __qualname____doc__rrrrN __classcell__r+s@r,rr's 6GF&!r-c:eZdZdZdZddifddddfZfd ZxZS) ra Executes a direct download of data from Quandl servers for the given time range. Specific parameters (or specific meaning): - ``dataname`` The ticker to download ('YHOO' for example) - ``baseurl`` The server url. Someone might decide to open a Quandl compatible service in the future. - ``proxies`` A dict indicating which proxy to go through for the download as in {'http': 'http://myproxy.com'} or {'http': 'http://127.0.0.1:8080'} - ``buffered`` If True the entire socket connection wil be buffered locally before parsing starts. - ``reverse`` Quandl returns the value in descending order (newest first). If this is ``True`` (the default), the request will tell Quandl to return in ascending (oldest to newest) format - ``adjclose`` Whether to use the dividend/split adjusted close and adjust all values according to it. - ``apikey`` apikey identification in case it may be needed - ``dataset`` string identifying the dataset to query. Defaults to ``WIKI`` T)baseurlz&https://www.quandl.com/api/v3/datasetsproxies)bufferedT)rT)apikeyN)datasetWIKIc|d|_dj|jj|jjt |jj }g}|jjr|jd|jj4|jdj|jj|jjrE|jjjd}|jdj||jjrE|jjjd}|jdj||r|ddj|zz }|jjr5t|jj}t!|}t#| t%|}|j*d d k7rd |j*z|_y|j,j.rEt1j2|j5j7d d }|j9n|}||_t<t>|y#t&$r}t)||_Yd}~yd}~wwxYw)Nz {}/{}/{}.csvz order=ascz api_key={}z%Y-%m-%dz start_date={}z end_date={}?&z Content-Typeztext/csvzWrong content type: %szutf-8r)!errorformatr9rVrZr datanamerappendrYfromdatestrftimetodatejoinrWr r rr IOErrorstrheadersrrXr#r$readdecoder'r!rrr) r(urlurlargsdtxtproxyopenerdatafileer!r+s r,rz Quandl.starts ## FFNNDFFNNHTVV__,EG 66>> NN; ' 66== $ NN<..tvv}}= > 66??66??++J7D NN?11$7 8 66==66==))*5D NN=//5 6  3'** *C 66>> 0E!%(F 6 " s|H   N +z 91H4D4DDDJ  ;;   HMMO227;TJA NN A fd!#' QDJ  s/ J J;!J66J;)rOrPrQrRrrrrSrTs@r,rrs9, \G > B F2$2$r-) __future__rrrrrrrr#r4 utils.py3r r r r rrutilsr__all__ CSVDataBaserrr-r,rzs^***# ))  !Y  Yxl$Yl$r-