-
删除Checkpoint - 数据接入服务 DIS
(request) if err == nil { fmt.Printf("%+v\n", response) } else { fmt.Println(err) } } 更多 更多编程语言的SDK代码示例,请参见API Explorer
-
连接OBS - 数据接入服务 DIS
连接OBS 介绍 DIS可以向对象存储服务(Object Storage Service,简称OBS)上传数据。 前提条件 已参考自动创建委托创建IAM委托,授权DIS服务去访问用户的OBS。 数据转储 用户在新增转储任务时可设置”数据转储地址”。
-
查询分区监控 - 数据接入服务 DIS
(Byte) total_put_records_per_partition:分区总输入记录数(个) total_get_records_per_partition:分区总输出记录数(个) 枚举值: total_put_bytes_per_partition total_get_bytes_per_partition
-
步骤4:从DIS获取数据 - 数据接入服务 DIS
[main] INFOcom.bigdata.dis.sdk.demo.ConsumerDemo - Get Record [hello world.], partitionKey [528377], sequenceNumber [2].
-
步骤4:从DIS获取数据 - 数据接入服务 DIS
[main] INFOcom.bigdata.dis.sdk.demo.ConsumerDemo - Get Record [hello world.], partitionKey [528377], sequenceNumber [2].
-
删除指定通道 - 数据接入服务 DIS
\n", response) } else { fmt.Println(err) } } 更多 更多编程语言的SDK代码示例,请参见API Explorer的代码示例页签,可生成自动对应的SDK代码示例。
-
删除App - 数据接入服务 DIS
) } else { fmt.Println(err) } } 更多 更多编程语言的SDK代码示例,请参见API Explorer的代码示例页签,可生成自动对应的SDK代码示例。
-
查询Checkpoint详情 - 数据接入服务 DIS
fmt.Println(err) } } 更多 更多编程语言的SDK代码示例,请参见API Explorer的代码示例页签,可生成自动对应的SDK代码示例。
-
获取数据游标 - 数据接入服务 DIS
枚举值: AT_SEQUENCE_NUMBER AFTER_SEQUENCE_NUMBER TRIM_HORIZON LATEST AT_TIMESTAMP starting-sequence-number 否 String 序列号。序列号是每个记录的唯一标识符。
-
查询App列表 - 数据接入服务 DIS
状态码 状态码 描述 200 正常返回 400 Invalid Parameters 404 Application not found 500 Internal Server Error 错误码 请参见错误码。 父主题: App管理
-
查询通道监控 - 数据接入服务 DIS
total_get_bytes_per_stream total_put_records_per_stream total_get_records_per_stream total_put_req_latency total_get_req_latency total_put_req_suc_per_stream
-
下载数据 - 数据接入服务 DIS
>) request.MaxFetchBytes = &maxFetchBytesRequest response, err := client.ConsumeRecords(request) if err == nil { fmt.Printf("%+v\n
-
查看App详情 - 数据接入服务 DIS
) } else { fmt.Println(err) } } 更多 更多编程语言的SDK代码示例,请参见API Explorer的代码示例页签,可生成自动对应的SDK代码示例。
-
上传数据 - 数据接入服务 DIS
error_code String 错误码。 error_message String 错误消息。
-
创建消费App - 数据接入服务 DIS
(request) if err == nil { fmt.Printf("%+v\n", response) } else { fmt.Println(err) } } 更多 更多编程语言的SDK代码示例,请参见API Explorer
-
初始化DIS客户端 - 数据接入服务 DIS
(DISConfig.PROPERTY_PRODUCER_RECORDS_RETRIES, "-1") .withProperty(DISConfig.PROPERTY_PRODUCER_EXCEPTION_RETRIES, "-1") .build(); 若需要使用代理
-
查看App消费状态 - 数据接入服务 DIS
request.withCheckpointType(ShowConsumerStateRequest.CheckpointTypeEnum.fromValue("<checkpoint_type>")); try { ShowConsumerStateResponse
-
查询权限策略列表 - 数据接入服务 DIS
\n", response) } else { fmt.Println(err) } } 更多 更多编程语言的SDK代码示例,请参见API Explorer的代码示例页签,可生成自动对应的SDK代码示例。
-
查看通道详情 - 数据接入服务 DIS
枚举值: snappy gzip zip csv_properties CSVProperties object CSV 格式数据的相关属性,比如分隔符 delimiter writable_partition_count Integer 可写分区总数量(只包含ACTIVE状态的分区
-
下载流式数据 - 数据接入服务 DIS
更改游标类型cursorType='AT_SEQUENCE_NUMBER' 获取游标getCursor_test采用test_0方法,下载数据getRecords_test采用test方法;test方法较test_0方法,增加参数bodySerializeType="protobuf