Tablestore:Lastpoint インデックスデータを取得する

1. 検索インデックスを作成する

次の例では、Lastpoint インデックスの検索インデックスを作成します。サンプルのシナリオとデータについては、「付録」をご参照ください。

func createSearchIndex(client *tablestore.TableStoreClient) {
	request := &tablestore.CreateSearchIndexRequest{}
	request.TableName = "<LASTPOINT_INDEX_NAME>" // Lastpoint インデックス名
	request.IndexName = "<SEARCH_INDEX_NAME>" // 検索インデックス名
	request.IndexSchema = &tablestore.IndexSchema{
		FieldSchemas: []*tablestore.FieldSchema{
			{
				FieldName:        proto.String("_#h"), // プライマリキーのハッシュ値
				FieldType:        tablestore.FieldType_KEYWORD,
				Index:            proto.Bool(true),
				EnableSortAndAgg: proto.Bool(true),
			},
			{
				FieldName:        proto.String("_m_name"), // メジャー名
				FieldType:        tablestore.FieldType_KEYWORD,
				Index:            proto.Bool(true),
				EnableSortAndAgg: proto.Bool(true),
			},
			{
				FieldName:        proto.String("_data_source"), // データソース
				FieldType:        tablestore.FieldType_KEYWORD,
				Index:            proto.Bool(true),
				EnableSortAndAgg: proto.Bool(true),
			},
			{
				FieldName:        proto.String("_tags"), // タグ
				FieldType:        tablestore.FieldType_KEYWORD,
				Index:            proto.Bool(true),
				EnableSortAndAgg: proto.Bool(true),
				IsArray:          proto.Bool(true), // タグは配列として定義されている
			},
			{
				FieldName:        proto.String("_time"), // データの報告時間
				FieldType:        tablestore.FieldType_LONG,
				Index:            proto.Bool(true),
				EnableSortAndAgg: proto.Bool(true),
			},
			{
				FieldName:        proto.String("gps"), // GPS 座標
				FieldType:        tablestore.FieldType_GEO_POINT,
				Index:            proto.Bool(true),
				EnableSortAndAgg: proto.Bool(true),
			},
			{
				FieldName:        proto.String("speed"), // 速度
				FieldType:        tablestore.FieldType_DOUBLE,
				Index:            proto.Bool(true),
				EnableSortAndAgg: proto.Bool(true),
			},
			{
				FieldName:        proto.String("status"), // 状態
				FieldType:        tablestore.FieldType_KEYWORD,
				Index:            proto.Bool(true),
				EnableSortAndAgg: proto.Bool(true),
			},
			{
				FieldName:        proto.String("total_mileage"), // 総走行距離
				FieldType:        tablestore.FieldType_LONG,
				Index:            proto.Bool(true),
				EnableSortAndAgg: proto.Bool(true),
			},
			{
				FieldName:        proto.String("remaining_mileage"), // 残り走行距離
				FieldType:        tablestore.FieldType_LONG,
				Index:            proto.Bool(true),
				EnableSortAndAgg: proto.Bool(true),
			},
		},
	}
	_, err := client.CreateSearchIndex(request)
	if err != nil {
		fmt.Println("Failed to create searchIndex with error:", err) // 検索インデックスの作成に失敗しました
		return
	}
}

2. 検索インデックスを使用してデータを取得する

次の例は、検索インデックスの範囲クエリ機能の使用方法を示しています。

この例では、速度の値が 20.0 より大きい Lastpoint インデックスから行を取得します。

func RangeQuery(client *tablestore.TableStoreClient, lastpointName string, indexName string) {
	searchRequest := &tablestore.SearchRequest{}
	searchRequest.SetTableName(lastpointName) // Lastpoint インデックス名を設定
	searchRequest.SetIndexName(indexName)   // 検索インデックス名を設定
	searchQuery := search.NewSearchQuery()
	rangeQuery := &search.RangeQuery{}     // クエリタイプを RangeQuery に設定します。
	rangeQuery.FieldName = "speed"       // 一致するフィールドを設定します
	rangeQuery.GT(20.0)                  // このフィールドの範囲条件を 20.0 より大きく設定します。
	searchQuery.SetQuery(rangeQuery)
	// 速度列で降順にソートします。
	searchQuery.SetSort(&search.Sort{
		[]search.Sorter{
			&search.FieldSort{
				FieldName: "speed",
				Order:     search.SortOrder_DESC.Enum(),
			},
		},
	})
	searchRequest.SetSearchQuery(searchQuery)
	searchRequest.SetColumnsToGet(&tablestore.ColumnsToGet{
		ReturnAll: true, // すべての列を取得
	})
	searchResponse, err := client.Search(searchRequest)
	if err != nil {
		fmt.Printf("%#v", err)
		return
	}
	fmt.Println("IsAllSuccess: ", searchResponse.IsAllSuccess) // クエリ条件を満たすすべての行が返されたかどうかを確認します。
	fmt.Println("RowCount: ", len(searchResponse.Rows))      // 取得した行数
	for _, row := range searchResponse.Rows {
		jsonBody, err := json.Marshal(row)
		if err != nil {
			panic(err)
		}
		fmt.Println("Row: ", string(jsonBody)) // 各行の JSON 形式のデータ
	}
}