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

OpenSearch Koneksi layanan

Anda dapat menggunakan AWS Glue for Spark untuk membaca dan menulis ke tabel di OpenSearch Layanan di AWS Glue 4.0 dan versi yang lebih baru. Anda dapat menentukan apa yang akan dibaca dari OpenSearch Layanan dengan OpenSearch kueri. Anda terhubung ke OpenSearch Layanan menggunakan kredentif otentikasi dasar HTTP yang disimpan AWS Secrets Manager melalui koneksi AWS Glue. Fitur ini tidak kompatibel dengan OpenSearch Layanan tanpa server.

Untuk informasi selengkapnya tentang OpenSearch Layanan Amazon, lihat dokumentasi OpenSearch Layanan Amazon.

Mengkonfigurasi koneksi OpenSearch Layanan

Untuk terhubung ke OpenSearch Service from AWS Glue, Anda harus membuat dan menyimpan kredenSIAL OpenSearch Layanan Anda secara AWS Secrets Manager rahasia, lalu mengaitkan rahasia itu dengan koneksi OpenSearch Service AWS Glue.

Prasyarat:

Setelah membuat koneksi OpenSearch Layanan AWS Glue, Anda harus melakukan langkah-langkah berikut sebelum menjalankan pekerjaan AWS Glue Anda:

Membaca dari indeks OpenSearch Layanan

Prasyarat:

Contoh ini membaca indeks dari Amazon OpenSearch Service. Anda harus memberikan pushdown parameter.

Contoh:

opensearch_read = glueContext.create_dynamic_frame.from_options(
    connection_type="opensearch",
    connection_options={
        "connectionName": "connectionName",
        "opensearch.resource": "aosIndex",
        "pushdown": "true",
    }
)

Anda juga dapat memberikan string kueri untuk memfilter hasil yang dikembalikan di DynamicFrame. Anda perlu mengkonfigurasiopensearch.query.

opensearch.querydapat mengambil string parameter kueri URL queryString atau objek queryObject DSL JSON query. Untuk informasi selengkapnya tentang kueri DSL, lihat Query DSL dalam dokumentasi OpenSearch. Untuk menyediakan string parameter kueri URL, tambahkan kueri ?q= Anda, seperti yang Anda lakukan di URL yang memenuhi syarat. Untuk menyediakan objek DSL query, string keluar dari objek JSON sebelum menyediakannya.

Contoh:

            queryObject = "{ "query": { "multi_match": { "query": "Sample", "fields": [ "sample" ] } } }"
            queryString = "?q=queryString"
            
            opensearch_read_query = glueContext.create_dynamic_frame.from_options(
    connection_type="opensearch",
    connection_options={
        "connectionName": "connectionName",
        "opensearch.resource": "aosIndex",
        "opensearch.query": queryString,
        "pushdown": "true",
    }
)

Untuk informasi selengkapnya tentang cara membuat kueri di luar sintaks spesifiknya, lihat Sintaks string kueri dalam OpenSearch dokumentasi.

Saat membaca dari OpenSearch koleksi yang berisi data tipe array, Anda harus menentukan bidang mana yang merupakan tipe array dalam panggilan metode Anda menggunakan opensearch.read.field.as.array.include parameter.

Misalnya, saat membaca dokumen berikut, Anda akan menemukan bidang actor array genre dan:

{
    "_index": "movies",
    "_id": "2",
    "_version": 1,
    "_seq_no": 0,
    "_primary_term": 1,
    "found": true,
    "_source": {
        "director": "Frankenheimer, John",
        "genre": [
            "Drama",
            "Mystery",
            "Thriller",
            "Crime"
        ],
        "year": 1962,
        "actor": [
            "Lansbury, Angela",
            "Sinatra, Frank",
            "Leigh, Janet",
            "Harvey, Laurence",
            "Silva, Henry",
            "Frees, Paul",
            "Gregory, James",
            "Bissell, Whit",
            "McGiver, John",
            "Parrish, Leslie",
            "Edwards, James",
            "Flowers, Bess",
            "Dhiegh, Khigh",
            "Payne, Julie",
            "Kleeb, Helen",
            "Gray, Joe",
            "Nalder, Reggie",
            "Stevens, Bert",
            "Masters, Michael",
            "Lowell, Tom"
        ],
        "title": "The Manchurian Candidate"
    }
}

Dalam hal ini, Anda akan menyertakan nama-nama bidang tersebut dalam panggilan metode Anda. Contoh:

"opensearch.read.field.as.array.include": "genre,actor"

Jika bidang array Anda bersarang di dalam struktur dokumen Anda, rujuknya menggunakan notasi titik:"genre,actor,foo.bar.baz". Ini akan menentukan array yang diser baz takan dalam dokumen sumber Anda melalui dokumen tertanam foo yang berisi dokumen yang disematkanbar.

Menulis ke tabel OpenSearch Layanan

Contoh ini menulis informasi dari yang sudah ada DynamicFrame, dynamicFrame ke OpenSearch Layanan. Jika indeks sudah memiliki informasi, AWS Glue akan menambahkan data dari Anda DynamicFrame. Anda harus memberikan pushdown parameter.

Prasyarat:

Contoh:

glueContext.write_dynamic_frame.from_options(
    frame=dynamicFrame,
    connection_type="opensearch",
    connection_options={
      "connectionName": "connectionName",
      "opensearch.resource": "aosIndex",
    },
)

OpenSearch Referensi opsi koneksi layanan