Downloads 676this week

GitHub stars 23

Extension descriptor (YAML)

Query Elasticsearch indices directly using SQL

Compatibility Matrix

This table covers all DuckDB releases that have not reached end-of-life, including LTS releases, and shows the 2 most recent patch releases of each. Older patch releases are not listed, but the extension may be available for them as well.

Installing and Loading

INSTALL elasticsearch FROM community;
LOAD elasticsearch;

Example

-- Basic query.
SELECT * FROM elasticsearch_query(
    host := 'localhost',
    index := 'products'
);

-- Query with authentication.
SELECT * FROM elasticsearch_query(
    host := 'localhost',
    index := 'logs-*',
    username := 'elastic',
    password := 'secret',
    use_ssl := true
);

-- Filter pushdown – WHERE clauses are translated to Elasticsearch Query DSL.
SELECT name, price FROM elasticsearch_query(
    host := 'localhost',
    index := 'products'
)
WHERE category = 'electronics' AND price > 100;

-- Geospatial query pushdown (requires the DuckDB spatial extension).
INSTALL spatial;
LOAD spatial;

SELECT name FROM elasticsearch_query(
    host := 'localhost',
    index := 'places'
)
WHERE ST_Intersects(ST_GeomFromGeoJSON(geometry), ST_Point(-122.4194, 37.7749));

-- Combine WHERE clause with a base Elasticsearch query.
SELECT title, author FROM elasticsearch_query(
    host := 'localhost',
    index := 'books',
    query := '{"match": {"description": "science fiction"}}'
)
WHERE in_stock = true
LIMIT 10;

About elasticsearch

The DuckDB Elasticsearch extension enables querying Elasticsearch indices directly using SQL. It supports filter, projection and limit pushdown for optimized queries, automatic schema inference from index mappings and handles complex types like nested objects, arrays and geospatial types.

Key features:

• Filter pushdown – WHERE clauses are translated to Elasticsearch Query DSL.
• Projection pushdown – only requested columns are fetched via _source filtering.
• Limit pushdown – LIMIT/OFFSET clauses are pushed to Elasticsearch.
• Automatic schema inference from index mappings with array detection.
• Support for multi-index queries (e.g. logs-*).
• Geospatial types (geo_point, geo_shape) converted to GeoJSON format.
• SSL/TLS support with configurable certificate verification.
• Automatic retry with exponential backoff for transient errors.

For detailed documentation, visit the extension repository.

Added Functions

Overloaded Functions

This extension does not add any function overloads.

Added Types

This extension does not add any types.

Added Settings

This extension does not add any settings.