U Ec_@s,ddlmZmZmZmZGdddeZdS))NamespacedClient query_params _make_path SKIP_IN_PATHc@sheZdZeddddZedddddZeddddd Zed dd d Zedd dZdS) IngestClientZmaster_timeoutNcCs|jjdtdd|||dS)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 GET_ingestpipelineparamsheaders) transportperform_requestrselfidr r rB/tmp/pip-target-m1bursmm/lib/python/elasticsearch/client/ingest.py get_pipelines  zIngestClient.get_pipelinetimeoutcCs<||fD]}|tkrtdq|jjdtdd||||dS)ai 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.PUTrr r r bodyr ValueErrorr rr)rrrr r paramrrr put_pipeline%s   zIngestClient.put_pipelinecCs,|tkrtd|jjdtdd|||dS)a8 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'.DELETErr r rrrrrdelete_pipeline=s  zIngestClient.delete_pipelineverbosecCs0|tkrtd|jjdtdd|d|||dS)a` 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'.POSTrr Z _simulaterr)rrrr r rrrsimulateRs  zIngestClient.simulatecCs|jjdd||dS)z Returns a list of the built-in patterns. ``_ rz/_ingest/processor/grokr )r r)rr r rrrprocessor_grokhs zIngestClient.processor_grok)NNN)NN)NN)NNN)NN) __name__ __module__ __qualname__rrrrr!r"rrrrrs    rN)utilsrrrrrrrrrs