Tablestore:ソートとページング

ScoreSort

BM25 アルゴリズムで計算された関連性スコアに基づいて、結果をソートします。この方法は、全文検索など、関連性ランキングが必要なシナリオに適しています。

searchQuery := search.NewSearchQuery()
searchQuery.SetSort(&search.Sort{
    []search.Sorter{
        &search.ScoreSort{
            Order: search.SortOrder_DESC.Enum(), // スコアの降順でソートします
        },
    },
})

PrimaryKeySort

プライマリキー に基づいて結果をソートします。これは、一意の識別子でアイテムを順序付ける場合に便利です。

searchQuery := search.NewSearchQuery()
searchQuery.SetSort(&search.Sort{
    []search.Sorter{
        &search.PrimaryKeySort{
            Order: search.SortOrder_ASC.Enum(),
        },
    },
})

FieldSort

特定の フィールド の値に基づいて結果をソートします。この方法は、販売数やページビューなどの属性でアイテムをソートする必要がある e コマースやソーシャルメディアアプリケーションで便利です。

// Col_Long フィールドに基づいて結果を降順にソートします
searchQuery.SetSort(&search.Sort{
    []search.Sorter{
        &search.FieldSort{
            FieldName: "Col_Long",
            Order:     search.SortOrder_DESC.Enum(),
        },
    },
})

searchQuery.SetSort(&search.Sort{
    []search.Sorter{
        &search.FieldSort{
            FieldName: "col1",
            Order:     search.SortOrder_ASC.Enum(),
        },
        &search.FieldSort{
            FieldName: "col2",
            Order:     search.SortOrder_DESC.Enum(),
        },
    },
})

GeoDistanceSort

地理的な地点からの距離に基づいて結果をソートします。これは、現在地から近いレストランを距離順にソートするなど、マッピングやロジスティクスのアプリケーションで便利です。

searchQuery.SetSort(&search.Sort{
    []search.Sorter{
        &search.GeoDistanceSort{
            FieldName: "location",   // GeoPoint フィールドの名前を指定します
            Points:    []string{"40,-70"}, // 中心点を指定します
        },
    },
})

Limit と Offset によるページング

Limit と Offset を使用してページングできます。Limit と Offset の合計は 100,000 以下である必要があり、Limit の最大値は 100 です。

これらのパラメータを指定しない場合、Limit のデフォルト値は 10、Offset のデフォルト値は 0 です。

searchQuery := search.NewSearchQuery()
searchQuery.SetLimit(10)
searchQuery.SetOffset(10) 

トークンによるページング

ディープページングの場合は token を使用してください。この方法には深さの制限がありません。

クエリが単一のレスポンスに収まりきらない結果を返す場合、サーバーは NextToken を提供します。このトークンを後続のリクエストで使用して、次のページを取得します。

デフォルトでは、トークンベースのページングは前方へのみ移動できます。ただし、token はクエリセッション中有効であるため、以前のトークンをキャッシュすることで後方へのページングも実装できます。

token を使用する場合、前回のリクエストのソート方法が自動的に適用されます。そのため、トークンベースのリクエストでは Sort または Offset パラメータを指定できません。データは順次、1 ページずつのみ読み取ることができます。

/**
 * トークンを使用してページごとにデータを読み取ります。
 * SearchResponse に NextToken が含まれている場合、それを使用して次のクエリを開始できます。
 * nil の NextToken は、一致するすべてのデータが取得されたことを示します。
 */
func QueryRowsWithToken(client *tablestore.TableStoreClient, tableName string, indexName string) {
    querys := []search.Query{
        &search.MatchAllQuery{},
        &search.TermQuery{
            FieldName: "Col_Keyword",
            Term:      "tablestore",
        },
    }
    for _, query := range querys {
        fmt.Printf("Test query: %#v\n", query)
        searchRequest := &tablestore.SearchRequest{}
        searchRequest.SetTableName(tableName)
        searchRequest.SetIndexName(indexName)
        searchQuery := search.NewSearchQuery()
        searchQuery.SetQuery(query)
        searchQuery.SetLimit(10)
        searchQuery.SetGetTotalCount(true)
        searchRequest.SetSearchQuery(searchQuery)
        searchResponse, err := client.Search(searchRequest)
        if err != nil {
            fmt.Printf("%#v", err)
            return
        }
        rows := searchResponse.Rows
        requestCount := 1
        for searchResponse.NextToken != nil {           
            {  
	              // NextToken を永続化または送信するには、Base64 エンコードを使用します。
	              // トークンはバイトスライスであり、文字列ではないため、直接変換するとデータ損失が発生します。
	              tokenAsString := base64.StdEncoding.EncodeToString(searchResponse.NextToken)
	              // 文字列をバイトスライスにデコードします。
	              tokenAsByte, err := base64.StdEncoding.DecodeString(tokenAsString)
	              if err != nil {
		                fmt.Printf("len:%d, %#v",len(tokenAsByte), err)
		                return
	              }
            }
            searchQuery.SetToken(searchResponse.NextToken)
            searchResponse, err = client.Search(searchRequest)
            if err != nil {
                fmt.Printf("%#v", err)
                return
            }
            requestCount++
            for _, r := range searchResponse.Rows {
                rows = append(rows, r)
            }
        }
        fmt.Println("IsAllSuccess: ", searchResponse.IsAllSuccess)
        fmt.Println("TotalCount: ", searchResponse.TotalCount)
        fmt.Println("RowsSize: ", len(rows))
        fmt.Println("RequestCount: ", requestCount)
    }
}