elastic

elastic

Elasticsearch client for R.

Connection

library(elastic)

# Connect to local Elasticsearch
connect()

# Connect with options
connect(
  host = "localhost",
  port = 9200,
  user = "elastic",
  pwd = "password"
)

# Check connection
ping()

Index Operations

# Create index
index_create("myindex")

# Create with settings
index_create("myindex", body = '{
  "settings": {
    "number_of_shards": 1,
    "number_of_replicas": 0
  },
  "mappings": {
    "properties": {
      "title": {"type": "text"},
      "date": {"type": "date"},
      "count": {"type": "integer"}
    }
  }
}')

# Check if exists
index_exists("myindex")

# Delete index
index_delete("myindex")

# List indices
cat_indices()

Indexing Documents

# Index single document
docs_create(index = "myindex", id = 1, body = list(
  title = "Hello",
  content = "World",
  date = Sys.Date()
))

# Bulk index
docs_bulk(df, index = "myindex")

# Bulk from file
docs_bulk("data.json", index = "myindex")

Search

# Simple search
Search(index = "myindex", q = "hello")

# Query DSL
Search(index = "myindex", body = '{
  "query": {
    "match": {
      "title": "hello"
    }
  }
}')

# Bool query
Search(index = "myindex", body = '{
  "query": {
    "bool": {
      "must": [
        {"match": {"title": "hello"}},
        {"range": {"date": {"gte": "2024-01-01"}}}
      ]
    }
  }
}')

# With pagination
Search(index = "myindex", size = 10, from = 0)

# With sorting
Search(index = "myindex", body = '{
  "query": {"match_all": {}},
  "sort": [{"date": "desc"}]
}')

Aggregations

# Terms aggregation
Search(index = "myindex", body = '{
  "size": 0,
  "aggs": {
    "categories": {
      "terms": {"field": "category.keyword"}
    }
  }
}')

# Date histogram
Search(index = "myindex", body = '{
  "size": 0,
  "aggs": {
    "by_month": {
      "date_histogram": {
        "field": "date",
        "calendar_interval": "month"
      }
    }
  }
}')

# Nested aggregations
Search(index = "myindex", body = '{
  "size": 0,
  "aggs": {
    "by_category": {
      "terms": {"field": "category.keyword"},
      "aggs": {
        "avg_price": {"avg": {"field": "price"}}
      }
    }
  }
}')