-
查询转储详情 - 数据接入服务 DIS
配置参数如下: 1 2 streamname="dis-test1"#已存在的通道名 task_name="test_1" #查询该通道下的xx转储任务 配置好以上参数后,执行describe_dump_task_sample.py文件默认调用describe_dump_task_test
-
添加转储任务 - 数据接入服务 DIS
()); request.setObsDestinationDescriptor(descriptor); 配置“CreateTransferTaskRequest”对象之后,通过调用createTransferTask的方法创建转储任务。
-
查询APP详情 - 数据接入服务 DIS
配置参数如下: 1 appname=”app1” #查询的APP名称 配置好以上参数,执行describeApp_sample.py文件调用describeApp_test方法。
-
创建APP - 数据接入服务 DIS
配置参数如下: 1 appName = "" #创建的APP名称 配置好以上参数,执行createApp_sample.py文件调用createApp_test方法,响应201表示创建成功。 父主题: 使用SDK(Python)
-
查询转储详情 - 数据接入服务 DIS
1 DescribeTransferTaskResult result = dic.describeTransferTask(request); 查询转储任务的返回信息如下。
-
查询通道详情 - 数据接入服务 DIS
配置参数如下: 1 streamname="dis-test1" #已存在的通道名 配置好以上参数后,执行describeStream_sample.py文件默认调用describeStream_test方法。
-
准备DIS Flink Connector的相关环境 - 数据接入服务 DIS
cloud-dis-flink-connector_2.11</artifactId> <version>1.0.5</version> <scope>compile</scope> </dependency> 检查认证信息 检查AK/SK AK/SK (Access Key ID/Secret
-
创建通道 - 数据接入服务 DIS
配置好参数后,执行createstream_sample.py文件默认调用createStream_test方法,获取响应201创建成功。 父主题: 使用SDK(Python)
-
创建通道 - 数据接入服务 DIS
1 dic.createStream(createStreamRequest); 父主题: 使用SDK(Java)
-
准备DIS Spark Streaming的相关环境 - 数据接入服务 DIS
cloud-dis-spark-streaming_2.11</artifactId> <version>1.2.1</version> <scope>compile</scope> </dependency> 检查认证信息 检查AK/SK AK/SK (Access Key ID/Secret