Terjemahan disediakan oleh mesin penerjemah. Jika konten terjemahan yang diberikan bertentangan dengan versi bahasa Inggris aslinya, utamakan versi bahasa Inggris.

# Membuat pipeline di Amazon OpenSearch Service
<a name="managed-opensearch-plugin-pipeline-example"></a>

Setelah [menginstal plugin Amazon Personalize Search Ranking](open-search-install-managed.md), Anda siap mengonfigurasinya dengan membuat pipeline OpenSearch pencarian. 

*Pipeline pencarian* adalah sekumpulan prosesor permintaan dan respons yang berjalan secara berurutan sesuai urutan yang Anda buat. Saat Anda membuat pipeline pencarian untuk plugin, Anda menentukan prosesor `personalized_search_ranking` respons. Untuk informasi tentang saluran pipa pencarian, lihat [Cari saluran pipa](https://opensearch.org/docs/latest/search-plugins/search-pipelines/index/). 

Setelah membuat pipeline pencarian dengan prosesor `personalized_search_ranking` respons, Anda siap untuk mulai menerapkan plugin ke OpenSearch kueri. Anda dapat menerapkannya ke OpenSearch indeks atau OpenSearch kueri individual. Untuk informasi selengkapnya, lihat [Menerapkan plugin](managed-apply-plugin.md). 

Anda dapat menggunakan kode Python berikut untuk membuat pipeline pencarian dengan prosesor `personalized_search_ranking` respons pada domain OpenSearch Layanan. Ganti `domain endpoint` dengan URL endpoint domain Anda. Sebagai contoh: `https://<domain name>.<AWS region>.es-staging.amazonaws.com`. Untuk penjelasan lengkap dari setiap `personalized_search_ranking` parameter, lihat[Bidang untuk prosesor `personalized_search_ranking` respons](opensearch-plugin-pipeline-fields.md). 

```
import requests
from requests_auth_aws_sigv4 import AWSSigV4

domain_endpoint = 'domain endpoint'
pipeline_name = 'pipeline name'
url = f'{domain_endpoint}/_search/pipeline/{pipeline_name}'
auth = AWSSigV4('es')

headers = {'Content-Type': 'application/json'}

body = {
  "description": "A pipeline to apply custom re-ranking from Amazon Personalize",
  "response_processors": [
    {
      "personalized_search_ranking" : {
        "campaign_arn" : "Amazon Personalize Campaign ARN",
        "item_id_field" : "productId",
        "recipe" : "aws-personalized-ranking-v2",
        "weight" : "0.3",
        "tag" : "personalize-processor",
        "iam_role_arn": "Role ARN",
        "aws_region": "AWS region",
        "ignore_failure": true
    }
  ]
}
try:
    response = requests.put(url, auth=auth, json=body, headers=headers, verify=False)
    print(response.text)
except Exception as e:
    print(f"Error: {e}")
```