a ŠxdEã@srddlZddlZddlmZddlmZddlmZddlmZddlm Z ddl m Z ddl m Z dd lmZdd lmZdd lmZd d lmZd dlmZd dlmZd dlmZddlmZe e¡Z Gdd„deƒZ!Gdd„de!ƒZ"Gdd„de!ƒZ#Gdd„de!ƒZ$Gdd„de!ƒZ%Gdd„de!ƒZ&Gdd„de!ƒZ'Gd d!„d!e!ƒZ(Gd"d#„d#e!ƒZ)Gd$d%„d%e!ƒZ*dS)&éN)Údatetime)Úweb)Úgen)ÚIOLoop)Ú json_decode)Ú HTTPError)Ústates)Ú AsyncResult)ÚAbortableAsyncResult)ÚDisabledBackendé)Útasks)Ú BaseHandler)ÚBroker)ÚControlHandler)Ú OrderedDictc@sDeZdZdZdd„Zedd„ƒZdd„Zdd „Zd d „Z d d „Z dS)ÚBaseTaskHandlerz%Y-%m-%d %H:%M:%S.%fc Csžz|jj}|rt|ƒni}Wn2tyN}ztdt|ƒƒ‚WYd}~n d}~00t|tƒsdtddƒ‚| dg¡}| di¡}t|t t fƒs”tddƒ‚|||fS)Nézinvalid optionsÚargsÚkwargszargs must be an array) ÚrequestÚbodyrÚ ValueErrorrÚstrÚ isinstanceÚdictÚpopÚlistÚtuple)ÚselfrÚoptionsÚerr©r"úH/var/www/html/Ranjet/env/lib/python3.9/site-packages/flower/api/tasks.pyÚ get_task_argss$     zBaseTaskHandler.get_task_argscCst|jtƒ S©N)rÚbackendr )Úresultr"r"r#Úbackend_configured0sz"BaseTaskHandler.backend_configuredcKs| |¡dSr%)Z set_status)rÚ status_coderr"r"r#Ú write_error4szBaseTaskHandler.write_errorcCsB|jtjkr(| | |j¡|jdœ¡n| d| |j¡i¡dS)N)r'Ú tracebackr')ÚstaterÚFAILUREÚupdateÚ safe_resultr'r+)rÚresponser'r"r"r#Úupdate_response_result7s  ÿ z&BaseTaskHandler.update_response_resultcCs€d|vrt |d|j¡|d<d|vr6t|dƒ|d<d|vr||d}z t|ƒ}Wn tyrt ||j¡}Yn0||d<dS)NÚetaZ countdownÚexpires)rÚstrptimeÚ DATE_FORMATÚfloatr)rr r3r"r"r#Únormalize_options>s ÿ  z!BaseTaskHandler.normalize_optionscCs2zt |¡Wnty(t|ƒYS0|SdS)zreturns json encodable resultN)ÚjsonÚdumpsÚ TypeErrorÚrepr)rr'r"r"r#r/Ls  zBaseTaskHandler.safe_resultN) Ú__name__Ú __module__Ú __qualname__r5r$Ú staticmethodr(r*r1r7r/r"r"r"r#rs rc@s(eZdZejejdd„ƒƒZdd„ZdS)Ú TaskApplyccsÂ| ¡\}}}t d|||¡z|jj|}Wn tyNtdd|ƒ‚Yn0z| |¡Wntyztddƒ‚Yn0|j f||dœ|¤Ž}d|j i}t   ¡  d|j||¡V}| |¡dS) a# Execute a task by name and wait results **Example request**: .. sourcecode:: http POST /api/task/apply/tasks.add HTTP/1.1 Accept: application/json Accept-Encoding: gzip, deflate, compress Content-Length: 16 Content-Type: application/json; charset=utf-8 Host: localhost:5555 { "args": [1, 2] } **Example response**: .. sourcecode:: http HTTP/1.1 200 OK Content-Length: 71 Content-Type: application/json; charset=UTF-8 { "state": "SUCCESS", "task-id": "c60be250-fe52-48df-befb-ac66174076e6", "result": 3 } :query args: a list of arguments :query kwargs: a dictionary of arguments :reqheader Authorization: optional OAuth token to authenticate :statuscode 200: no error :statuscode 401: unauthorized request :statuscode 404: unknown task ú'Invoking a task '%s' with '%s' and '%s'é”úUnknown task '%s'rúInvalid option©rrútask-idN)r$ÚloggerÚdebugÚcappr ÚKeyErrorrr7rÚ apply_asyncÚtask_idrÚcurrentZrun_in_executorÚ wait_resultsÚwrite©rÚtasknamerrr Útaskr'r0r"r"r#ÚpostWs$*ÿ    ÿzTaskApply.postcCs4|jdd| ||¡| |¡r0|j|jd|S)NF)Ú propagate©r,)Úgetr1r(r.r,)rr'r0r"r"r#rN–s    zTaskApply.wait_resultsN) r<r=r>rÚ authenticatedrÚ coroutinerSrNr"r"r"r#r@Vs =r@c@seZdZejdd„ƒZdS)ÚTaskAsyncApplycCsÂ| ¡\}}}t d|||¡z|jj|}Wn tyNtdd|ƒ‚Yn0z| |¡Wntyztddƒ‚Yn0|j f||dœ|¤Ž}d|j i}|  |¡r´|j |j d| |¡d S) ac Execute a task **Example request**: .. sourcecode:: http POST /api/task/async-apply/tasks.add HTTP/1.1 Accept: application/json Accept-Encoding: gzip, deflate, compress Content-Length: 16 Content-Type: application/json; charset=utf-8 Host: localhost:5555 { "args": [1, 2] } **Example response**: .. sourcecode:: http HTTP/1.1 200 OK Content-Length: 71 Content-Type: application/json; charset=UTF-8 Date: Sun, 13 Apr 2014 15:55:00 GMT { "state": "PENDING", "task-id": "abc300c7-2922-4069-97b6-a635cc2ac47c" } :query args: a list of arguments :query kwargs: a dictionary of arguments :query options: a dictionary of `apply_async` keyword arguments :reqheader Authorization: optional OAuth token to authenticate :statuscode 200: no error :statuscode 401: unauthorized request :statuscode 404: unknown task rArBrCrrDrErFrUN)r$rGrHrIr rJrr7rrKrLr(r.r,rOrPr"r"r#rS¢s"*ÿ    zTaskAsyncApply.postN©r<r=r>rrWrSr"r"r"r#rY srYc@seZdZejdd„ƒZdS)ÚTaskSendcCsh| ¡\}}}t d|||¡|jj|f||dœ|¤Ž}d|ji}| |¡rZ|j|jd|  |¡dS)a" Execute a task by name (doesn't require task sources) **Example request**: .. sourcecode:: http POST /api/task/send-task/tasks.add HTTP/1.1 Accept: application/json Accept-Encoding: gzip, deflate, compress Content-Length: 16 Content-Type: application/json; charset=utf-8 Host: localhost:5555 { "args": [1, 2] } **Example response**: .. sourcecode:: http HTTP/1.1 200 OK Content-Length: 71 Content-Type: application/json; charset=UTF-8 { "state": "SUCCESS", "task-id": "c60be250-fe52-48df-befb-ac66174076e6" } :query args: a list of arguments :query kwargs: a dictionary of arguments :reqheader Authorization: optional OAuth token to authenticate :statuscode 200: no error :statuscode 401: unauthorized request :statuscode 404: unknown task z%Invoking task '%s' with '%s' and '%s'rErFrUN) r$rGrHrIZ send_taskrLr(r.r,rO)rrQrrr r'r0r"r"r#rSâs(ÿÿÿÿ  z TaskSend.postNrZr"r"r"r#r[ásr[c@seZdZejdd„ƒZdS)Ú TaskResultcCsˆ| dd¡}|durt|ƒnd}t|ƒ}| |¡s:tdƒ‚||jdœ}|rf|j|dd| ||¡n| ¡rz| ||¡|  |¡dS)a– Get a task result **Example request**: .. sourcecode:: http GET /api/task/result/c60be250-fe52-48df-befb-ac66174076e6 HTTP/1.1 Host: localhost:5555 **Example response**: .. sourcecode:: http HTTP/1.1 200 OK Content-Length: 84 Content-Type: application/json; charset=UTF-8 { "result": 3, "state": "SUCCESS", "task-id": "c60be250-fe52-48df-befb-ac66174076e6" } :query timeout: how long to wait, in seconds, before the operation times out :reqheader Authorization: optional OAuth token to authenticate :statuscode 200: no error :statuscode 401: unauthorized request :statuscode 503: result backend is not configured ÚtimeoutNé÷)rFr,F)r]rT) Ú get_argumentr6r r(rr,rVr1ÚreadyrO)rÚtaskidr]r'r0r"r"r#rVs    zTaskResult.getN©r<r=r>rrWrVr"r"r"r#r\sr\c@seZdZejdd„ƒZdS)Ú TaskAbortcCsFt d|¡t|ƒ}| |¡s&tdƒ‚| ¡| td|d¡dS)a) Abort a running task **Example request**: .. sourcecode:: http POST /api/task/abort/c60be250-fe52-48df-befb-ac66174076e6 HTTP/1.1 Host: localhost:5555 **Example response**: .. sourcecode:: http HTTP/1.1 200 OK Content-Length: 61 Content-Type: application/json; charset=UTF-8 { "message": "Aborted '1480b55c-b8b2-462c-985e-24af3e9158f9'" } :reqheader Authorization: optional OAuth token to authenticate :statuscode 200: no error :statuscode 401: unauthorized request :statuscode 503: result backend is not configured zAborting task '%s'r^z Aborted '%s')ÚmessageN)rGÚinfor r(rÚabortrOr)rrar'r"r"r#rSGs   zTaskAbort.postNrZr"r"r"r#rcFsrcc@s eZdZejejdd„ƒƒZdS)ÚGetQueueLengthsccs¾|j}|jjj}d}|jdkr.|jjr.|jj}d}|jjjrF|jjj}t|j  ¡j dd|||d}|  ¡}|sœt |jjj gƒt dd„|jjjp’gDƒƒB}| t|ƒ¡V}| d|i¡dS) aH Return length of all active queues **Example request**: .. sourcecode:: http GET /api/queues/length Host: localhost:5555 **Example response**: .. sourcecode:: http HTTP/1.1 200 OK Content-Length: 94 Content-Type: application/json; charset=UTF-8 { "active_queues": [ {"name": "celery", "messages": 0}, {"name": "video-queue", "messages": 5} ] } :reqheader Authorization: optional OAuth token to authenticate :statuscode 200: no error :statuscode 401: unauthorized request :statuscode 503: result backend is not configured NZamqpT)Zinclude_password)Úhttp_apiÚbroker_optionsÚbroker_use_sslcSsg|]}|jr|j‘qSr")Úname)Ú.0Úqr"r"r#Ú £óz'GetQueueLengths.get..Z active_queues)Ú applicationrIÚconfZBROKER_TRANSPORT_OPTIONSÚ transportr Z broker_apiZBROKER_USE_SSLrÚ connectionÚas_uriZget_active_queue_namesÚsetZCELERY_DEFAULT_QUEUEZ CELERY_QUEUESÚqueuesÚsortedrO)rÚapprirhrjZbrokerZ queue_namesrvr"r"r#rVps$!   ÿÿzGetQueueLengths.getN)r<r=r>rrWrrXrVr"r"r"r#rgosrgc@seZdZejdd„ƒZdS)Ú ListTasksc Cs&|j}| dd¡}|jddtd}| dd¡}| dd¡}| dd¡}| d d¡}| d d¡}| d d¡} |ott|ƒ}t|dƒ}|d krŒ|nd}|d krœ|nd}|d kr¬|nd}g} tj|j||| |||||d D]@\} } t | ¡} |  dd¡}|dur|j | d<|   | | f¡qÒ|  t | ƒ¡dS)aU List tasks **Example request**: .. sourcecode:: http GET /api/tasks HTTP/1.1 Host: localhost:5555 User-Agent: HTTPie/0.8.0 **Example response**: .. sourcecode:: http HTTP/1.1 200 OK Content-Length: 1109 Content-Type: application/json; charset=UTF-8 Etag: "b2478118015c8b825f7b88ce6b660e5449746c37" Server: TornadoServer/3.1.1 { "e42ceb2d-8730-47b5-8b4d-8e0d2a1ef7c9": { "args": "[3, 4]", "client": null, "clock": 1079, "eta": null, "exception": null, "exchange": null, "expires": null, "failed": null, "kwargs": "{}", "name": "tasks.add", "received": 1398505411.107885, "result": "'7'", "retried": null, "retries": 0, "revoked": null, "routing_key": null, "runtime": 0.01610181899741292, "sent": null, "started": 1398505411.108985, "state": "SUCCESS", "succeeded": 1398505411.124802, "timestamp": 1398505411.124802, "traceback": null, "uuid": "e42ceb2d-8730-47b5-8b4d-8e0d2a1ef7c9", "worker": "celery@worker1" }, "f67ea225-ae9e-42a8-90b0-5de0b24507e0": { "args": "[1, 2]", "client": null, "clock": 1042, "eta": null, "exception": null, "exchange": null, "expires": null, "failed": null, "kwargs": "{}", "name": "tasks.add", "received": 1398505395.327208, "result": "'3'", "retried": null, "retries": 0, "revoked": null, "routing_key": null, "runtime": 0.012884548006695695, "sent": null, "started": 1398505395.3289, "state": "SUCCESS", "succeeded": 1398505395.341089, "timestamp": 1398505395.341089, "traceback": null, "uuid": "f67ea225-ae9e-42a8-90b0-5de0b24507e0", "worker": "celery@worker1" } } :query limit: maximum number of tasks :query offset: skip first n tasks :query sort_by: sort tasks by attribute (name, state, received, started) :query workername: filter task by workername :query taskname: filter tasks by taskname :query state: filter tasks by state :query received_start: filter tasks by received date (must be greater than) format %Y-%m-%d %H:%M :query received_end: filter tasks by received date (must be less than) format %Y-%m-%d %H:%M :reqheader Authorization: optional OAuth token to authenticate :statuscode 200: no error :statuscode 401: unauthorized request ÚlimitNÚoffsetr)ÚdefaultÚtypeZ workernamerQr,Úreceived_startÚ received_endÚsort_byZAll)rzr{r€r}Úworkerr,r~rr) rpr_ÚintÚmaxr Z iter_tasksÚeventsÚas_dictrÚhostnameÚappendrOr) rrxrzr{rr}r,r~rr€r'rLrRr"r"r#rVªs6\          ü    z ListTasks.getNrbr"r"r"r#ry©sryc@seZdZejdd„ƒZdS)Ú ListTaskTypescCs(|jjj ¡}i}||d<| |¡dS)aÞ List (seen) task types **Example request**: .. sourcecode:: http GET /api/task/types HTTP/1.1 Host: localhost:5555 **Example response**: .. sourcecode:: http HTTP/1.1 200 OK Content-Length: 44 Content-Type: application/json; charset=UTF-8 { "task-types": [ "tasks.add", "tasks.sleep" ] } :reqheader Authorization: optional OAuth token to authenticate :statuscode 200: no error :statuscode 401: unauthorized request z task-typesN)rpr„r,Z task_typesrO)rZseen_task_typesr0r"r"r#rV%szListTaskTypes.getNrbr"r"r"r#rˆ$srˆc@seZdZejdd„ƒZdS)ÚTaskInfocCsNt |jj|¡}|s"tdd|ƒ‚| ¡}|jdur@|jj|d<| |¡dS)a¼ Get a task info **Example request**: .. sourcecode:: http GET /api/task/info/91396550-c228-4111-9da4-9d88cfd5ddc6 HTTP/1.1 Accept: */* Accept-Encoding: gzip, deflate, compress Host: localhost:5555 **Example response**: .. sourcecode:: http HTTP/1.1 200 OK Content-Length: 575 Content-Type: application/json; charset=UTF-8 { "args": "[2, 2]", "client": null, "clock": 25, "eta": null, "exception": null, "exchange": null, "expires": null, "failed": null, "kwargs": "{}", "name": "tasks.add", "received": 1400806241.970742, "result": "'4'", "retried": null, "retries": null, "revoked": null, "routing_key": null, "runtime": 2.0037889280356467, "sent": null, "started": 1400806241.972624, "state": "SUCCESS", "succeeded": 1400806243.975336, "task-id": "91396550-c228-4111-9da4-9d88cfd5ddc6", "timestamp": 1400806243.975336, "traceback": null, "worker": "celery@worker1" } :reqheader Authorization: optional OAuth token to authenticate :statuscode 200: no error :statuscode 401: unauthorized request :statuscode 404: unknown task rBrCNr) r Zget_task_by_idrpr„rr…rr†rO)rrarRr0r"r"r#rVLs9  z TaskInfo.getNrbr"r"r"r#r‰Ksr‰)+r8ÚloggingrZtornadorrZtornado.iolooprZtornado.escaperZ tornado.webrZceleryrZ celery.resultr Zcelery.contrib.abortabler Zcelery.backends.baser Úutilsr ZviewsrZ utils.brokerrZ api.controlrÚ collectionsrÚ getLoggerr<rGrr@rYr[r\rcrgryrˆr‰r"r"r"r#Ús6                ;JA41):{'