o gZh5@sHddlZddlmZddlmZddlmZmZm Z GdddeZ dS)N)ObjectApiResponse)NamespacedClient) SKIP_IN_PATH_quote_rewrite_parametersc@seZdZeddddddddedejedejejeej efdejedejejdd efd ejed ejejdd efd e ej fd dZ eddddddejedejejeej efdejed ejed e ej f ddZ edddddddddejedejedejejeej efdejedejejdd efd ejedejed e ej fddZeddddddejedejejeej efdejed ejed e ej f ddZedddidddddddddddddd dedejedejedejejeej efdejedejedejejdd efdejejeej fdejej ejeej fd ejed ejej ejeej fd ejejdd efd!ejed e ej fd"d#Zedd$ddddddddd%dejed&ejej ejeej fdejedejejeej efdejed'ejejeej fd ejed(ejed e ej fd)d*ZdS)+ IngestClientN) error_trace filter_pathhumanmaster_timeoutprettytimeoutidr r r r z t.Literal[-1]z t.Literal[0]r rreturnc Cs|tvrtddt|}i} |dur|| d<|dur!|| d<|dur)|| d<|dur1|| d<|dur9|| d<|durA|| d <d d i} |jd || | d S)a Deletes a pipeline. ``_ :param id: Pipeline ID or wildcard expression of pipeline IDs used to limit the request. To delete all ingest pipelines in a cluster, use a value of `*`. :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 timeout: Period to wait for a response. If no response is received before the timeout expires, the request fails and returns an error. %Empty value passed for parameter 'id'/_ingest/pipeline/Nr r r r r racceptapplication/jsonDELETEparamsheadersr ValueErrorrperform_request) selfrr r r r r r_IngestClient__path_IngestClient__query_IngestClient__headersr X/var/www/html/lang_env/lib/python3.10/site-packages/elasticsearch/_sync/client/ingest.pydelete_pipelines(zIngestClient.delete_pipeline)r r r r cCbd}i}|dur ||d<|dur||d<|dur||d<|dur$||d<ddi}|jd |||d S) z Returns statistical information about geoip databases ``_ z/_ingest/geoip/statsNr r r r rrGETrrrr r r r rrrr r r! geo_ip_statsKzIngestClient.geo_ip_stats)rr r r r r summaryr)c 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 a pipeline. ``_ :param id: Comma-separated list of pipeline IDs to retrieve. Wildcard (`*`) expressions are supported. To get all ingest pipelines, omit this parameter or use `*`. :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 summary: Return pipelines without their definitions (default: false) rz/_ingest/pipelineNr r r r r r)rrr$rrrr) rrr r r r r r)rrrr r r! get_pipelinehs(zIngestClient.get_pipelinecCr#) z Returns a list of the built-in patterns. ``_ z/_ingest/processor/grokNr r r r rrr$rr%r&r r r!processor_grokr(zIngestClient.processor_grokT_metameta) body_fieldsZparameter_aliases) descriptionr r r if_versionr r. on_failurer processorsrversionr0r1r2r3r4c Cs|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<ddd}|jd||||dS)a Creates or updates a pipeline. ``_ :param id: ID of the ingest pipeline to create or update. :param description: Description of the ingest pipeline. :param if_version: Required version for optimistic concurrency control for pipeline updates :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 meta: Optional metadata about the ingest pipeline. May have any contents. This map is not automatically generated by Elasticsearch. :param on_failure: Processors to run immediately after a processor failure. Each processor supports a processor-level `on_failure` value. If a processor without an `on_failure` value fails, Elasticsearch uses this pipeline-level parameter as a fallback. The processors in this parameter run sequentially in the order specified. Elasticsearch will not attempt to run the pipeline's remaining processors. :param processors: Processors used to perform transformations on documents before indexing. Processors run sequentially in the order specified. :param timeout: Period to wait for a response. If no response is received before the timeout expires, the request fails and returns an error. :param version: Version number used by external systems to track ingest pipelines. This parameter is intended for external systems only. Elasticsearch does not use or validate pipeline version numbers. rrNr0r r r r1r r-r2r r3rr4rrz content-typePUTrrbodyr)rrr0r r r r1r r.r2r r3rr4r_IngestClient__bodyrrr r r! put_pipelinesB3  zIngestClient.put_pipeline)r/)rdocsr r r pipeliner verboser;r<r=c Cs|tvr dt|d} nd} i} i} |dur|| d<|dur#|| d<|dur+|| d<|dur3|| d<|dur;|| d <|durC|| d <|durK|| d <d d d } |jd| | | | dS)u Allows to simulate a pipeline with example documents. ``_ :param id: Pipeline to test. If you don’t specify a `pipeline` in the request body, this parameter is required. :param docs: Sample documents to test in the pipeline. :param pipeline: Pipeline to test. If you don’t specify the `pipeline` request path parameter, this parameter is required. If you specify both this and the request path parameter, the API only uses the request path parameter. :param verbose: If `true`, the response includes output data for each processor in the executed pipeline. rz /_simulatez/_ingest/pipeline/_simulateNr;r r r r<r r=rr5POSTr7r*) rrr;r r r r<r r=rr9rrr r r!simulate s.  zIngestClient.simulate)__name__ __module__ __qualname__rstrtOptionalboolUnionSequencerAnyr"r'r+r,intMappingr:r?r r r r!rsF   /    /     Q   r) typingrDZelastic_transportr_baserutilsrrrrr r r r!s