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
Setelah menginstal plugin Amazon Personalize Search Ranking, 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
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.
Anda dapat menggunakan kode Python berikut untuk membuat pipeline pencarian dengan prosesor personalized_search_ranking
respons pada domain OpenSearch Layanan. Ganti domain endpoint
dengan endpoint URL domain Anda. Sebagai contoh: https://<domain
name>.<AWS region>.es-staging.amazonaws.com
. Untuk penjelasan lengkap dari setiap personalized_search_ranking
parameter, lihatBidang untuk prosesor personalized_search_ranking respons.
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", "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}")