-
上传流式数据 - 数据接入服务 DIS
上传流式数据 样例代码 使用初始化DIS客户端后的客户端实例将用户的流式数据通过DIS通道上传至DIS服务。 其中,“streamName”的配置值要与开通DIS通道中“通道名称”的值一致,“endpoint”,“ak”,“sk”,“region”,“projectId”信息请参见获取认证信息。
-
安装前准备 - 数据接入服务 DIS
检查依赖 服务器类型。 Linux x86-64(64位)服务器,常见的有EulerOS、Ubuntu、Debian、CentOS、OpenSUSE等。 Windows 7及以上版本。 已安装1.8.0及以上版本的Java。 请参见JRE地址下载JRE。 Linux服务器安装请参考如下步骤:
-
使用SDK(Java) - 数据接入服务 DIS
使用SDK(Java) 准备环境 配置样例工程 初始化DIS客户端 创建通道 添加转储任务 更新转储任务 删除转储任务 查询转储列表 查询转储详情 删除通道 查询通道列表 查询通道详情 下载流式数据 上传流式数据 获取数据游标 创建APP 删除APP 新增Checkpoint 查询Checkpoint
-
配置样例工程 - 数据接入服务 DIS
Projects”页面。 单击“Browse”按钮,根据实际情况选择“dis-sdk-demo”样例工程的存储位置,勾选样例工程,如图1所示。 图1 Import Maven Projects 单击“Finish”完成项目导入。 配置Demo工程。 配置项目编码为“UTF-8”。
-
下载流式数据 - 数据接入服务 DIS
列号由DIS在数据生产者调用PutRecords操作以添加数据到DIS数据通道时DIS服务自动分配的。同一分区键的序列号通常会随时间变化增加。PutRecords请求之间的时间段越长,序列号越大。 说明: 请根据上传流式数据的执行结果,控制台的返回信息字段,例如“sequenceNumber
-
添加转储任务 - 数据接入服务 DIS
参考初始化DIS客户端的操作初始化一个DIS客户端实例,实例名称为dic。 使用DIS SDK创建转储任务,需要指定通道名称、转储任务名称,转储周期,转储目标服务等信息。 添加转储到对象存储服务(OBS)的转储任务 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17
-
准备环境 - 数据接入服务 DIS
已从Oracle官网下载并安装JDK1.8或以上版本,配置好JAVA环境变量。 已从Eclipse官网下载并安装Eclipse IDE for Java Developers最新版本。 已在Eclipse中配置好JDK。 父主题: 使用SDK(Java)
-
初始化DIS客户端 - 数据接入服务 DIS
DISClientBuilder.standard() .withEndpoint("YOUR_ENDPOINT") // 认证用的ak和sk硬编码到代码中或者明文存储都有很大的安全风险,建议在配置文件或者环境变量中密文存放,使用时解密,确保安全; // 本示例以ak和sk保存在环
-
删除通道 - 数据接入服务 DIS
Stream的方法删除通道。 1 dic.deleteStream(deleteStreamRequest); 父主题: 使用SDK(Java)
-
创建通道 - 数据接入服务 DIS
Stream的方法创建通道。 1 dic.createStream(createStreamRequest); 父主题: 使用SDK(Java)
-
查询Checkpoint - 数据接入服务 DIS
getCheckpoint: {"sequence_number": "10", "metadata": "metadata"} 父主题: 使用SDK(Java)
-
查询通道详情 - 数据接入服务 DIS
13288589]'}], hasMorePartitions=false, updatePartitionCounts=null] 父主题: 使用SDK(Java)
-
变更分区数量 - 数据接入服务 DIS
[currentPartitionCount=2, streamName=mystream, targetPartitionCount=2] 父主题: 使用SDK(Java)
-
查询转储详情 - 数据接入服务 DIS
"deliver_time_interval":300, "consumer_strategy":"LATEST" } } 父主题: 使用SDK(Java)
-
创建APP - 数据接入服务 DIS
配置APP名称之后,通过调用createApp的方法创建APP。 dic.createApp(myApp); 父主题: 使用SDK(Java)
-
获取数据游标 - 数据接入服务 DIS
equest); String cursor = response.getPartitionCursor(); 父主题: 使用SDK(Java)
-
删除APP - 数据接入服务 DIS
配置APP名称之后,通过调用deleteApp的方法删除APP。 dic.deleteApp(myApp); 父主题: 使用SDK(Java)
-
更新转储任务 - 数据接入服务 DIS
参考初始化DIS客户端的操作初始化一个DIS客户端实例,实例名称为dic。 使用DIS SDK更新转储任务,需要指定通道名称、转储任务名称,转储周期,转储目标服务等信息。 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 /
-
删除转储任务 - 数据接入服务 DIS
ansferTask的方法删除转储任务。 1 dic.deleteTransferTask(request); 父主题: 使用SDK(Java)
-
新增Checkpoint - 数据接入服务 DIS
提交checkpoint。 dic.commitCheckpoint(commitCheckpointRequest); 父主题: 使用SDK(Java)