检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
updatePartitionCountResult); } catch (Exception e) { LOGGER.error("Failed to update partition count", e); } 变更分区数量成功的返回信息如下。 1 Success to update
配置好以上参数后，执行putRecords_sample.py文件调用putRecords_test方法，响应结果如下： 1 2 200 {'failed_record_count': 0, 'records': [{'partition_id': 'shardId-0000000001'
双击“start-dis-agent.bat”，启动DIS Agent。 若控制台前几行中打印出如下日志表示启动成功。 [INFO ] (main) com.bigdata.dis.agent.Agent Agent: Startup completed in XXX ms. 父主题：
LoggerFactory.getLogger(DISKafkaProducerDemo.class); public static void main(String[] args) { // 认证用的ak和sk直接写到代码中有很大的安全风险，建议
LoggerFactory.getLogger(DISKafkaProducerDemo.class); public static void main(String[] args) { // 认证用的ak和sk直接写到代码中有很大的安全风险，建议
准备DIS Spark Streaming的相关环境 准备DIS应用开发环境 参考步骤1：开通DIS通道准备相应DIS环境。 安装Maven并配置本地仓库地址。 安装scala-sdk。 配置DIS Spark Streaming依赖 项目中可通过以下配置引入DIS Spark Streaming依赖：
准备DIS Flink Connector的相关环境 准备DIS应用开发环境 参考步骤1：开通DIS通道准备相应DIS环境。 安装Maven并配置本地仓库地址。 安装scala-sdk。 配置DIS Flink Connector依赖 项目中可通过以下配置引入DIS Flink Connector依赖：
putRecords_sample.py文件调用protobuf_putRecords_test方法，响应结果下： 1 2 200 {'failed_record_count': 0, 'records': [{'partition_id': 'shardId-0000000001'
"password": "********", "domain": { "name": "domainname" } }
record to which the SN corresponds has expired. Try to obtain the partition iterator again. 获取数据时，传入的数据游标partition-cursor对应的序列号starting-sequence-number过期
弹性伸缩分区 用户在创建通道成功后，随着业务的发展和变化，对通道容量有了新的需求。弹性伸缩分区可以对已经创建成功的通道进行分区扩容或者分区缩容以满足用户这一需求，支持自动和手动扩缩容两种方式。 约束限制 每个通道在一小时内仅可操作实现10次自动扩容、10次手动扩容、1次缩容（包含手动缩容和自动缩容）操作。
source，监控/tmp/dis.txt文件) agent.sources.exec.type = exec agent.sources.exec.command = tail -F /tmp/dis.txt agent.sources.exec.shell = /bin/bash -c agent.sources
用开发工具（如Eclipse）编译运行示例工程，或以示例工程为基础开发您的应用。示例工程代码路径：“\dis-sdk-demo\src\main\java\com\bigdata\dis\sdk\demo”。 示例代码 说明 ConsumerDemo.java 展示了下载数据的用法
配置DIS Logstash Plugin DIS Logstash Plugins 分为Input与Output插件，本节介绍插件的各个配置项具体含义。 配置DIS Logstash Input 配置模板如下：（该模板为从DIS通道下载数据写入本地文件） input { dis
public static void main(String[] args) { // The AK and SK used for authentication are hard-coded or stored in plaintext, which has great
录结构为“桶名称/转储文件目录/2018/10/16”。 示例2：转储多层嵌套的Json数据。 源数据： { "id":"1", "detail":{ "detID":"05790110000000000103#567fd3cb13a4493eaa43076953253eed",
SDK加密上传数据，读取数据也需要使用JAVA SDK配置相同的密钥。 使用配置文件初始化DIS SDK客户端实例。 在“dis-sdk-demo\src\main\resources”目录下的“dis.properties”文件中添加如下配置项。 ak/sk：用户在IAM中创建的AK/SK。 region：用户使用通道所在的区域。
内容示例如下。具体配置项说明请参见表1。 --- # cloud region id region: myregion ## The plaintext storage of the AK and SK used for authentication has great security
自定义Flink Streaming作业 获取DIS Flink Connector Demo 这里获取“dis-flink-connector-X.X.X.zip”压缩包。解压“dis-flink-connector-X.X.X.zip”压缩包，解压之后获得以下目录： “hua
长按/截图保存，微信识别二维码
或者关注公众号“华为云”
