Tablestore:結果のソートとページネーション

検索リクエスト

search メソッドには次のパラメーターが含まれます。

クエリ設定

search_query は SearchQuery タイプであり、次のソートおよびページネーションパラメーターが含まれます。

ソート設定

search_query.sort は Sort タイプであり、次のパラメーターが含まれます。

関連度スコアソート

search_query.sort.sorters[] が ScoreSort タイプの場合、行は関連度スコアでソートされます。ScoreSort には次のパラメーターが含まれます。

プライマリキーソート

search_query.sort.sorters[] が PrimaryKeySort タイプの場合、行はプライマリキーでソートされます。PrimaryKeySort には次のパラメーターが含まれます。

フィールドソート

search_query.sort.sorters[] が FieldSort タイプの場合、行はフィールド値でソートされます。FieldSort には次のパラメーターが含まれます。

Nestedフィルター

search_query.sort.sorters[].nested_filter は NestedFilter タイプであり、 FieldSort または GeoDistanceSort で使用でき、次のパラメーターが含まれます。

地理距離ソート

search_query.sort.sorters[] が GeoDistanceSort タイプの場合、行は地理的ポイントとターゲットポイント間の距離でソートされます。GeoDistanceSort には次のパラメーターが含まれます。

返す列

columns_to_get は ColumnsToGet タイプであり、次のパラメーターが含まれます。

タプル互換レスポンス

Tablestore SDK for Python 5.2.0 以降、検索 API はタプルの代わりにレスポンスオブジェクトを返します。バージョン 5.1.0 以前はタプルを直接返します。バージョン 5.2.1 以降では、SearchResponse.v1_response() を呼び出して、以前のバージョンと互換性のあるタプルを取得できます。新しいコードでは、レスポンスフィールドが拡張された場合のアンパックエラーを回避するために、SearchResponse 属性に直接アクセスしてください。

(
    rows,
    next_token,
    total_count,
    is_all_succeed,
    agg_results,
    group_by_results,
    search_hits,
) = response.v1_response()

地理距離によるソート

次の例では、 location と 30.25,120.16 の間の球面距離に基づき、近い順に結果を返します。

sort = Sort([
    GeoDistanceSort(
        "location",
        ["30.25,120.16"],
        sort_order=SortOrder.ASC,
        sort_mode=SortMode.MIN,
        geo_distance_type=GeoDistanceType.ARC,
    )
])
response = client.search(
    "example_table",
    "example_index",
    SearchQuery(MatchAllQuery(), sort=sort, limit=10),
)
print(response.rows)

next_tokenを使用したページネーション

最初のリクエストでソート順を指定します。後続のリクエストでは、トークンが空になるまで、前のレスポンスからの next_token と同じクエリ条件のみを渡します。

query = MatchAllQuery()
response = client.search(
    "example_table",
    "example_index",
    SearchQuery(query, sort=Sort([PrimaryKeySort()]), limit=100),
)
all_rows = list(response.rows)

while response.next_token:
    response = client.search(
        "example_table",
        "example_index",
        SearchQuery(query, next_token=response.next_token, limit=100),
    )
    all_rows.extend(response.rows)

print(len(all_rows))