Tablestore:時系列テーブルの作成

分析ストアなしで時系列テーブルを作成する

次のサンプルコードは、時系列テーブルを作成する方法の例です。

/**
 * CreateTimeseriesTableSample は時系列テーブルを作成します。timeseriesTableName で時系列テーブルの名前を、timeTolive で時系列テーブルの TTL を指定します。
 */
func CreateTimeseriesTableSample(client *tablestore.TimeseriesClient, timeseriesTableName string , timeToLive int64) {
    fmt.Println("[Info]: Begin to create timeseries table: " , timeseriesTableName)

    // 時系列テーブルの設定情報を構築します。
    timeseriesTableOptions := tablestore.NewTimeseriesTableOptions(timeToLive) 

    // テーブルのメタデータ情報を構築します。
    // 時系列テーブルの名前を指定します。
    timeseriesTableMeta := tablestore.NewTimeseriesTableMeta(timeseriesTableName) 
    // 時系列テーブルの設定情報を指定します。
    timeseriesTableMeta.SetTimeseriesTableOptions(timeseriesTableOptions)    

    // 時系列テーブルを作成するリクエストを構築します。
    createTimeseriesTableRequest := tablestore.NewCreateTimeseriesTableRequest()   
    createTimeseriesTableRequest.SetTimeseriesTableMeta(timeseriesTableMeta)
    // デフォルトの分析ストアを作成しないことを指定します。
    createTimeseriesTableRequest.SetEnableAnalyticalStore(false)  

    // クライアントを呼び出して時系列テーブルを作成します。
    createTimeseriesTableResponse , err := client.CreateTimeseriesTable(createTimeseriesTableRequest) 
    if err != nil {
        fmt.Println("[Error]: Failed to create timeseries table with error: " , err)
        return
    }
    fmt.Println("[Info]: CreateTimeseriesTable finished! RequestId: " , createTimeseriesTableResponse.RequestId)
}

時系列テーブルと分析ストアを作成する

時系列テーブルを作成する際、デフォルトの分析ストアまたはカスタム分析ストアを作成できます。

/**
 * CreateTimeseriesTableSample は時系列テーブルを作成します。timeseriesTableName で時系列テーブルの名前を、timeTolive で時系列テーブルの TTL を指定します。
 */
func CreateTimeseriesTableSample(client *tablestore.TimeseriesClient, timeseriesTableName string , timeToLive int64) {
    fmt.Println("[Info]: Begin to create timeseries table: " , timeseriesTableName)

    // 時系列テーブルの設定情報を構築します。
    timeseriesTableOptions := tablestore.NewTimeseriesTableOptions(timeToLive)        

    // テーブルのメタデータ情報を構築します。
    // 時系列テーブルの名前を指定します。
    timeseriesTableMeta := tablestore.NewTimeseriesTableMeta(timeseriesTableName)  
    // 時系列テーブルの設定情報を指定します。
    timeseriesTableMeta.SetTimeseriesTableOptions(timeseriesTableOptions)      

    // 時系列テーブルを作成するリクエストを構築します。
    createTimeseriesTableRequest := tablestore.NewCreateTimeseriesTableRequest()    
    createTimeseriesTableRequest.SetTimeseriesTableMeta(timeseriesTableMeta)

    // クライアントを呼び出して時系列テーブルを作成します。
    createTimeseriesTableResponse , err := client.CreateTimeseriesTable(createTimeseriesTableRequest)    
    if err != nil {
        fmt.Println("[Error]: Failed to create timeseries table with error: " , err)
        return
    }
    fmt.Println("[Info]: CreateTimeseriesTable finished! RequestId: " , createTimeseriesTableResponse.RequestId)
}

/**
 * CreateTimeseriesTableSample は時系列テーブルを作成します。timeseriesTableName で時系列テーブルの名前を、timeTolive で時系列テーブルの TTL を指定します。この例では、`test_analytical_store` という名前の分析ストアを作成します。
 */
func CreateTimeseriesTableSample(client *tablestore.TimeseriesClient, timeseriesTableName string , timeToLive int64) {
    fmt.Println("[Info]: Begin to create timeseries table: " , timeseriesTableName)

    // 時系列テーブルの設定情報を構築します。
    timeseriesTableOptions := tablestore.NewTimeseriesTableOptions(timeToLive)    

    // テーブルのメタデータ情報を構築します。
    // 時系列テーブルの名前を指定します。
    timeseriesTableMeta := tablestore.NewTimeseriesTableMeta(timeseriesTableName)  
    // 時系列テーブルの設定情報を指定します。
    timeseriesTableMeta.SetTimeseriesTableOptions(timeseriesTableOptions)  

    // 時系列テーブルを作成するリクエストを構築します。
    createTimeseriesTableRequest := tablestore.NewCreateTimeseriesTableRequest() 
    createTimeseriesTableRequest.SetTimeseriesTableMeta(timeseriesTableMeta)

    // 分析ストアの設定情報を構築します。
    createTimeseriesTableRequest.SetAnalyticalStores([]*tablestore.TimeseriesAnalyticalStore{
        tablestore.NewTimeseriesAnalyticalStore("test_analytical_store"),
    })

    // クライアントを呼び出して時系列テーブルを作成します。
    createTimeseriesTableResponse , err := client.CreateTimeseriesTable(createTimeseriesTableRequest) 
    if err != nil {
        fmt.Println("[Error]: Failed to create timeseries table with error: " , err)
        return
    }
    fmt.Println("[Info]: CreateTimeseriesTable finished! RequestId: " , createTimeseriesTableResponse.RequestId)
}

カスタム時系列識別子とカスタムデータフィールドを時系列テーブルのプライマリキー列として指定する

次のサンプルコードは、時系列識別子が pk1 と pk2 で構成され、field1 (Integer)、field2 (String)、field3 (Binary) のデータフィールドがプライマリキー列として指定される時系列テーブルを作成する方法の例です。

/**
 * CreateTimeseriesTableSample は時系列テーブルを作成します。timeseriesTableName で時系列テーブルの名前を、timeTolive で時系列テーブルの TTL を指定します。
 */
func CreateTimeseriesTableSample(client *tablestore.TimeseriesClient, timeseriesTableName string, timeToLive int64) {
	fmt.Println("[Info]: Begin to create timeseries table: ", timeseriesTableName)

	timeseriesTableOptions := tablestore.NewTimeseriesTableOptions(timeToLive)
	timeseriesTableMeta := tablestore.NewTimeseriesTableMeta(timeseriesTableName)
	timeseriesTableMeta.SetTimeseriesTableOptions(timeseriesTableOptions)
	// カスタム時系列識別子を追加します。
	timeseriesTableMeta.AddTimeseriesKey("pk1")
	timeseriesTableMeta.AddTimeseriesKey("pk2")
	// プライマリキー列として指定するデータフィールドを追加します。
	timeseriesTableMeta.AddFieldPrimaryKey("field1", tablestore.PrimaryKeyType_INTEGER)
	timeseriesTableMeta.AddFieldPrimaryKey("field2", tablestore.PrimaryKeyType_STRING)
	timeseriesTableMeta.AddFieldPrimaryKey("field3", tablestore.PrimaryKeyType_BINARY)
	// 時系列テーブルを作成するリクエストを構築します。
	createTimeseriesTableRequest := tablestore.NewCreateTimeseriesTableRequest()
	createTimeseriesTableRequest.SetTimeseriesTableMeta(timeseriesTableMeta)

	createTimeseriesTableResponse, err := client.CreateTimeseriesTable(createTimeseriesTableRequest)
	if err != nil {
		fmt.Println("[Error]: Failed to create timeseries table with error: ", err)
		return
	}
	fmt.Println("[Info]: CreateTimeseriesTable finished! RequestId: ", createTimeseriesTableResponse.RequestId)
}

時系列テーブルと Lastpoint インデックスを作成する

次のサンプルコードは、時系列テーブルと、その時系列テーブルに対して index1 という名前の Lastpoint インデックスを同時に作成する方法の例です。

func createTimeseriesTable(client *tablestore.TimeseriesClient) {
	timeseriesTableMeta := tablestore.NewTimeseriesTableMeta("test_timeseries_table")
	timeseriesTableMeta.SetTimeseriesTableOptions(tablestore.NewTimeseriesTableOptions(-1))
	request := tablestore.NewCreateTimeseriesTableRequest()
	request.SetTimeseriesTableMeta(timeseriesTableMeta)
	request.SetLastpointIndexNames([]string{"index1"})
	_, err := client.CreateTimeseriesTable(request)
	if err != nil {
		log.Fatal(err)
	}
}