3 ] @s,ddlmZmZmZmZGdddeZdS))NamespacedClient query_params _make_path SKIP_IN_PATHc@sheZdZeddddZedddddZeddddd Zed dd d Zedd dZdS) IngestClientZmaster_timeoutNcCs|jjdtdd||dS)a ``_ :arg id: Comma separated list of pipeline ids. Wildcards supported :arg master_timeout: Explicit operation timeout for connection to master node GET_ingestpipeline)params) transportperform_requestr)selfidr rD/tmp/pip-build-z81i1n8o/elasticsearch/elasticsearch/client/ingest.py get_pipelines zIngestClient.get_pipelinetimeoutcCs>x ||fD]}|tkr tdq W|jjdtdd|||dS)a: ``_ :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 body)r ValueErrorr r r)r rrr paramrrr put_pipelines  zIngestClient.put_pipelinecCs*|tkrtd|jjdtdd||dS)a ``_ :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 )rrr r r)r rr rrrdelete_pipeline$s zIngestClient.delete_pipelineverbosecCs.|tkrtd|jjdtdd|d||dS)a$ ``_ :arg body: The simulate definition :arg id: Pipeline ID :arg verbose: Verbose mode. Display data output for each processor in executed pipeline, default False z2Empty value passed for a required argument 'body'.rrr Z _simulate)r r)rrr r r)r rrr rrrsimulate4s  zIngestClient.simulatecCs|jjdd|dS)z ``_ rz/_ingest/processor/grok)r )r r )r r rrrprocessor_grokGszIngestClient.processor_grok)NN)N)N)NN)N) __name__ __module__ __qualname__rrrrrrrrrrrs    rN)utilsrrrrrrrrrs