OpenSearch:Perbarui data

Langkah 1: Tambahkan tabel

Untuk mengimpor set data lengkap, buat tabel dan konfigurasikan sumber data seperti OSS, MaxCompute, atau Data Lake Formation (DLF).

Pada panel navigasi kiri halaman Detail Instans, klik Table Management, lalu klik Add Table.

Untuk informasi lebih lanjut tentang pembuatan tabel, lihat topik berikut:

• Sumber data MaxCompute + API

• Sumber data API

• Sumber data OSS + API

• Sinkronkan data vektor dari OpenLake-DLF ke OpenSearch Vector Search Edition

Setelah Anda mengonfigurasi tabel, Anda dapat menggunakan API untuk memasukkan data begitu statusnya berubah menjadi In Use.

Pada daftar tabel, kolom Status akan menampilkan In Use.

Langkah 2: Konfigurasikan daftar putih akses publik

Jika Anda mengakses instans dari VPC dan vSwitch yang sama, Anda dapat melewati langkah ini.

Jika Anda mengakses instans dari lingkungan on-premises atau internet publik, lihat Konfigurasikan daftar putih akses publik.

Langkah 3: Dorong data ke tabel

Contoh berikut menggunakan Python.

Instal dependensi:

pip install alibabacloud-ha3engine-vector

Kode contoh:

# -*- coding: utf-8 -*-

from alibabacloud_ha3engine_vector import models, client
from Tea.exceptions import TeaException, RetryError

Config = models.Config(
    endpoint="<your_api_endpoint>",        # Titik akhir API instans Anda. Anda dapat menemukannya di halaman Detail Instans di bawah API Endpoint.
                                        # Hapus awalan "http://".
                                        # Untuk akses dari on-premises atau internet publik, gunakan titik akhir publik.
                                        # Untuk akses dalam VPC yang sama, gunakan titik akhir pribadi.
    instance_id="<your_instance_id>",      # ID instans. Anda dapat menemukannya di pojok kiri atas halaman Detail Instans. Contoh: ha-cn-i7*****605
    protocol="http",
    access_user_name="<your_username>",    # Username untuk akses API. Anda dapat menemukannya di halaman Detail Instans di bawah API Endpoint.
    access_pass_word="<your_password>"     # Password untuk username tersebut. Anda dapat mengelolanya di halaman Detail Instans di bawah API Endpoint.

)

# Inisialisasi client engine.
ha3EngineClient = client.Client(Config)

def push():
    # Nama tabel untuk mendorong dokumen harus dalam format <instance_id>_<table_name>.
    tableName = "<instance_id>_<table_name>";

    try:
        # Tambahkan dokumen. Ini adalah operasi upsert: jika dokumen dengan kunci primer yang sama sudah ada,
        # dokumen tersebut akan ditimpa; jika tidak, dokumen baru akan ditambahkan.
        # =====================================================
        # Definisikan bidang-bidang untuk dokumen.
        add2DocumentFields = {
            "id": 1,                          # Kunci primer (INT).
            "cate_id": "123",                 # Bidang bernilai tunggal (STRING).
            "vector": "a\x1Db\x1Dc\x1Dd"      # Bidang bernilai ganda (STRING). Nilai dipisahkan oleh karakter \x1D.
        }
        
        # Susun struktur dokumen untuk permintaan.
        add2Document = {
            "fields": add2DocumentFields,
            "cmd": "add"                      # Gunakan perintah "add" untuk menyisipkan atau memperbarui dokumen.
        }

        optionsHeaders = {}
        # Badan permintaan berupa array yang berisi satu atau beberapa operasi dokumen.
        documentArrayList = []
        documentArrayList.append(add2Document)
        pushDocumentsRequest = models.PushDocumentsRequest(optionsHeaders, documentArrayList)

        # Tentukan bidang kunci primer untuk dokumen-dokumen tersebut.
    	pkField = "id"
        # Kirim permintaan dengan opsi waktu proses default.
        response = ha3EngineClient.push_documents(tableName, pkField, pushDocumentsRequest)
        print(response.body)
    except TeaException as e:
        print(f"Terjadi error API: {e}")
    except RetryError as e:
        print(f"Terjadi error koneksi: {e}")

if __name__ == "__main__":
    push()</table_name></instance_id>

Catatan:

• Saat menggunakan SDK Python, hapus awalan http:// dari titik akhir.

• Untuk akses dari lingkungan on-premises atau internet publik, gunakan titik akhir publik (yang mengandung public) dan pastikan akses publik telah diaktifkan serta daftar putih telah dikonfigurasi. Untuk akses dari dalam VPC yang sama (misalnya, dari Instance ECS), gunakan titik akhir pribadi.

• Parameter tableName dalam permintaan menggunakan format <instance_id>_<table_name>, misalnya, tableName=ha-cn-zpr3dgzxg04_test_vector_api.

Tanggapan {"status": "OK", "code": 200} menunjukkan bahwa permintaan berhasil.

Langkah 4: Verifikasi data

Untuk memverifikasi data, jalankan kueri di tool Query Test menggunakan kunci primer atau vektor.

Pada bilah navigasi kiri, klik Vector Management > Query Test, lalu pilih tab Vector Query. Pada daftar drop-down Table Name, pilih tabel target, masukkan permintaan kueri dalam format JSON di area pengeditan sebelah kiri (termasuk parameter seperti vector, topK, indexName, dan includeVector), lalu klik Search. Hasil kueri dan waktu yang diperlukan akan ditampilkan di sebelah kanan.

Untuk informasi lebih lanjut tentang sintaksis kueri, lihat Kueri berbasis kunci primer dan Kueri berbasis vektor.

Referensi SDK lainnya

Untuk contoh SDK dalam bahasa pemrograman lain, lihat Kueri data.