检测到您已登录华为云国际站账号,为了您更好的体验,建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
//需配置转储任务的全量参数,不支持更新单个参数 UpdateTransferTaskRequest request = new UpdateTransferTaskRequest(); // 配置待更新的转储任务所属通道的名称 request.setStreamName(streamName); // 配置待更新的转储任务名称
DescribeTransferTaskRequest request = new DescribeTransferTaskRequest(); // 指定待查询的通道名称 request.setStreamName(streamName); // 指定待查询的转储任务名称 request.setTransfe
est"); request.withBody(body); try { UpdateStreamResponse response = client.updateStream(request); System
Length的请求信息。 412 Precondition Failed 未满足前提条件,服务器未满足请求者在请求中设置的其中一个前提条件。 413 Request Entity Too Large 由于请求的实体过大,服务器无法处理,因此拒绝请求。为防止客户端的连续请求,服务器
SDK查询指定通道的转储任务列表。 1 2 3 4 ListTransferTasksRquest request = new ListTransferTasksRquest(); // 指定待查询的通道名称 request.setStreamName(streamName); 配置“ListTra
request.withBody(body); try { BatchStartTransferTaskResponse response = client.batchStartTransferTask(request);
request.withBody(body); try { BatchStopTransferTaskResponse response = client.batchStopTransferTask(request);
CreateAppRequest request = new CreateAppRequest(); CreateAppReq body = new CreateAppReq(); body.withAppName("newapp"); request.withBody(body);
request.withBody(body); try { CreateObsTransferTaskResponse response = client.createObsTransferTask(request);
withTag(tagbody); request.withBody(body); try { CreateTagResponse response = client.createTag(request); System
); request.withBody(body); try { CommitCheckpointResponse response = client.commitCheckpoint(request);
ListStreamsRequest request = new ListStreamsRequest(); request.withLimit(<limit>); request.withStartStreamName("<start_stream_name>");
fromValue("delete")); request.withBody(body); try { BatchDeleteTagsResponse response = client.batchDeleteTags(request);
DeleteAppRequest request = new DeleteAppRequest(); try { DeleteAppResponse response = client.deleteApp(request);
build() try: request = DeleteTransferTaskRequest() response = client.delete_transfer_task(request) print(response)
ream"); request.withBody(body); try { SendRecordsResponse response = client.sendRecords(request); System
DeleteStreamRequest request = new DeleteStreamRequest(); try { DeleteStreamResponse response = client.deleteStream(request);
ShowAppRequest request = new ShowAppRequest(); try { ShowAppResponse response = client.showApp(request); System
发送“POST https://dis的Endpoint/v2/{project_id}/streams”。 在Request Header中增加“X-Auth-Token”。 在Request Body中传入参数如下: { "stream_name": "dis-DLpR", "partition_count":
eam"); request.withBody(body); try { CreateStreamResponse response = client.createStream(request); System