elasticsearch_dbapi_sqlalchemy_connection_and_sql_query.py

1from sqlalchemy import create_engine
2
3# The connection string follows the format:
4# elasticsearch+http://{user}:{password}@{host}:{port}/
5# For a local instance without authentication:
6engine = create_engine("elasticsearch+http://localhost:9200/")
7
8# Execute a query using the connection
9with engine.connect() as connection:
10    # Note: Elasticsearch SQL syntax is used here
11    result = connection.execute("SELECT * FROM \"my-index\" LIMIT 10")
12    for row in result:
13        print(row)