FZj!ZddlZddlZddlZddlmZmZmZmZddlm Z m Z Gdde Z y)N)DaasGetQueryResultDaasGetJobStatusResult DaasResultNOT_FULL_API_CALL_EXCEPTION)APIDEFAULT_TIMEOUTceZdZddddeddffd ZdedededefdZd edefd Z ded edefd Z d edefd Z d ede fdZ d edefdZd edefdZd edefdZd edefdZxZS) AltitudeAPINz my.geotab.comc t |||||||||tjtj tj dd} y)a A wrapper around mygeotab API for altitude users. :param username: The username used for MyGeotab servers. Usually an email address. :type username: str :param password: The password associated with the username. Optional if `session_id` is provided. :type password: str :param database: The database or company name. Optional as this usually gets resolved upon authentication. :type database: str :param session_id: A session ID, assigned by the server. :type session_id: str :param server: The server ie. my23.geotab.com. Optional as this usually gets resolved upon authentication. :type server: str or None :param timeout: The timeout to make the call, in seconds. By default, this is 300 seconds (or 5 minutes). :type timeout: float or None :param proxies: The proxies dictionary to apply to the request. :type proxies: dict or None :param cert: The path to client certificate. A single path to .pem file or a Tuple (.cer file, .key file). :type cert: str or Tuple or None :raise Exception: Raises an Exception if a username, or one of the session_id or password is not provided. )usernamepassworddatabase session_idservertimeoutproxiescertz3%(asctime)s.%(msecs)03d %(levelname)-8s %(message)sz%Y-%m-%d %H:%M:%S)streamlevelformatdatefmtN)super__init__logging basicConfigsysstdoutINFO) selfrrrrrrrr_ __class__s [C:\Users\Rodrigo\frota-trucks-cliente\python\Lib\site-packages\mygeotab/altitude/wrapper.pyrzAltitudeAPI.__init__ sVB !     ::,,H'   service_name function_namefunction_parametersreturnc0|jd|||}|S)NGetAltitudeData)method serviceName functionNamefunctionParameters)call)r!r&r'r(resultss r$ _call_apizAltitudeAPI._call_api;s())$$&2   r%respcn|jdgxs"|jdijdgS)z+Extracts errors from myG and daas wrappers.errors apiResult)get)r!r3s r$_extract_errorszAltitudeAPI._extract_errorsDs1xx"%T+r)B)F)FxQS)TTr%paramscD|dvsJd}t|D]+} |j|d||d}t||cSy #t$rS}|tk(r>||dz k(r|t dt dtj|dzd zn|Yd }~d }~wwxYw) zy Supports getJobStatus calls, and getQueryResults calls. Retries in case of errors like connection rest. ) getJobStatusgetQueryResultscreateQueryJobr-r/)r&r'r(rz2encountered error trying to parse to api response z, retrying.... N) ranger2r Exceptionrprintstrtimesleep)r!r'r9 max_tries try_index call_resultes r$call_apizAltitudeAPI.call_apiIs UUUU y)I "nn!' !6"/(./C(D- ;'""* 33 IM1 RSVWbScRddrst IMR#78G9  s&A B A BBc |jd|}|j|}|rt|djdd|dddS#t$r}t j d ||d }~wwxYw) z8 creates the job with the given params. r=)r'r9)r3rmessagezFailed to create the jobr6r1 Exception: N)rJr8rAr7rerror)r!r9r1r5rIs r$ create_jobzAltitudeAPI.create_jobbs mm.$G ))w)7Fq i9S TUU;' 215 5  MMKs+ ,G sAA A:A55A:c@|jd|}t|}|S)zY checks the status of a given job. jobId needs to be included in params. r;)rJr)r!r9rH daas_statuss r$check_job_statuszAltitudeAPI.check_job_statusus$mmNF; ,[9 r%c |j|}|jr't|jdkDr|jd|jr |jSt j dt jd|j#t$rA}t jd|t jdj|d}~wwxYw)zn waits for a job to finish running and returns the job. jobId needs to be included in params. rr>zwaiting for results: rMz8error: error while waiting for job to complete, result: N) rRr5len has_finishedrDrErinfojobrArN)r!r9rQrIs r$wait_for_job_to_completez$AltitudeAPI.wait_for_job_to_complete}s "33F; %%#k.@.@*AA*E%,,Q//"//1 1  4[__4EFG  A3/0 XYdYhYhXijk sAB$7B C&%[c&kAoMM$A&)"MN )O D!*   DQCHI sBB"" C +CC ctjd|j|}tjd||d|dd<tjd|j|}tjd|tjd|j |}tjd |S) zq given the parameters, will call the request, wait on it to finish and return the combined data. z creating jobz job created: idr/jobIdzchecking the job statuszjob finished: zgathering resultz data gathered)rrVrOrXrh)r!r9rWr1r[s r$dozAltitudeAPI.dos  |%oof% }SE*+03D #$W- .0//7 ~gY/0 ')}}V$ }& r%)__name__ __module__ __qualname__r rrCdictr2listr8rJrOrrRrXrarhrl __classcell__)r#s@r$r r s 0 dc#TX]aUDUTU c4D2$&t0Ft,$Bt*$r%r ) rrDrdaas_definitionrrrrapir r r r%r$rvs% pp&O#Or%