(self, id, body, params=None)
return self.transport.perform_request('PUT', _make_path('_ingest',
            'pipeline', id), params=params, body=body)
`<https://www.elastic.co/guide/en/elasticsearch/plugins/current/ingest.html>`_

        :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
`<https://www.elastic.co/guide/en/elasticsearch/plugins/current/ingest.html>`_
<https : // www . elastic . co / guide / en / elasticsearch / plugins / current / ingest . html > _
def put_pipeline(self, id, body, params=None):
        """
        `<https://www.elastic.co/guide/en/elasticsearch/plugins/current/ingest.html>`_

        :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
        """
        for param in (id, body):
            if param in SKIP_IN_PATH:
                raise ValueError("Empty value passed for a required argument.")
        return self.transport.perform_request('PUT', _make_path('_ingest',
            'pipeline', id), params=params, body=body)
def put_pipeline ( self , id , body , params = None ) : for param in ( id , body ) : if param in SKIP_IN_PATH : raise ValueError ( "Empty value passed for a required argument." ) return self . transport . perform_request ( 'PUT' , _make_path ( '_ingest' , 'pipeline' , id ) , params = params , body = body )