o gZhG@sHddlZddlmZddlmZddlmZmZm Z GdddeZ dS)N)ObjectApiResponse)NamespacedClient) SKIP_IN_PATH_quote_rewrite_parametersc @sxeZdZeddddddedejedejejeej efdejedejede ej f d d Z edddddd dejedejedejejeej efdejedejede ej f d d Z edddddd dejedejedejejeej efdejedejede ej f ddZeddddddejeej efdejedejejeej efdejedejede ej f ddZeddhddddddddddededejeej fdedededejedejejeej efdejejeejeej effdejedejej ejeej fdejedejejddefde ej fd d!Zedd"ddddddddddd# dejeej efd$ejejeejeej ffd%ejejeejeej ffdejedejejeej efdejedejed&ejejeej fd'ejed(ejed)ejede ej fd*d+Zeddddddedejedejejeej efdejedejede ej f d,d-Zeddddddd.dedejedejejeej efdejedejedejejddefd/ejede ej fd0d1ZdS)2 RollupClientN) error_trace filter_pathhumanprettyidr r r r returnc Cs||tvrtddt|}i}|dur||d<|dur!||d<|dur)||d<|dur1||d<dd i}|jd |||d S) z Deletes an existing rollup job. ``_ :param id: Identifier for the job. %Empty value passed for parameter 'id' /_rollup/job/Nr r r r acceptapplication/jsonDELETEparamsheadersr ValueErrorrperform_request selfr r r r r _RollupClient__path_RollupClient__query_RollupClient__headersrX/var/www/html/lang_env/lib/python3.10/site-packages/elasticsearch/_sync/client/rollup.py delete_jobs zRollupClient.delete_job)r r r r r c Cz|tvr dt|}nd}i}|dur||d<|dur ||d<|dur(||d<|dur0||d<dd i}|jd |||d S) a+ Retrieves the configuration, stats, and status of rollup jobs. ``_ :param id: Identifier for the rollup job. If it is `_all` or omitted, the API returns all rollup jobs. rz /_rollup/jobNr r r r rrGETrrrrrrrr get_jobs=s zRollupClient.get_jobsc Cr") a Returns the capabilities of any rollup jobs that have been configured for a specific index or index pattern. ``_ :param id: Index, indices or index-pattern to return rollup capabilities for. `_all` may be used to fetch rollup capabilities from all jobs. z/_rollup/data/ /_rollup/dataNr r r r rrr#rr$rrrr get_rollup_capsas zRollupClient.get_rollup_capsindexc C~|tvrtddt|d}i}|dur||d<|dur"||d<|dur*||d<|dur2||d<d d i}|jd |||d S) a} Returns the rollup capabilities of all jobs inside of a rollup index (e.g. the index where rollup data is stored). ``_ :param index: Data stream or index to check for rollup capabilities. Wildcard (`*`) expressions are supported. (Empty value passed for parameter 'index'/r&Nr r r r rrr#rr) rr(r r r r rrrrrr get_rollup_index_capss z"RollupClient.get_rollup_index_capsTr) body_fieldsZignore_deprecated_options)r r rr metricsr timeoutcrongroups index_pattern page_size rollup_indexr.r/z t.Literal[-1]z t.Literal[0]c CsT|tvrtd|durtd|durtd|dur td|dur(td|dur0tddt|}i}i}|durC||d <|durK||d <|durS||d <|dur[||d <|durc||d <|durk||d<|durs||d<| dur{| |d<| dur| |d<| dur| |d<| dur| |d<| dur| |d<ddd}|jd||||dS)uK Creates a rollup job. ``_ :param id: Identifier for the rollup job. This can be any alphanumeric string and uniquely identifies the data that is associated with the rollup job. The ID is persistent; it is stored with the rolled up data. If you create a job, let it run for a while, then delete the job, the data that the job rolled up is still be associated with this job ID. You cannot create a new job with the same ID since that could lead to problems with mismatched job configurations. :param cron: A cron string which defines the intervals when the rollup job should be executed. When the interval triggers, the indexer attempts to rollup the data in the index pattern. The cron pattern is unrelated to the time interval of the data being rolled up. For example, you may wish to create hourly rollups of your document but to only run the indexer on a daily basis at midnight, as defined by the cron. The cron pattern is defined just like a Watcher cron schedule. :param groups: Defines the grouping fields and aggregations that are defined for this rollup job. These fields will then be available later for aggregating into buckets. These aggs and fields can be used in any combination. Think of the groups configuration as defining a set of tools that can later be used in aggregations to partition the data. Unlike raw data, we have to think ahead to which fields and aggregations might be used. Rollups provide enough flexibility that you simply need to determine which fields are needed, not in what order they are needed. :param index_pattern: The index or index pattern to roll up. Supports wildcard-style patterns (`logstash-*`). The job attempts to rollup the entire index or index-pattern. :param page_size: The number of bucket results that are processed on each iteration of the rollup indexer. A larger value tends to execute faster, but requires more memory during processing. This value has no effect on how the data is rolled up; it is merely used for tweaking the speed or memory cost of the indexer. :param rollup_index: The index that contains the rollup results. The index can be shared with other rollup jobs. The data is stored so that it doesn’t interfere with unrelated jobs. :param headers: :param metrics: Defines the metrics to collect for each grouping tuple. By default, only the doc_counts are collected for each group. To make rollup useful, you will often add metrics like averages, mins, maxes, etc. Metrics are defined on a per-field basis and for each field you configure which metric should be collected. :param timeout: Time to wait for the request to complete. rNz'Empty value passed for parameter 'cron'z)Empty value passed for parameter 'groups'z0Empty value passed for parameter 'index_pattern'z,Empty value passed for parameter 'page_size'z/Empty value passed for parameter 'rollup_index'rr0r1r2r3r4r r rr r.r r/rrz content-typePUTrrbodyr)rr r0r1r2r3r4r r rr r.r r/r_RollupClient__bodyrrrrr put_jobsVB  zRollupClient.put_job)r-) aggregationsaggsr r r r queryrest_total_hits_as_intsize typed_keysr;r<r=r>r?r@c Cs|tvrtddt|d} i} i}|dur|| d<|dur$|| d<|dur,||d<|dur4||d<|dur<||d <|durD||d <|durL|| d <| durT| |d <| dur\| | d <| durd| |d<ddd}|jd| ||| dS)a Enables searching rolled-up data using the standard query DSL. ``_ :param index: Enables searching rolled-up data using the standard Query DSL. :param aggregations: Specifies aggregations. :param aggs: Specifies aggregations. :param query: Specifies a DSL query. :param rest_total_hits_as_int: Indicates whether hits.total should be rendered as an integer or an object in the rest search response :param size: Must be zero if set, as rollups work on pre-aggregated data. :param typed_keys: Specify whether aggregation and suggester names should be prefixed by their respective types in the response r*r+z/_rollup_searchNr;r<r r r r r=r>r?r@rr5POSTr7r)rr(r;r<r r r r r=r>r?r@rr9rrrrr rollup_searchs:!  zRollupClient.rollup_searchc Cr)) z Starts an existing, stopped rollup job. ``_ :param id: Identifier for the rollup job. rrz/_startNr r r r rrrArrrrrr start_jobWs zRollupClient.start_job)r r r r r/wait_for_completionrDc Cs|tvrtddt|d}i} |dur|| d<|dur"|| d<|dur*|| d<|dur2|| d<|dur:|| d <|durB|| d <d d i} |jd || | dS)a Stops an existing, started rollup job. ``_ :param id: Identifier for the rollup job. :param timeout: If `wait_for_completion` is `true`, the API blocks for (at maximum) the specified duration while waiting for the job to stop. If more than `timeout` time has passed, the API throws a timeout exception. :param wait_for_completion: If set to `true`, causes the API to block until the indexer state completely stops. If set to `false`, the API returns immediately and the indexer is stopped asynchronously in the background. rrz/_stopNr r r r r/rDrrrArr) rr r r r r r/rDrrrrrr stop_jobys(zRollupClient.stop_job)__name__ __module__ __qualname__rstrtOptionalboolUnionSequencerAnyr!r%r'r,Mappingintr:rBrCrErrrr rs ! # $ #   "    j      < !  r) typingrJZelastic_transportr_baserutilsrrrrrrrr s