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