a _b@s,ddlmZmZmZmZGdddeZdS)) SKIP_IN_PATHNamespacedClient _make_path query_paramsc@szeZdZedddddZedddddZedddd d Zed dd d ZedddZedddZ dS) IngestClientZmaster_timeoutsummaryNcs"|jjdtdd|||dIdHS)a> Returns a pipeline. :arg id: Comma separated list of pipeline ids. Wildcards supported :arg master_timeout: Explicit operation timeout for connection to master node :arg summary: Return pipelines without their definitions (default: false) GET_ingestpipelineparamsheadersN) transportperform_requestrselfidr r rH/tmp/pip-target-4jja1joz/lib/python/opensearchpy/_async/client/ingest.py get_pipelines zIngestClient.get_pipelinetimeoutcsB||fD]}|tvrtdq|jjdtdd||||dIdHS)a  Creates or updates a pipeline. :arg id: Pipeline ID :arg body: The ingest definition :arg master_timeout: Explicit operation timeout for connection to master node :arg timeout: Explicit operation timeout z+Empty value passed for a required argument.PUTr r r r bodyNr ValueErrorrrr)rrrr r paramrrr put_pipeline0s   zIngestClient.put_pipelinecs2|tvrtd|jjdtdd|||dIdHS)z Deletes a pipeline. :arg id: Pipeline ID :arg master_timeout: Explicit operation timeout for connection to master node :arg timeout: Explicit operation timeout z0Empty value passed for a required argument 'id'.DELETEr r r Nrrrrrdelete_pipelineHs  zIngestClient.delete_pipelineverbosecs6|tvrtd|jjdtdd|d|||dIdHS)z Allows to simulate a pipeline with example documents. :arg body: The simulate definition :arg id: Pipeline ID :arg verbose: Verbose mode. Display data output for each processor in executed pipeline z2Empty value passed for a required argument 'body'.POSTr r Z _simulaterNr)rrrr r rrrsimulate]s  zIngestClient.simulatecs|jjdd||dIdHS)z; Returns a list of the built-in patterns. rz/_ingest/processor/grokr Nrrrr r rrrprocessor_groksszIngestClient.processor_grokcs|jjdd||dIdHS)zH Returns statistical information about geoip databases rz/_ingest/geoip/statsr Nr#r$rrr geo_ip_stats}szIngestClient.geo_ip_stats)NNN)NN)NN)NNN)NN)NN) __name__ __module__ __qualname__rrrrr"r%r&rrrrrs     rN)utilsrrrrrrrrrs