Пример: Обогащение данных на основе точных значений

match политики обогащения сопоставляют данные для обогащения с поступающими документами на основе точного значения, например, адреса электронной почты или идентификатора, используя term запрос.

В следующем примере создается match политика обогащения, которая добавляет имя пользователя и контактную информацию к поступающим документам на основе адреса электронной почты. Затем она добавляет match политику обогащения в процессор в конвейере преобразования данных.

Используйте API создания индекса или API индексирования для создания исходного индекса.

Следующий запрос API индексирования создает исходный индекс и индексирует новый документ в этот индекс.

PUT /users/_doc/1?refresh=wait_for
{
  "email": "mardy.brown@asciidocsmith.com",
  "first_name": "Mardy",
  "last_name": "Brown",
  "city": "New Orleans",
  "county": "Orleans",
  "state": "LA",
  "zip": 70116,
  "web": "mardy.asciidocsmith.com"
}

Используйте API создания политики обогащения для создания политики обогащения с типом match. Эта политика должна включать:

PUT /_enrich/policy/users-policy
{
  "match": {
    "indices": "users",
    "match_field": "email",
    "enrich_fields": ["first_name", "last_name", "city", "zip", "state"]
  }
}

Используйте API выполнения политики обогащения для создания индекса обогащения для политики.

POST /_enrich/policy/users-policy/_execute

Используйте API создания или обновления конвейера, чтобы создать конвейер преобразования данных. В конвейере добавьте процессор обогащения, который включает:

PUT /_ingest/pipeline/user_lookup
{
  "processors" : [
    {
      "enrich" : {
        "description": "Add 'user' data based on 'email'",
        "policy_name": "users-policy",
        "field" : "email",
        "target_field": "user",
        "max_matches": "1"
      }
    }
  ]
}

Используйте конвейер преобразования данных для индексирования документа. Поступающий документ должен содержать field, указанное в вашем процессоре обогащения.

PUT /my-index-000001/_doc/my_id?pipeline=user_lookup
{
  "email": "mardy.brown@asciidocsmith.com"
}

Чтобы проверить, что процессор обогащения сопоставил и добавил соответствующие данные поля, используйте API получения для просмотра индексированного документа.

GET /my-index-000001/_doc/my_id

API возвращает следующий ответ:

{
  "found": true,
  "_index": "my-index-000001",
  "_type": "_doc",
  "_id": "my_id",
  "_version": 1,
  "_seq_no": 55,
  "_primary_term": 1,
  "_source": {
    "user": {
      "email": "mardy.brown@asciidocsmith.com",
      "first_name": "Mardy",
      "last_name": "Brown",
      "zip": 70116,
      "city": "New Orleans",
      "state": "LA"
    },
    "email": "mardy.brown@asciidocsmith.com"
  }
}