Python api client connection with proxy

Hi use the following class to connect the client to Elastic Cloud running in Azure. The job runs in kubernetes updating my index with some data in a daily basis, and I need to setup the proxy from my organization in order to reach the es endpoint.

from elasticsearch import Elasticsearch, RequestsHttpConnection # v7.10.0
from elasticsearch.helpers import bulk

class ESManagement:
    def __init__(self):
        self.es_client = Elasticsearch(
            http_auth=(os.environ.get('es_username'), os.environ.get('es_password')),
            proxies={'https': os.environ.get('proxy4server'), 'http': os.environ.get('proxy4server')}

    def create_index(self, index: str):

    def delete_index(self, index_name):

    def index_batch(self, docs):

class MyConnection(RequestsHttpConnection):
    def __init__(self, *args, **kwargs):
        proxies = kwargs.pop('proxies', {})
        super(MyConnection, self).__init__(*args, **kwargs)
        self.session.proxies = proxies

This class works fine running with elasticsearch 7.10.0. Now I want to update to elasticsearch api 8.5.1. I saw the migration page, but it doesn't mention anything about the proxies setup. Does any one have any idea about how to implement some similar code for the new version?

Also I realized that "RequestsHttpConnection" is not available anymore, so I guess the api will be using Urllib3 library everytime, rigth?

elasticsearch 7.10 is EOL and no longer supported. Please upgrade ASAP.

(This is an automated response from your friendly Elastic bot. Please report this post if you have any suggestions or concerns :elasticheart: )

This topic was automatically closed 28 days after the last reply. New replies are no longer allowed.