例: 正確な値に基づいてデータを強化（Example: Enrich your data based on exact values）

例: 正確な値に基づいてデータを強化する

match enrich policies は、メールアドレスやIDなどの正確な値に基づいて、受信文書に強化データを一致させます。これは term query を使用します。

次の例では、メールアドレスに基づいて受信文書にユーザー名と連絡先情報を追加する match 強化ポリシーを作成します。その後、受信パイプラインのプロセッサに match 強化ポリシーを追加します。

create index API または index API を使用して、ソースインデックスを作成します。

次のインデックスAPIリクエストは、ソースインデックスを作成し、そのインデックスに新しい文書をインデックスします。

Python

resp = client.index(
   index="users",
   id="1",
   refresh="wait_for",
   document={
   "email": "[email protected]",
   "first_name": "Mardy",
   "last_name": "Brown",
   "city": "New Orleans",
   "county": "Orleans",
   "state": "LA",
   "zip": 70116,
   "web": "mardy.asciidocsmith.com"
   },
)
print(resp)

Ruby

response = client.index(
  index: 'users',
  id: 1,
  refresh: 'wait_for',
  body: {
   email: '[email protected]',
   first_name: 'Mardy',
   last_name: 'Brown',
   city: 'New Orleans',
   county: 'Orleans',
   state: 'LA',
   zip: 70_116,
   web: 'mardy.asciidocsmith.com'
  }
)
puts response

Js

const response = await client.index({
  index: "users",
  id: 1,
  refresh: "wait_for",
  document: {
   email: "[email protected]",
   first_name: "Mardy",
   last_name: "Brown",
   city: "New Orleans",
   county: "Orleans",
   state: "LA",
   zip: 70116,
   web: "mardy.asciidocsmith.com",
  },
});
console.log(response);

コンソール

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

create enrich policy APIを使用して、matchポリシータイプの強化ポリシーを作成します。このポリシーには次のものが含まれている必要があります:

• 1つ以上のソースインデックス
• match_field、受信文書と一致させるために使用されるソースインデックスのフィールド
• 受信文書に追加したいソースインデックスからの強化フィールド

Python

resp = client.enrich.put_policy(
   name="users-policy",
   match={
   "indices": "users",
   "match_field": "email",
   "enrich_fields": [
   "first_name",
   "last_name",
   "city",
   "zip",
   "state"
   ]
   },
)
print(resp)

Ruby

response = client.enrich.put_policy(
  name: 'users-policy',
  body: {
   match: {
   indices: 'users',
   match_field: 'email',
   enrich_fields: [
   'first_name',
   'last_name',
   'city',
   'zip',
   'state'
   ]
   }
  }
)
puts response

Js

const response = await client.enrich.putPolicy({
  name: "users-policy",
  match: {
   indices: "users",
   match_field: "email",
   enrich_fields: ["first_name", "last_name", "city", "zip", "state"],
  },
});
console.log(response);

コンソール

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

execute enrich policy APIを使用して、ポリシーのための強化インデックスを作成します。

コンソール

POST /_enrich/policy/users-policy/_execute?wait_for_completion=false

create or update pipeline APIを使用して、受信パイプラインを作成します。パイプライン内で、次のものを含むenrich processorを追加します:

• あなたの強化ポリシー。
• 受信文書のfield、強化インデックスからの文書と一致させるために使用されます。
• 受信文書のために追加された強化データを保存するために使用されるtarget_field。このフィールドには、あなたの強化ポリシーで指定されたmatch_fieldとenrich_fieldsが含まれています。

Python

resp = client.ingest.put_pipeline(
   id="user_lookup",
   processors=[
   {
   "enrich": {
   "description": "Add 'user' data based on 'email'",
   "policy_name": "users-policy",
   "field": "email",
   "target_field": "user",
   "max_matches": "1"
   }
   }
   ],
)
print(resp)

Js

const response = await client.ingest.putPipeline({
  id: "user_lookup",
  processors: [
   {
   enrich: {
   description: "Add 'user' data based on 'email'",
   policy_name: "users-policy",
   field: "email",
   target_field: "user",
   max_matches: "1",
   },
   },
  ],
});
console.log(response);

コンソール

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が含まれている必要があります。

Python

resp = client.index(
   index="my-index-000001",
   id="my_id",
   pipeline="user_lookup",
   document={
   "email": "[email protected]"
   },
)
print(resp)

Js

const response = await client.index({
  index: "my-index-000001",
  id: "my_id",
  pipeline: "user_lookup",
  document: {
   email: "[email protected]",
  },
});
console.log(response);

コンソール

PUT /my-index-000001/_doc/my_id?pipeline=user_lookup
{
  "email": "[email protected]"
}

強化プロセッサが適切なフィールドデータを一致させて追加したことを確認するには、get APIを使用してインデックスされた文書を表示します。

Python

resp = client.get(
   index="my-index-000001",
   id="my_id",
)
print(resp)

Ruby

response = client.get(
  index: 'my-index-000001',
  id: 'my_id'
)
puts response

Js

const response = await client.get({
  index: "my-index-000001",
  id: "my_id",
});
console.log(response);

コンソール

GET /my-index-000001/_doc/my_id

APIは次の応答を返します:

コンソール-結果

{
  "found": true,
  "_index": "my-index-000001",
  "_id": "my_id",
  "_version": 1,
  "_seq_no": 55,
  "_primary_term": 1,
  "_source": {
   "user": {
   "email": "[email protected]",
   "first_name": "Mardy",
   "last_name": "Brown",
   "zip": 70116,
   "city": "New Orleans",
   "state": "LA"
   },
   "email": "[email protected]"
  }
}