o gZhSW@sHddlZddlmZddlmZddlmZmZm Z GdddeZ dS)N)ObjectApiResponse)NamespacedClient) SKIP_IN_PATH_quote_rewrite_parametersc%@seZdZedddddddedejejeejefdeje dejejeejefdeje deje d e ej fd d Z eddddd dedeje dejejeejefdeje deje d e ej f d dZ eddddd dedeje dejejeejefdeje deje d e ej f ddZeddddd dedeje dejejeejefdeje deje d e ej f ddZedddddddddddddddd dejedejejeejdeffdejejeej fdeje deje dejejeejefdeje deje deje deje dejejeej fdejejeej fdejejeej fd e ej fd d!Zeddddd dedeje dejejeejefdeje deje d e ej f d"d#Zedddddddddddddddddd$ded%ejejeejeej ffd&eje d'ejejeej fdeje dejejeejefdeje d(ejed)ejed*ejejeej fd+ejejeej fdeje d,ejed-ejejeej fd.ejejeej fd/ejed e ej f"d0d1Zedd2d3id4dddddddddd5 deje dejejeejefd3ejedeje deje d6ejejeej fd7ejejejde eeeej fd8ejed9ejejejejeejeej ffejeejeej fffd e ej fd:d;Zeddddd deje dejejeejefdeje deje d e ej f dd?ejejejejd@efejd@effdAeje deje dejejeejefdeje deje d e ej fdBdCZeddddd deje dejejeejefdeje deje d e ej f dDdEZdS)F WatcherClientN) action_id error_trace filter_pathhumanprettywatch_idr r r r r returnc Cs|tvrtd|tvr|tvrdt|dt|}n|tvr*dt|d}ntdi}|dur8||d<|dur@||d<|durH||d <|durP||d <d d i} |jd ||| dS)a9 Acknowledges a watch, manually throttling the execution of the watch's actions. ``_ :param watch_id: Watch ID :param action_id: A comma-separated list of the action ids to be acked +Empty value passed for parameter 'watch_id'/_watcher/watch/z/_ack/z/_ackz-Couldn't find a path for the given parametersNr r r r acceptapplication/jsonPUTparamsheadersr ValueErrorrperform_request) selfrr r r r r _WatcherClient__path_WatcherClient__query_WatcherClient__headersrY/var/www/html/lang_env/lib/python3.10/site-packages/elasticsearch/_sync/client/watcher.py ack_watchs(zWatcherClient.ack_watch)r r r r c C~|tvrtddt|d}i}|dur||d<|dur"||d<|dur*||d<|dur2||d<d d i}|jd |||d S) z Activates a currently inactive watch. ``_ :param watch_id: Watch ID rrz /_activateNr r r r rrrrr rrr r r r rrrrrr activate_watchD zWatcherClient.activate_watchc Cr") z Deactivates a currently active watch. ``_ :param watch_id: Watch ID rrz /_deactivateNr r r r rrrrrr#rrr deactivate_watchfr%zWatcherClient.deactivate_watchidc C||tvrtddt|}i}|dur||d<|dur!||d<|dur)||d<|dur1||d<dd i}|jd |||d S) z Removes a watch from Watcher. ``_ :param id: Watch ID %Empty value passed for parameter 'id'rNr r r r rrDELETErr rr'r r r r rrrrrr delete_watch zWatcherClient.delete_watchT) body_fields) r' action_modesalternative_inputdebugr r r ignore_conditionr record_executionsimulated_actions trigger_datawatchr/zKt.Literal['execute', 'force_execute', 'force_simulate', 'simulate', 'skip']r0r1r2r3r4r5r6c Cs|tvr dt|d}nd}i}i}|dur||d<|dur#||d<|dur+||d<|dur3||d<|dur;||d <|durC||d <|durK||d <| durS| |d <| dur[| |d <| durc| |d<| durk| |d<| durs| |d<|swd}ddi}|durd|d<|jd||||dS)a Forces the execution of a stored watch. ``_ :param id: Identifier for the watch. :param action_modes: Determines how to handle the watch actions as part of the watch execution. :param alternative_input: When present, the watch uses this object as a payload instead of executing its own input. :param debug: Defines whether the watch runs in debug mode. :param ignore_condition: When set to `true`, the watch execution uses the always condition. This can also be specified as an HTTP parameter. :param record_execution: When set to `true`, the watch record representing the watch execution result is persisted to the `.watcher-history` index for the current time. In addition, the status of the watch is updated, possibly throttling subsequent executions. This can also be specified as an HTTP parameter. :param simulated_actions: :param trigger_data: This structure is parsed as the data of the trigger event that will be used during the watch execution :param watch: When present, this watch is used instead of the one specified in the request. This watch is not persisted to the index and record_execution cannot be set. rz /_executez/_watcher/watch/_executeNr/r0r1r r r r2r r3r4r5r6rr content-typerrrbodyrrr)rr'r/r0r1r r r r2r r3r4r5r6r_WatcherClient__bodyrrrrr execute_watchsJ4 zWatcherClient.execute_watchc Cr() z Retrieves a watch by its ID. ``_ :param id: Watch ID r)rNr r r r rrGETrrr+rrr get_watchr-zWatcherClient.get_watch)actionsactive conditionr r r if_primary_term if_seq_noinputmetadatar throttle_period transformtriggerversionr?r@rArBrCrDrErFrGrHrIcCsJ|tvrtddt|}i}i}|dur||d<|dur#||d<|dur+||d<|dur3||d<|dur;||d<|durC||d <|durK||d <| durS| |d <| dur[| |d <| durc| |d <| durk| |d<| durs| |d<|dur{||d<|dur||d<|dur||d<|sd}ddi}|durd|d<|jd||||dS)a* Creates a new watch, or updates an existing one. ``_ :param id: Watch ID :param actions: :param active: Specify whether the watch is in/active by default :param condition: :param if_primary_term: only update the watch if the last operation that has changed the watch has the specified primary term :param if_seq_no: only update the watch if the last operation that has changed the watch has the specified sequence number :param input: :param metadata: :param throttle_period: :param transform: :param trigger: :param version: Explicit version number for concurrency control r)rNr?r@rAr r r rBrCrDrEr rFrGrHrIrrr7rr8r)rr'r?r@rAr r r rBrCrDrEr rFrGrHrIrr;rrrrr put_watch'sV+ zWatcherClient.put_watchfromfrom_)r.Zparameter_aliases) r r rLr r query search_aftersizesortrMrNrOrPc Cs(d} i} i} | dur2t| trd| vs,t| ttfr2tdd| Dr2tdd| Dr2| | d<d} |dur:|| d<|durB|| d <|durJ|| d <|durR|| d <|durZ|| d <|durb|| d <|durj|| d<|durr|| d<| durz| | d<| s~d} ddi} | durd| d<|jd| | | | dS)u" Retrieves stored watches. ``_ :param from_: The offset from the first result to fetch. Needs to be non-negative. :param query: Optional, query filter watches to be returned. :param search_after: Optional search After to do pagination using last hit’s sort values. :param size: The number of hits to return. Needs to be non-negative. :param sort: Optional sort definition. z/_watcher/_query/watchesN:css|]}t|tVqdS)N) isinstancestr.0Z_xrrr sz.WatcherClient.query_watches..css|]}d|vVqdS)rQNrrTrrr rVsrPr r rKr r rMrNrOrrr7POSTr8)rRrSlisttupleallanyr)rr r rLr r rMrNrOrPrrr;rrrr query_watches~sR$  zWatcherClient.query_watchescCbd}i}|dur ||d<|dur||d<|dur||d<|dur$||d<ddi}|jd |||d S) z Starts Watcher if it is not already running. ``_ z/_watcher/_startNr r r r rrrWrrrr r r r rrrrrr startzWatcherClient.start)metricemit_stacktracesr r r r rbzIt.Literal['_all', 'current_watches', 'pending_watches', 'queued_watches']rcc Cs|tvr dt|}nd}i}|dur||d<|dur ||d<|dur(||d<|dur0||d<|dur8||d<d d i} |jd ||| d S) ai Retrieves the current Watcher metrics. ``_ :param metric: Defines which additional metrics are included in the response. :param emit_stacktraces: Defines whether stack traces are generated for each watch that is running. z/_watcher/stats/z/_watcher/statsNrcr r r r rrr=rr:) rrbrcr r r r rrrrrr statss$!zWatcherClient.statscCr]) z Stops Watcher if it is running. ``_ z/_watcher/_stopNr r r r rrrWrr^r_rrr stoprazWatcherClient.stop)__name__ __module__ __qualname__rrStOptionalUnionSequenceboolrAnyr!r$r&r,Mappingr<r>intrJfloatr\r`rdrerrrr rst ( ! ! !   X !      T    I  4r) typingriZelastic_transportr_baserutilsrrrrrrrr s