检测到您已登录华为云国际站账号,为了您更好的体验,建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
配置好以上参数,执行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)
通道列表的返回信息示例如下: 1 2 200 {'stream_names': ['dis-jLGp', 'dis-w_p', 'dis_test1', 'dis_test2'], 'has_more_streams': False, 'total_number': 4} 父主题
父主题: 使用DIS Flume Plugin上传与下载数据
响应结果如下: 1 2 200 {'app_name': 'app1', 'app_id': 'OPKQuggQVtfqhyvK0cs', 'create_time': 1532425956631} 父主题: 使用SDK(Python)
图1 添加权限 父主题: 管理通道
父主题: 入门
父主题: 入门
图1 数据流向 父主题: 一般性问题
父主题: 入门
图2 查看节点IP 父主题: 转储相关问题
父主题: 使用前必读
': 1543301301992, 'app_name': 'sadfghjkl'}, {'app_id': 'MtPG1lD1E7IesDuOcNt', 'create_time': 1542765418080, 'app_name': 'testAppName2'}]} 父主题
1 2 getCheckpoint: {"sequence_number": "10", "metadata": "metadata"} 父主题: 使用SDK(Java)
父主题: 使用DIS Flume Plugin上传与下载数据
父主题: 使用DIS Flink Connector上传与下载数据
父主题: 使用Agent上传数据
父主题: 使用DIS Spark Streaming下载数据
dic.commitCheckpoint(commitCheckpointRequest); 父主题: 使用SDK(Java)