Elasticsearch наполняется и обновляется через операции индексирования и обновления документов. Обычно данные отправляются в Elasticsearch в формате JSON через REST API или клиентские библиотеки.

Для наполнения (индексации) используется метод index или bulk для пакетной загрузки. При обновлении можно использовать метод update, который позволяет частично изменить документ, либо повторно индексировать весь документ.

Пример на Go с использованием официального клиента elasticsearch-go:

import (
    "context"
    "encoding/json"
    "fmt"
    "strings"
    "github.com/elastic/go-elasticsearch/v8"
)

type Document struct {
    Title string `json:"title"`
    Content string `json:"content"`
}

func main() {
    es, _ := elasticsearch.NewDefaultClient()

    doc := Document{Title: "Пример", Content: "Текст документа"}
    data, _ := json.Marshal(doc)

    // Индексация документа
    res, err := es.Index(
        "my-index",
        strings.NewReader(string(data)),
        es.Index.WithDocumentID("1"),
        es.Index.WithRefresh("true"),
    )
    if err != nil {
        fmt.Println("Ошибка индексации:", err)
    }
    defer res.Body.Close()

    // Обновление документа (частичное)
    updateScript := `{"doc": {"content": "Обновленный текст"}}`
    res, err = es.Update(
        "my-index",
        "1",
        strings.NewReader(updateScript),
        es.Update.WithRefresh("true"),
    )
    if err != nil {
        fmt.Println("Ошибка обновления:", err)
    }
    defer res.Body.Close()
}

Таким образом, наполнение и обновление происходит через индексирование новых документов и обновление существующих через API Elasticsearch.

Как Elasticsearch наполнялся и обновлялся?