ElasticSearch

Situs web resmi: Elasticsearch: Mesin Pencarian dan Analisis Terdistribusi Resmi | Elastic

Elasticsearch adalah mesin pencarian dan analisis data yang terdistribusi dengan gaya RESTful, yang mampu menangani berbagai kasus penggunaan yang terus muncul. Sebagai inti dari Elastic Stack, Elasticsearch menyimpan data Anda secara terpusat, memungkinkan Anda melakukan pencarian dengan cepat, menyesuaikan relevansi, melakukan analisis yang kuat, dan dengan mudah meningkatkan skala. Artikel ini akan menjelaskan cara melakukan beberapa operasi dasar pada Elasticsearch dengan Go, seperti menambah, menghapus, mengubah, dan mencari. Jika Anda tidak familiar dengan Elasticsearch, silakan pelajari terlebih dahulu.

Dependensi

Unduh pustaka resmi

bash

$ github.com/elastic/go-elasticsearch/v7

Jika Anda menggunakan ES8, ganti versinya

bash

$ github.com/elastic/go-elasticsearch/v8

TIP

Artikel ini menggunakan ES8 untuk demonstrasi

Koneksi

Gunakan fungsi elasticsearch.NewClient untuk membuat koneksi baru

func NewClient(cfg Config) (*Client, error)

ES8+ menggunakan koneksi HTTPS secara default. Saat membuat koneksi HTTPS, Anda dapat menggunakan sertifikat CA atau sidik jari CA. Keduanya dihasilkan di sisi server Elasticsearch. Berikut adalah contohnya

client, err := elasticsearch.NewClient(elasticsearch.Config{
    Addresses:              []string{"https://192.168.153.132:9200"},
    Username:               "elastic",
    Password:               "TETJ8IY+ifbt8SLc+RRQ",
    CertificateFingerprint: "C0E9867C7D446BFF72FE46E7E9FE3455E970A8ADB0D3DF0E1472D55DB2612CD5",
})

Go API yang disediakan oleh elasticsearch pada dasarnya menggunakan fungsi bergaya opsi. Misalnya, Anda dapat menguji apakah layanan tersedia menggunakan API ping

pingResp, err := client.Ping(client.Ping.WithPretty(), client.Ping.WithHuman())
if err != nil {
    panic(err)
}
fmt.Println(pingResp)

Output

[200 OK]

Atau misalnya, periksa status layanan melalui Info API

infoResp, err := client.Info(client.Info.WithHuman())
if err != nil {
    panic(err)
}
fmt.Println(infoResp)

Output

[200 OK] {
  "name" : "db-debian12",
  "cluster_name" : "docker-cluster",
  "cluster_uuid" : "OMbDIsNwTFiuyjNF9Xnpbw",
  "version" : {
    "number" : "8.15.0",
    "build_flavor" : "default",
    "build_type" : "docker",
    "build_hash" : "1a77947f34deddb41af25e6f0ddb8e830159c179",
    "build_date" : "2024-08-05T10:05:34.233336849Z",
    "build_snapshot" : false,
    "lucene_version" : "9.11.1",
    "minimum_wire_compatibility_version" : "7.17.0",
    "minimum_index_compatibility_version" : "7.0.0"
  },
  "tagline" : "You Know, for Search"
}

TIP

Untuk pertanyaan apa pun tentang ES API, silakan konsultasikan dokumentasi resmi ES Restful API.

Indeks

Mengoperasikan indeks melalui go api, semua API operasi indeks terletak pada struktur esapi.Indices

// Indices contains the Indices APIs
type Indices struct {
    AddBlock              IndicesAddBlock
    Analyze               IndicesAnalyze
    ClearCache            IndicesClearCache
    Clone                 IndicesClone
    Close                 IndicesClose
    ...
    ...
  ValidateQuery         IndicesValidateQuery
}

Membuat

Membuat indeks, seperti yang ditunjukkan di bawah ini

json

{
  "settings": {
    "number_of_shards": 3,
    "number_of_replicas": 2
  },
  "mappings": {
    "properties": {
      "name": {
        "type": "text"
      },
      "age": {
        "type": "long"
      },
      "salary": {
        "type": "double"
      }
    }
  }
}

Operasi aktualnya hampir sama dengan mengirim permintaan HTTP

func main() {
  client, err := newClient()
  if err != nil {
    panic(err)
  }
  dsl := bytes.NewBufferString(`{
  "settings": {
    "number_of_shards": 3,
    "number_of_replicas": 2
  },
  "mappings": {
    "properties": {
        "name": {
          "type": "text"
        },
        "age": {
          "type": "long"
        },
        "salary": {
          "type": "double"
        }
      }
  }
}`)

  createIndices := client.Indices.Create
  resp, err := createIndices("user", createIndices.WithBody(dsl))
  if err != nil {
    panic(err)
  }
  fmt.Println(resp)
}

Output

json

[200 OK] {"acknowledged":true,"shards_acknowledged":true,"index":"user"}

Mendapatkan

Mendapatkan informasi tentang beberapa indeks

func main() {
  client, err := newClient()
  if err != nil {
    panic(err)
  }

  get := client.Indices.Get
  response, err := get([]string{"user"}, get.WithPretty(), get.WithHuman())
  if err != nil {
    panic(err)
  }
  fmt.Println(response)
}

Output

json

[200 OK] {
  "user" : {
    "aliases" : { },
    "mappings" : {
      "properties" : {
        "age" : {
          "type" : "long"
        },
        "name" : {
          "type" : "text"
        },
        "salary" : {
          "type" : "double"
        }
      }
    },
    "settings" : {
      "index" : {
        "creation_date_string" : "2024-09-23T04:35:04.528Z",
        "routing" : {
          "allocation" : {
            "include" : {
              "_tier_preference" : "data_content"
            }
          }
        },
        "number_of_shards" : "3",
        "provided_name" : "user",
        "creation_date" : "1727066104528",
        "number_of_replicas" : "2",
        "uuid" : "AvhhuqV2ShGkRP9z7XbdDA",
        "version" : {
          "created_string" : "8.14.4-snapshot[8512000]",
          "created" : "8512000"
        }
      }
    }
  }
}

Menganalisis

Menganalisis string teks untuk indeks yang ditentukan dan mengembalikan hasilnya, teks sebagai berikut

json

{
  "analyzer": "standard",
  "text": ["this is a test", "the second text"]
}

Kode

func main() {
  client, err := newClient()
  if err != nil {
    panic(err)
  }

  analyze := client.Indices.Analyze
  dsl := bytes.NewBufferString(`{
  "analyzer" : "standard",
  "text" : ["this is a test", "the second text"]
}`)
  response, err := analyze(analyze.WithIndex("user"), analyze.WithBody(dsl), analyze.WithPretty(), analyze.WithHuman())
  if err != nil {
    panic(err)
  }
  fmt.Println(response)
}

Output

json

[200 OK] {
  "tokens" : [
    {
      "token" : "this",
      "start_offset" : 0,
      "end_offset" : 4,
      "type" : "<ALPHANUM>",
      "position" : 0
    },
    {
      "token" : "is",
      "start_offset" : 5,
      "end_offset" : 7,
      "type" : "<ALPHANUM>",
      "position" : 1
    },
    {
      "token" : "a",
      "start_offset" : 8,
      "end_offset" : 9,
      "type" : "<ALPHANUM>",
      "position" : 2
    },
    {
      "token" : "test",
      "start_offset" : 10,
      "end_offset" : 14,
      "type" : "<ALPHANUM>",
      "position" : 3
    },
    {
      "token" : "the",
      "start_offset" : 15,
      "end_offset" : 18,
      "type" : "<ALPHANUM>",
      "position" : 104
    },
    {
      "token" : "second",
      "start_offset" : 19,
      "end_offset" : 25,
      "type" : "<ALPHANUM>",
      "position" : 105
    },
    {
      "token" : "text",
      "start_offset" : 26,
      "end_offset" : 30,
      "type" : "<ALPHANUM>",
      "position" : 106
    }
  ]
}

Menghapus

Menghapus beberapa indeks yang ditentukan

func main() {
  client, err := newClient()
  if err != nil {
    panic(err)
  }

  indicesDelete := client.Indices.Delete
  response, err := indicesDelete([]string{"user"})
  if err != nil {
    panic(err)
  }
  fmt.Println(response)
}

Output

json

[200 OK] {"acknowledged":true}

Dalam API ini, Anda dapat melihat bahwa badan permintaan harus diserialisasi secara manual, dan pihak resmi tidak memetakannya ke struktur Go. Badan respons juga harus ditangani secara manual. Ini adalah API yang umum digunakan, dan API lainnya tidak terlalu berbeda.

Dokumen

Membuat

Membuat dokumen seperti berikut

json

{
  "name": "jack",
  "age": 12,
  "salary": 5701.1
}

Kode

func main() {
  client, err := newClient()
  if err != nil {
    panic(err)
  }

  doc := bytes.NewBufferString(`{
    "name": "jack",
    "age": 12,
    "salary": 5701.1
}`)
  create := client.Create
  response, err := create("user", "1", doc, create.WithPretty())
  if err != nil {
    panic(err)
  }
  fmt.Println(response)
}

Output

json

[201 Created] {
  "_index" : "user",
  "_id" : "1",
  "_version" : 1,
  "result" : "created",
  "_shards" : {
    "total" : 3,
    "successful" : 1,
    "failed" : 0
  },
  "_seq_no" : 0,
  "_primary_term" : 1
}

Mendapatkan

Mendapatkan dokumen dengan ID yang ditentukan

func main() {
  client, err := newClient()
  if err != nil {
    panic(err)
  }

  get := client.Get
  response, err := get("user", "1", get.WithPretty())
  if err != nil {
    panic(err)
  }
  fmt.Println(response)
}

Output

json

[200 OK] {
  "_index" : "user",
  "_id" : "1",
  "_version" : 1,
  "_seq_no" : 0,
  "_primary_term" : 1,
  "found" : true,
  "_source" : {
    "name" : "jack",
    "age" : 12,
    "salary" : 5701.1
  }
}

Memperbarui

Memperbarui konten dokumen

json

{
  "doc": {
    "name": "jack",
    "age": 35,
    "salary": 5701.1
  }
}

Kode

func main() {
  client, err := newClient()
  if err != nil {
    panic(err)
  }

  doc := bytes.NewBufferString(`{
   "doc":  { "name": "jack",
    "age": 35,
    "salary": 5701.1
}}`)
  update := client.Update
  response, err := update("user", "1", doc, update.WithPretty())
  if err != nil {
    panic(err)
  }
  fmt.Println(response)
}

Output

json

[200 OK] {
  "_index" : "user",
  "_id" : "1",
  "_version" : 2,
  "result" : "updated",
  "_shards" : {
    "total" : 3,
    "successful" : 1,
    "failed" : 0
  },
  "_seq_no" : 1,
  "_primary_term" : 1
}

Update API juga mendukung operasi seperti upsert dengan script. Kunjungi Update API untuk informasi lebih lanjut.

Menghapus

Menghapus dokumen yang ditentukan berdasarkan ID

func main() {
    client, err := newClient()
    if err != nil {
       panic(err)
    }

    deleteDoc := client.Delete
    response, err := deleteDoc("user", "1", deleteDoc.WithPretty())
    if err != nil {
       panic(err)
    }
    fmt.Println(response)
}

Output

json

[200 OK] {
  "_index" : "user",
  "_id" : "1",
  "_version" : 3,
  "result" : "deleted",
  "_shards" : {
    "total" : 3,
    "successful" : 1,
    "failed" : 0
  },
  "_seq_no" : 2,
  "_primary_term" : 1
}

Pencarian

API yang paling umum digunakan di ES API adalah search API. Berikut adalah demonstrasi sederhana tentang cara penggunaannya. Pertama, siapkan data.

func main() {
  client, err := newClient()
  if err != nil {
    panic(err)
  }

  for i := range 10 {
    doc := bytes.NewBufferString(fmt.Sprintf(`{
    "name": "%s",
    "age": %d,
    "salary": %f
}`, randomName(), rand.Intn(18)+18, rand.Float64()))
    create := client.Create
    response, err := create("user", string('0'+i), doc, create.WithPretty())
    if err != nil {
      panic(err)
    }
    fmt.Println(response)
  }
}

func randomName() string {
  var b []byte
  for range 10 {
    b = append(b, byte(rand.Intn(26)+'a'))
  }
  return string(b)
}

Search API sama seperti HTTP API pada umumnya.

Query semua dokumen

func main() {
  client, err := newClient()
  if err != nil {
    panic(err)
  }
  dsl := bytes.NewBufferString(`{"query": {"match_all":{}}, "size": 1}`)
  search := client.Search
  response, err := search(search.WithBody(dsl), search.WithPretty())
  if err != nil {
    panic(err)
  }
  fmt.Println(response)
}

Mencocokkan bidang tertentu

func main() {
  client, err := newClient()
  if err != nil {
    panic(err)
  }
  dsl := bytes.NewBufferString(`{"query": {"term":{ "age": 22 } }, "size": 1}`)
  search := client.Search
  response, err := search(search.WithBody(dsl), search.WithPretty())
  if err != nil {
    panic(err)
  }
  fmt.Println(response)
}

Ringkasan

Operasi dasar hampir seperti ini. Penggunaannya sama seperti HTTP API. Setelah Anda menguasai ES, menggunakan Go API tidak akan menjadi masalah. Untuk operasi yang lebih canggih seperti cluster, data stream, dan lainnya, silakan jelajahi sendiri.

ElasticSearch ​

Dependensi ​

Koneksi ​

Indeks ​

Membuat ​

Mendapatkan ​

Menganalisis ​

Menghapus ​

Dokumen ​

Membuat ​

Mendapatkan ​

Memperbarui ​

Menghapus ​

Pencarian ​

Ringkasan ​

ElasticSearch

Dependensi

Koneksi

Indeks

Membuat

Mendapatkan

Menganalisis

Menghapus

Dokumen

Membuat

Mendapatkan

Memperbarui

Menghapus

Pencarian

Ringkasan