Connecting

This page contains the information you need to connect the Client with Elasticsearch.

This section contains code snippets to show you how to connect to various Elasticsearch providers.

Cloud ID is an easy way to configure your client to work with your Elastic Cloud deployment. Combine the cloud_id with either http_auth or api_key to authenticate with your Elastic Cloud deployment.

Using cloud_id enables TLS verification and HTTP compression by default and sets the port to 443 unless otherwise overwritten via the port parameter or the port value encoded within cloud_id. Using Cloud ID also disables sniffing.

from elasticsearch import Elasticsearch

es = Elasticsearch(
    cloud_id=”cluster-1:dXMa5Fx...”
)

HTTP authentication uses the http_auth parameter by passing in a username and password within a tuple:

from elasticsearch import Elasticsearch

es = Elasticsearch(
    http_auth=(“username”, “password”)
)

You can configure the client to use Elasticsearch’s API Key for connecting to your cluster.

from elasticsearch import Elasticsearch

es = Elasticsearch(
    api_key=(“api_key_id”, “api_key_secret”)
)

The Elasticsearch server version 8.0 is introducing a new compatibility mode that allows you a smoother upgrade experience from 7 to 8. In a nutshell, you can use the latest 7.x Python Elasticsearch Elasticsearch client with an 8.x Elasticsearch server, giving more room to coordinate the upgrade of your codebase to the next major version.

If you want to leverage this functionality, please make sure that you are using the latest 7.x Python Elasticsearch client and set the environment variable ELASTIC_CLIENT_APIVERSIONING to true. The client is handling the rest internally. For every 8.0 and beyond Python Elasticsearch client, you’re all set! The compatibility mode is enabled by default.

This section illustrates the best practices for leveraging the Elasticsearch client in a Function-as-a-Service (FaaS) environment. The most influential optimization is to initialize the client outside of the function, the global scope. This practice does not only improve performance but also enables background functionality as – for example – sniffing. The following examples provide a skeleton for the best practices.

from elasticsearch import Elasticsearch

client = Elasticsearch(
    ... # Client initialization
)

def main(request):
    ... # Use the client

from elasticsearch import Elasticsearch

client = Elasticsearch(
    ... # Client initialization
)

def main(event, context):
    ... # Use the client

import azure.functions as func
from elasticsearch import Elasticsearch

client = Elasticsearch(
    ... # Client initialization
)

def main(request: func.HttpRequest) -> func.HttpResponse:
    ... # Use the client

Resources used to assess these recommendations: