检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
以下配置失败时的重试次数 .withProperty(DISConfig.PROPERTY_PRODUCER_RECORDS_RETRIES, "-1") .withProperty(DISConfig.PROPERTY_PRODUCER_EXCEPTION_RETRIES, "-1")
response, err := client.DeleteStream(request) if err == nil { fmt.Printf("%+v\n", response) } else { fmt.Println(err) }
response, err := client.ShowApp(request) if err == nil { fmt.Printf("%+v\n", response) } else { fmt.Println(err) } }
输入流量（Byte） total_get_bytes_per_stream：总输出流量（Byte） total_put_records_per_stream：总输入记录数（个） total_get_records_per_stream：总输出记录数（个） total_put_re
response, err := client.SendRecords(request) if err == nil { fmt.Printf("%+v\n", response) } else { fmt.Println(err) }
更多编程语言的SDK代码示例，请参见API Explorer的代码示例页签，可生成自动对应的SDK代码示例。 状态码 状态码 描述 200 正常返回 400 Invalid Parameters 404 Application not found 500 Internal Server Error 错误码 请参见错误码。
选择，DIS支持的系统权限，请参见DIS系统权限。若您需要对除DIS之外的其它服务授权，IAM支持服务的所有权限请参见权限策略。 示例流程 图1 IAM用户授权流程 创建用户组并授权 在IAM控制台创建用户组，并授予数据接入服务的通道管理权限“DIS Operator”。 创建用户并加入用户组
REGION>")) .build(); ShowConsumerStateRequest request = new ShowConsumerStateRequest(); request.withAppName("{app_name}");
[{'sequence_number': '4', 'data': b'xxxxx', 'partitionKey': '0', 'timestamp': 1554705842558, 'timestamp_type': 'CreateTime'}, {'sequence_number': '5',
与其他服务的关系 介绍DIS与其他服务的关系。 对象存储服务（Object Storage Service，简称OBS） 在用户购买接入通道时选择数据转储至OBS，用户上传的数据会存储至对象存储服务（OBS）。 统一身份认证服务（Identity and Access Management，简称IAM）
response, err := client.CreateApp(request) if err == nil { fmt.Printf("%+v\n", response) } else { fmt.Println(err) } }
ConsumeRecordsRequest request = new ConsumeRecordsRequest(); try { ConsumeRecordsResponse response = client.consumeRecords(request);
BatchStopTransferTaskRequest request = new BatchStopTransferTaskRequest(); request.withStreamName("{stream_name}"); BatchStopTransferTaskReq
response, err := client.UpdatePartitionCount(request) if err == nil { fmt.Printf("%+v\n", response) } else { fmt.Println(err)
response, err := client.ListPolicies(request) if err == nil { fmt.Printf("%+v\n", response) } else { fmt.Println(err) }
partitionKey [528377], sequenceNumber [2] 14:40:22.092 [main] INFOcom.bigdata.dis.sdk.demo.ProducerDemo - ========== PUT OVER ============
partitionKey [528377], sequenceNumber [2] 14:40:22.092 [main] INFOcom.bigdata.dis.sdk.demo.ProducerDemo - ========== PUT OVER ============ 父主题： 入门
response, err := client.CreateTag(request) if err == nil { fmt.Printf("%+v\n", response) } else { fmt.Println(err) } }
概述 欢迎使用数据接入服务（Data Ingestion Service, DIS）。数据接入服务面向IoT、互联网等实时数据，提供高效采集、传输、分发能力，支持多种IoT协议，提供丰富的接口，帮助您快速构建实时数据应用。 您可以使用本文档提供API对实时数据进行相关操作，如上传
什么是DIS？ 数据接入服务（Data Ingestion Service）为处理或分析流数据的自定义应用程序构建数据流管道，主要解决云服务外的数据实时传输到云服务内的问题。数据接入服务每小时可从数十万种数据源（如IoT数据采集、日志和定位追踪事件、网站点击流、社交媒体源等）中连续捕获、传送和存储数TB数据。
