示例:根据精确值丰富您的数据
编辑示例:根据精确值丰富您的数据编辑
match
丰富策略 使用 term
查询,根据精确值(例如电子邮件地址或 ID)将丰富数据与传入文档匹配。
以下示例创建了一个 match
丰富策略,该策略根据电子邮件地址将用户名和联系信息添加到传入文档中。然后,它将 match
丰富策略添加到摄取管道中的处理器中。
以下索引 API 请求创建源索引并将新文档索引到该索引中。
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
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" }
使用创建丰富策略 API 使用 match
策略类型创建丰富策略。此策略必须包含
- 一个或多个源索引
- 一个
match_field
,用于匹配传入文档的源索引中的字段 - 您想要附加到传入文档的源索引中的丰富字段
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
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?wait_for_completion=false
使用 创建或更新管道 API 创建摄取管道。在管道中,添加一个 丰富处理器,其中包含
- 您的丰富策略。
- 用于匹配丰富索引中文档的传入文档的
field
。 - 用于存储附加到传入文档的丰富数据的
target_field
。此字段包含在您的丰富策略中指定的match_field
和enrich_fields
。
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": "[email protected]" }
要验证丰富处理器是否匹配并附加了适当的字段数据,请使用 获取 API 查看已索引的文档。
response = client.get( index: 'my-index-000001', id: 'my_id' ) puts 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]" } }