o gZh2@sHddlZddlmZddlmZddlmZmZm Z GdddeZ dS)N)ObjectApiResponse)NamespacedClient) SKIP_IN_PATH_quote_rewrite_parametersc+@s`eZdZeddddddddedejedejejeej efdejedejejdd efd ejed ejejdd efd e ej fd dZ eddddddddddededededejedejejeej efdejedejejdd efd ejed ejejdd efd e ej fddZ eddddddddddddddd dededejedejej edejejeej efdejedejedejedejejeej efdejejdd efdejejeej fdejed ejedejed e ej fddZeddddddddddd ded!ejeej fd"edejedejejeej efdejedejejdd efd ejedejejeej fd ejejdd efd#ejed e ej fd$d%Zedddddd&dededejedejejeej efdejedejejdd efd ejed e ej fd'd(Zeddddddddejeej efdejedejejeej efdejedejejdd efd ejed ejejdd efd e ej fd)d*Zedddddddddddddddddd+dedejeej efd,ejedejedejejeej efd-ejedejedejed.ejed/ejed0ejedejejdd efd1ejed2ejejd3efd ejed4ejed5ejed6ejejd7efd8ejed e ej f(d9d:Zedddddddd;dejejeej efdejedejejeej efdejedZeddddddddddddddddddd?dededejedejej edejejeej efdejed@ejej edejedAejedejedBejejeej fdejejeej efdejejdd efdejed ejedCejedDejedejed e ej f&dEdFZedddddddddGdejedejejeej efdejedejejeej efdejedejedejejdd efd ejed e ej fdHdIZeddddddddedejedejejeej efdejedejejdd efd ejed ejejdd efd e ej fdJdKZdS)LSnapshotClientN) error_trace filter_pathhumanmaster_timeoutprettytimeoutnamer r r r z t.Literal[-1]z t.Literal[0]r rreturnc C|tvrtddt|d}i} |dur|| d<|dur"|| d<|dur*|| d<|dur2|| d<|dur:|| d <|durB|| d <d d i} |jd || | dS)aa Removes stale data from repository. ``_ :param name: Snapshot repository to clean up. :param master_timeout: Period to wait for a connection to the master node. :param timeout: Period to wait for a response. 'Empty value passed for parameter 'name' /_snapshot/z /_cleanupNr r r r r racceptapplication/jsonPOSTparamsheadersr ValueErrorrperform_request selfrr r r r r r_SnapshotClient__path_SnapshotClient__query_SnapshotClient__headersr"Z/var/www/html/lang_env/lib/python3.10/site-packages/elasticsearch/_sync/client/snapshot.pycleanup_repository(z!SnapshotClient.cleanup_repositoryT)Z body_fields repositorysnapshottarget_snapshotindicesc Cs|tvrtd|tvrtd|tvrtd|dur tddt|dt|dt|} i} i} |dur=|| d <|durE|| d <|durM|| d <|durU|| d <|dur]|| d <| dure| | d<| durm| | d<ddd}|jd| | || dS)a Clones indices from one snapshot into another snapshot in the same repository. ``_ :param repository: A repository name :param snapshot: The name of the snapshot to clone from :param target_snapshot: The name of the cloned snapshot to create :param indices: :param master_timeout: Explicit operation timeout for connection to master node :param timeout: -Empty value passed for parameter 'repository'+Empty value passed for parameter 'snapshot'z2Empty value passed for parameter 'target_snapshot'Nz*Empty value passed for parameter 'indices'r/z/_clone/r)r r r r r rrr content-typePUTrrbodyr)rr&r'r(r)r r r r r rr_SnapshotClient__bodyr r!r"r"r#cloneGs:"  zSnapshotClient.clone) r feature_statesr r ignore_unavailableinclude_global_stater)r metadatapartialr wait_for_completionr4r5r6r7r8r9cCs4|tvrtd|tvrtddt|dt|}i}i}|dur(||d<|dur0||d<|dur8||d<|dur@||d <|durH||d <|durP||d <| durX| |d <| dur`| |d <| durh| |d<| durp| |d<| durx| |d<|dur||d<|sd}ddi}|durd|d<|jd||||dS)a Creates a snapshot in a repository. ``_ :param repository: Repository for the snapshot. :param snapshot: Name of the snapshot. Must be unique in the repository. :param feature_states: Feature states to include in the snapshot. Each feature state includes one or more system indices containing related data. You can view a list of eligible features using the get features API. If `include_global_state` is `true`, all current feature states are included by default. If `include_global_state` is `false`, no feature states are included by default. :param ignore_unavailable: If `true`, the request ignores data streams and indices in `indices` that are missing or closed. If `false`, the request returns an error for any data stream or index that is missing or closed. :param include_global_state: If `true`, the current cluster state is included in the snapshot. The cluster state includes persistent cluster settings, composable index templates, legacy index templates, ingest pipelines, and ILM policies. It also includes data stored in system indices, such as Watches and task records (configurable via `feature_states`). :param indices: Data streams and indices to include in the snapshot. Supports multi-target syntax. Includes all data streams and indices by default. :param master_timeout: Period to wait for a connection to the master node. If no response is received before the timeout expires, the request fails and returns an error. :param metadata: Optional metadata for the snapshot. May have any contents. Must be less than 1024 bytes. This map is not automatically generated by Elasticsearch. :param partial: If `true`, allows restoring a partial snapshot of indices with unavailable shards. Only shards that were successfully included in the snapshot will be restored. All missing shards will be recreated as empty. If `false`, the entire restore operation will fail if one or more indices included in the snapshot do not have all primary shards available. :param wait_for_completion: If `true`, the request returns a response when the snapshot is complete. If `false`, the request returns a response when the snapshot initializes. r*r+rr,Nr r4r r r5r6r)r r7r8r r9rrr.r/r0r)rr&r'r r4r r r5r6r)r r7r8r r9rr r2r!r"r"r#createsN; zSnapshotClient.create)r r r r r r&rverifysettingstyper;c Cs|tvrtd|durtd|durtddt|} i} i}|dur+|| d<|dur3|| d<|dur;||d<|durC||d <|durK||d <|durS||d <|dur[||d <| durc| | d <| durk| |d<| durs| |d<ddd}|jd| ||| dS)a Creates a repository. ``_ :param name: A repository name :param settings: :param type: :param master_timeout: Explicit operation timeout for connection to master node :param repository: :param timeout: Explicit operation timeout :param verify: Whether to verify the repository after creation rNz+Empty value passed for parameter 'settings'z'Empty value passed for parameter 'type'rr<r=r r r r r r&rr;rr-r/r0r)rrr<r=r r r r r r&rr;rr2r r!r"r"r#create_repositorysB!  z SnapshotClient.create_repository)r r r r r c Cs|tvrtd|tvrtddt|dt|}i} |dur&|| d<|dur.|| d<|dur6|| d<|dur>|| d <|durF|| d <d d i} |jd || | dS)aZ Deletes one or more snapshots. ``_ :param repository: A repository name :param snapshot: A comma-separated list of snapshot names :param master_timeout: Explicit operation timeout for connection to master node r*r+rr,Nr r r r r rrDELETErr) rr&r'r r r r r rr r!r"r"r#delete*s(zSnapshotClient.deletec Cs|tvrtddt|}i} |dur|| d<|dur!|| d<|dur)|| d<|dur1|| d<|dur9|| d<|durA|| d <d d i} |jd || | d S)a Deletes a repository. ``_ :param name: Name of the snapshot repository to unregister. Wildcard (`*`) patterns are supported. :param master_timeout: Explicit operation timeout for connection to master node :param timeout: Explicit operation timeout rrNr r r r r rrrr?rrrr"r"r#delete_repositoryVs(z SnapshotClient.delete_repository)afterr r from_sort_valuer r5include_repository index_details index_namesr offsetorderr sizeslm_policy_filtersortverboserBrCrDrErFrGrHzt.Literal['asc', 'desc']rIrJrKzmt.Literal['duration', 'failed_shard_count', 'index_count', 'name', 'repository', 'shard_count', 'start_time']rLcCsf|tvrtd|tvrtddt|dt|}i}|dur&||d<|dur.||d<|dur6||d<|dur>||d <|durF||d <|durN||d <| durV| |d <| dur^| |d <| durf| |d<| durn| |d<| durv| |d<|dur~||d<|dur||d<|dur||d<|dur||d<|dur||d<|dur||d<ddi}|jd|||dS)a Returns information about a snapshot. ``_ :param repository: Comma-separated list of snapshot repository names used to limit the request. Wildcard (*) expressions are supported. :param snapshot: Comma-separated list of snapshot names to retrieve. Also accepts wildcards (*). - To get information about all snapshots in a registered repository, use a wildcard (*) or _all. - To get information about any snapshots that are currently running, use _current. :param after: Offset identifier to start pagination from as returned by the next field in the response body. :param from_sort_value: Value of the current sort column at which to start retrieval. Can either be a string snapshot- or repository name when sorting by snapshot or repository name, a millisecond time value or a number when sorting by index- or shard count. :param ignore_unavailable: If false, the request returns an error for any snapshots that are unavailable. :param include_repository: If true, returns the repository name in each snapshot. :param index_details: If true, returns additional information about each index in the snapshot comprising the number of shards in the index, the total size of the index in bytes, and the maximum number of segments per shard in the index. Defaults to false, meaning that this information is omitted. :param index_names: If true, returns the name of each index in each snapshot. :param master_timeout: Period to wait for a connection to the master node. If no response is received before the timeout expires, the request fails and returns an error. :param offset: Numeric offset to start pagination from based on the snapshots matching this request. Using a non-zero value for this parameter is mutually exclusive with using the after parameter. Defaults to 0. :param order: Sort order. Valid values are asc for ascending and desc for descending order. Defaults to asc, meaning ascending order. :param size: Maximum number of snapshots to return. Defaults to 0 which means return all that match the request without limit. :param slm_policy_filter: Filter snapshots by a comma-separated list of SLM policy names that snapshots belong to. Also accepts wildcards (*) and combinations of wildcards followed by exclude patterns starting with -. To include snapshots not created by an SLM policy you can use the special pattern _none that will match all snapshots without an SLM policy. :param sort: Allows setting a sort order for the result. Defaults to start_time, i.e. sorting by snapshot start time stamp. :param verbose: If true, returns additional information about each snapshot such as the version of Elasticsearch which took the snapshot, the start and end times of the snapshot, and the number of shards snapshotted. r*r+rr,NrBr r rCr r5rDrErFr rGrHr rIrJrKrLrrGETrr)rr&r'rBr r rCr r5rDrErFr rGrHr rIrJrKrLrr r!r"r"r#getsXMzSnapshotClient.get)rr r r localr r rOc Cs|tvr dt|}nd}i} |dur|| d<|dur || d<|dur(|| d<|dur0|| d<|dur8|| d<|dur@|| d <d d i} |jd || | d S)a Returns information about a repository. ``_ :param name: A comma-separated list of repository names :param local: Return local information, do not retrieve the state from master node (default: false) :param master_timeout: Explicit operation timeout for connection to master node rz /_snapshotNr r r rOr r rrrMrrrr) rrr r r rOr r rr r!r"r"r#get_repositorys(zSnapshotClient.get_repository)r r4r r ignore_index_settingsr5include_aliasesr6index_settingsr)r r8r rename_patternrename_replacementr9rRrSrTrUrVcCsv|tvrtd|tvrtddt|dt|d}i}i}|dur)||d<|dur1||d<|dur9||d <|durA||d <|durI||d <|durQ||d <| durY| |d <| dura| |d<| duri| |d<| durq| |d<| dury| |d<|dur||d<|dur||d<|dur||d<|dur||d<|dur||d<|sd}ddi}|durd|d<|jd||||dS)a Restores a snapshot. ``_ :param repository: A repository name :param snapshot: A snapshot name :param feature_states: :param ignore_index_settings: :param ignore_unavailable: :param include_aliases: :param include_global_state: :param index_settings: :param indices: :param master_timeout: Explicit operation timeout for connection to master node :param partial: :param rename_pattern: :param rename_replacement: :param wait_for_completion: Should this request wait until the operation has completed before returning r*r+rr,z /_restoreNr r4r r rRr5rSr6rTr)r r8r rUrVr9rrr.rr0r)rr&r'r r4r r rRr5rSr6rTr)r r8r rUrVr9rr r2r!r"r"r#restore+s^0 zSnapshotClient.restore)r&r'r r r r5r r c Cs|tvr|tvrdt|dt|d} n|tvr#dt|d} nd} i} |dur/|| d<|dur7|| d<|dur?|| d<|durG|| d <|durO|| d <|durW|| d <d d i} |jd| | | dS)a  Returns information about the status of a snapshot. ``_ :param repository: A repository name :param snapshot: A comma-separated list of snapshot names :param ignore_unavailable: Whether to ignore unavailable snapshots, defaults to false which means a SnapshotMissingException is thrown :param master_timeout: Explicit operation timeout for connection to master node rr,z/_statusz/_snapshot/_statusNr r r r5r r rrrMrrP) rr&r'r r r r5r r rr r!r"r"r#statuss,zSnapshotClient.statusc Cr)a= Verifies a repository. ``_ :param name: A repository name :param master_timeout: Explicit operation timeout for connection to master node :param timeout: Explicit operation timeout rrz/_verifyNr r r r r rrrrrrrr"r"r#verify_repositoryr%z SnapshotClient.verify_repository)__name__ __module__ __qualname__rstrtOptionalboolUnionSequencerAnyr$r3Mappingr:r>r@rAintrNrQrWrXrYr"r"r"r#rs0   +     :     `     @  +   ,      y  -      ]   1   r) typingr^Zelastic_transportr_baserutilsrrrrr"r"r"r#s