Elasticsearch Python Client (7.x Series)

import os
from elasticsearch import Elasticsearch

# Connect to a local Elasticsearch 7.x instance
# Replace with your actual host, port, and auth details
ES_HOST = os.environ.get('ES_HOST', 'localhost')
ES_PORT = int(os.environ.get('ES_PORT', 9200))
ES_USER = os.environ.get('ES_USER', 'elastic')
ES_PASSWORD = os.environ.get('ES_PASSWORD', 'changeme')

# For local, unsecured ES, verify_certs=False might be needed. 
# For production, ensure proper CA certs and security.
# In 7.x, http_auth is common for basic authentication.
es = Elasticsearch(
    [
        {'host': ES_HOST, 'port': ES_PORT}
    ],
    http_auth=(ES_USER, ES_PASSWORD), # Use http_auth for 7.x
    verify_certs=False, 
    ssl_show_warn=False # Suppress SSL warnings if verify_certs=False
)

# Check connection
print("Connected to Elasticsearch:", es.ping())

# Index a document
doc = {
    'author': 'John Doe',
    'text': 'Elasticsearch is a search engine.',
    'timestamp': '2023-01-01'
}
response = es.index(index='my-test-index-7', id=1, document=doc)
print("Document indexed:", response['result'])

# Get a document
response = es.get(index='my-test-index-7', id=1)
print("Retrieved document:", response['_source'])

# Search for documents
search_body = {
    'query': {
        'match': {
            'text': 'search engine'
        }
    }
}
response = es.search(index='my-test-index-7', body=search_body)
print(f"Found {response['hits']['total']['value']} hits:")
for hit in response['hits']['hits']:
    print(hit['_source'])