Downloads 620this week

GitHub stars 16

Extension repository on GitHub

Extension descriptor (YAML)

Query Elasticsearch indices directly using SQL

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

| function_name | function_type | description | comment | examples | |—————|—————|————-|———|———-|

Added Types

| type_name | type_size | logical_type | type_category | internal | |———–|———-:|————–|—————|———-|

Added Settings