本文為英文版的機器翻譯版本，如內容有任何歧義或不一致之處，概以英文版為準。

OpenSearch Service 連線

您可以使用 AWS 適用於 Spark 的 Glue，在 Glue 4.0 和更新版本中讀取和寫入 OpenSearch Service AWS 中的資料表。您可以使用 OpenSearch 查詢定義要從 OpenSearch Service 讀取的內容。您可以使用 AWS Secrets Manager 透過 Glue 連線存放於 中的 HTTP AWS 基本身分驗證登入資料來連線至 OpenSearch Service。此功能與 OpenSearch Service Serverless 不相容。

如需有關 OpenSearch Service 的詳細資訊，請參閱 Amazon OpenSearch Service 文件。

設定 OpenSearch Service 連線

若要從 Glue AWS 連線至 OpenSearch Service，您需要在 AWS Secrets Manager 秘密中建立和存放您的 OpenSearch Service 登入資料，然後將該秘密與 OpenSearch Service AWS Glue 連線建立關聯。

先決條件：

建立 AWS Glue OpenSearch Service 連線後，您必須先執行下列步驟，才能執行 Glue AWS 任務：

從 OpenSearch Service 索引讀取

先決條件：

此範例會從 Amazon OpenSearch Service 讀取索引。您將需要提供 pushdown 參數。

例如：

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

您也可提供查詢字串，以篩選 DynamicFrame 中傳回的結果。您將需要設定 opensearch.query。

opensearch.query 可接受 URL 查詢參數字串 queryString 或查詢 DSL JSON 物件 queryObject。如需有關查詢 DSL 的詳細資訊，請參閱《OpenSearch 文件》中的查詢 DSL。若要提供 URL 查詢參數字串，請在查詢前面加上 ?q= 字首 (如同您會在完整 URL 中加上字首)。若要提供查詢 DSL 物件，請將 JSON 物件字串逸出後再進行。

例如：

            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",
    }
)

如需有關如何在其特定語法之外建立查詢的詳細資訊，請參閱《OpenSearch 文件》中的查詢字串語法。

從包含陣列類型資料的 OpenSearch 集合讀取時，您必須使用 opensearch.read.field.as.array.include 參數指定方法呼叫中哪些欄位是陣列類型。

例如，在閱讀下列文件時，您會遇到 genre 和 actor 陣列欄位：

{
    "_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"
    }
}

在此情況下，您會在方法呼叫中包含那些欄位名稱。例如：

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

如果在文件結構中將陣列欄位巢狀化，請使用點標記法來表示："genre,actor,foo.bar.baz"。這將透過內含嵌入文件 bar 的 foo 嵌入文件，指定來源文件中包含的 baz 陣列。

寫入 OpenSearch Service 資料表

此範例會從現有的 DynamicFrame dynamicFrame 將資訊寫入 OpenSearch Service。如果索引已有資訊， AWS Glue 將從您的 DynamicFrame 附加資料。您將需要提供 pushdown 參數。

先決條件：

例如：

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

OpenSearch Service 連線選項參考