-
使用SDK(Python) - 数据接入服务 DIS
使用SDK(Python) 准备环境 配置样例工程 初始化DIS客户端 创建通道 添加转储任务 删除通道 删除转储任务 查询通道列表 查询转储列表 查询通道详情 查询转储详情 Json格式上传流式数据 Protobuf格式上传流式数据 下载流式数据 创建APP 删除APP 查询APP详情
-
使用Agent上传数据 - 数据接入服务 DIS
使用Agent上传数据 DIS Agent概述 安装前准备 安装DIS Agent 配置DIS Agent 启动DIS Agent 验证DIS Agent 停止DIS Agent 父主题: 使用DIS
-
与原生KafkaConsumer接口适配说明 - 数据接入服务 DIS
与原生KafkaConsumer接口适配说明 表1 接口适配说明 原生KafkaConsumer 类型 DISKafkaConsumer 说明 Set<TopicPartition> assignment() 接口 支持 获取consumer消费的通道与分区信息 Set<String>
-
使用DIS Logstash Plugin上传与下载数据 - 数据接入服务 DIS
使用DIS Logstash Plugin上传与下载数据 DIS Logstash Plugin概述 安装DIS Logstash Plugin前准备 在线安装DIS Logstash Plugin 离线安装DIS Logstash Plugin 配置DIS Logstash Plugin
-
使用DIS Flink Connector上传与下载数据 - 数据接入服务 DIS
使用DIS Flink Connector上传与下载数据 DIS Flink Connector概述 准备DIS Flink Connector的相关环境 自定义Flink Streaming作业 父主题: 使用DIS
-
图解数据接入服务DIS - 数据接入服务 DIS
图解数据接入服务DIS
-
配置样例工程 - 数据接入服务 DIS
用开发工具(如Eclipse)编译运行示例工程,或以示例工程为基础开发您的应用。示例工程代码路径:“\dis-sdk-demo\src\main\java\com\bigdata\dis\sdk\demo”。 示例代码 说明 ConsumerDemo.java 展示了下载数据的用法
-
数据下载的消费模式 - 数据接入服务 DIS
getLogger(DISKafkaConsumerAssignDemo.class); public static void main(String[] args) { // 认证用的ak和sk直接写到代码中有很大的安全风险,建议在配
-
数据下载的消费模式 - 数据接入服务 DIS
getLogger(DISKafkaConsumerAssignDemo.class); public static void main(String[] args) { // 认证用的ak和sk直接写到代码中有很大的安全风险,建议在配
-
一般性问题 - 数据接入服务 DIS
-
DIS如何发送和接收数据? - 数据接入服务 DIS
-
API说明 - 数据接入服务 DIS
API说明 通道管理 App管理 Checkpoint管理 数据管理 转储任务管理 监控管理 标签管理
-
使用前必读 - 数据接入服务 DIS
使用前必读 概述 调用说明 终端节点 约束与限制 基本概念
-
App管理 - 数据接入服务 DIS
App管理 创建消费App 查询App列表 删除App 查看App详情 查看App消费状态 父主题: API说明
-
Checkpoint管理 - 数据接入服务 DIS
Checkpoint管理 提交Checkpoint 查询Checkpoint详情 删除Checkpoint 父主题: API说明
-
数据管理 - 数据接入服务 DIS
数据管理 上传数据 下载数据 获取数据游标 父主题: API说明
-
转储任务管理 - 数据接入服务 DIS
转储任务管理 添加OBS转储任务 查询转储任务列表 删除转储任务 查询转储任务详情 批量启动转储任务 批量暂停转储任务 添加DWS转储任务 添加MRS转储任务 添加DLI转储任务 添加CloudTable转储任务 父主题: API说明
-
标签管理 - 数据接入服务 DIS
标签管理 给指定通道添加标签 查询指定通道的标签信息 删除指定通道的标签 批量添加资源标签 查询指定区域所有标签集合 使用标签过滤资源(通道等) 批量删除资源标签 父主题: API说明
-
简介 - 数据接入服务 DIS
简介 DIS SDK能做什么 内容导航
-
相关资源 - 数据接入服务 DIS
相关资源 SDK下载 兼容性 如何校验软件包完整性?