Dis-go-sdk使用样例

初始化客户端：

disConf := models.DefaultDISClientConf()

// 必选配置
disConf.AK = "YOUR_AK"                                        // 用户Access Key ID，可在公有云“我的凭证”页面下载生成
disConf.SK = "YOUR_SK"                                        // 用户Secret Access Key，可在公有云“我的凭证”页面下载生成
disConf.ProjectId = "YOUR_PROJECT_ID"                         // 用户ProjectID
disConf.Region = "region"                                 // 中国华北区北京一，根据通道所属Region选择
disConf.Endpoint = "https://dis.region.myhuaweicloud.com" // 根据通道所属Region选择Endpoint

dis = client.FactoryEx(disConf) // 初始化客户端

// 初始化测试用例的输入参数
disInstance := demo.DISInstance{
   Dis:            dis,
   StreamName:     "YOUR_STREAM_NAME", // 通道名称
   StreamId:       "",                 // 通道ID，访问授权通道时需要指定通道ID
   PartitionId:    "0",
   CursorType:     models.AT_SEQUENCE_NUMBER, // 游标类型，用于确定从分区的什么位置开始获取数据
   SequenceNumber: "0",
   Timestamp:      1534142781293,
   AppName:        "YOUR_APP_NAME",
}

上传数据：

demo.PutRecords(disInstance)

消费数据：

demo.GetPartitionCursor(disInstance)

demo.GetRecords(disInstance)