检测到您已登录华为云国际站账号,为了您更好的体验,建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
父主题: 使用Kafka Adapter上传与下载数据
DIS Logstash Plugin前准备 在线安装DIS Logstash Plugin 离线安装DIS Logstash Plugin 配置DIS Logstash Plugin 验证DIS Logstash Plugin 卸载DIS Logstash Plugin(可选) 父主题
父主题: 相关资源
父主题: 使用SDK(Python)
图1 DIS Spark Streaming使用流程 父主题: 使用DIS Spark Streaming下载数据
图1 安装流程 父主题: 使用Agent上传数据
dic.createApp(myApp); 父主题: 使用SDK(Java)
父主题: 转储相关问题
父主题: 使用SDK(Java)
父主题: 使用前必读
父主题: 使用DIS Flume Plugin上传与下载数据
父主题: 入门
响应结果如下: 1 2 200 {'app_name': 'app1', 'app_id': 'OPKQuggQVtfqhyvK0cs', 'create_time': 1532425956631} 父主题: 使用SDK(Python)
父主题: 使用前必读
配置好以上参数,执行getCheckpoint_sample.py文件调用getCheckpoint_test方法,响应结果如下: 1 2 3 4 { "sequence_number": "10", "metadata": "metadata" } 父主题:
last_transfer_timestamp': 1538018769241, 'state': 'RUNNING', 'create_time': 1537949648144, 'destination_type': 'OBS', 'task_name': 'task_test1'}]} 父主题
父主题: 使用SDK(Python)
父主题: 使用SDK(Python)
通道列表的返回信息示例如下: 1 2 200 {'stream_names': ['dis-jLGp', 'dis-w_p', 'dis_test1', 'dis_test2'], 'has_more_streams': False, 'total_number': 4} 父主题
request.setCursorType(cursorType); GetPartitionCursorResult response = dic.getPartitionCursor(request); String cursor = response.getPartitionCursor(); 父主题