AppenderElasticSearch: Log to ElasticSearch

In lgrExtra: Extra Appenders for 'lgr'

Log to ElasticSearch

Description

NOTE: Maturing; not yet fully documented but well tested in a production scenario

Value

The ⁠$new()⁠ method returns an R6::R6 that inherits from lgr::Appender and can be uses as an appender by a lgr::Logger.

Super classes

lgr::Filterable -> lgr::Appender -> lgr::AppenderMemory -> AppenderElasticSearch

Active bindings

conn

a ElasticSearch connection

index

target ElasticSearch index. May either be:

• a character scalar, or

• a function returning a character scalar

index_create_body

• character scalar json string (or NULL).

• a function returning a character scalar json string (or NULL) Optional settings, mappings, aliases, etc... in case the target index has to be created by the logger. See https://www.elastic.co/docs/api/doc/elasticsearch/operation/operation-indices-create

Methods

Public methods

• AppenderElasticSearch$new()

• AppenderElasticSearch$set_conn()

• AppenderElasticSearch$get_data()

• AppenderElasticSearch$show()

• AppenderElasticSearch$flush()

Inherited methods

• lgr::Filterable$add_filter()
• lgr::Filterable$filter()
• lgr::Filterable$remove_filter()
• lgr::Filterable$set_filters()
• lgr::Appender$set_layout()
• lgr::Appender$set_threshold()
• lgr::AppenderMemory$append()
• lgr::AppenderMemory$clear()
• lgr::AppenderMemory$format()
• lgr::AppenderMemory$set_buffer_size()
• lgr::AppenderMemory$set_flush_on_exit()
• lgr::AppenderMemory$set_flush_on_rotate()
• lgr::AppenderMemory$set_flush_threshold()
• lgr::AppenderMemory$set_should_flush()

---

Method new()

Usage

AppenderElasticSearch$new(
  conn,
  index,
  threshold = NA_integer_,
  layout = ElasticSearchLayout,
  index_create_body = NULL,
  buffer_size = 0,
  flush_threshold = "error",
  flush_on_exit = TRUE,
  flush_on_rotate = TRUE,
  should_flush = NULL,
  filters = NULL
)

Arguments

conn, index

see section Fields

threshold, flush_threshold, layout, buffer_size

see lgr::AppenderBuffer A data data.frame. content of index

---

Method set_conn()

Usage

AppenderElasticSearch$set_conn(conn)

---

Method get_data()

Usage

AppenderElasticSearch$get_data(
  n = 20L,
  threshold = NA,
  result_type = "data.frame"
)

Arguments

n

integer scalar. Retrieve only the last n log entries that match threshold

threshold

character or integer scalar. The minimum log level that should be displayed

result_type

character scalar. Any of:

• data.frame

• data.table (shortcut: dt)

• list (unprocessed list with ElasticSearch metadata)

• json (raw ElasticSearch JSON)

Returns

see result_type

---

Method show()

Usage

AppenderElasticSearch$show(threshold = NA_integer_, n = 20)

---

Method flush()

Usage

AppenderElasticSearch$flush()

See Also

Other Appenders: AppenderAWSCloudWatchLog, AppenderDbi, AppenderDynatrace, AppenderGmail, AppenderPool, AppenderPushbullet, AppenderSendmail, AppenderSyslog

lgrExtra documentation built on Nov. 5, 2025, 7:13 p.m.