-
Json格式上传流式数据 - 数据接入服务 DIS
配置参数如下: 1 streamname="dis-test1"| #已存在的通道名 putRecords_sample.py文件中的putRecords_test方法中的records为需要上传的数据内容,数据上传格式如下: 1 2 3 4 records=[{"data":
-
验证DIS Logstash Plugin - 数据接入服务 DIS
bin/logstash -f local_to_dis.conf 其中 -f 为用户编写的配置文件路径。 检查DIS Logstash Output上传数据是否正常。
-
查询APP列表 - 数据接入服务 DIS
配置参数如下: 1 startAppName="app1" #APP名称(从该通道开始返回app列表,返回的app列表不包括此app名称。) 配置好以上参数,执行listApp_sample.py文件调用Applist_test方法。
-
下载流式数据 - 数据接入服务 DIS
' 配置好以上参数,执行getRecords_sample.py文件调用getRecords_test方法,响应结果如下。
-
DIS有哪些模块及各模块功能? - 数据接入服务 DIS
-
删除转储任务 - 数据接入服务 DIS
1 2 3 4 5 6 7 DeleteTransferTaskRequest request = new DeleteTransferTaskRequest(); // 配置转储任务所属的通道名称 request.setStreamName(streamName); // 配置待删除的转储任务名称
-
删除APP - 数据接入服务 DIS
1 2 // 待删除APP名称 String appName = "myApp"; 配置APP名称之后,通过调用deleteApp的方法删除APP。 dic.deleteApp(myApp); 父主题: 使用SDK(Java)
-
查询转储列表 - 数据接入服务 DIS
配置参数如下: 1 streamname="XXX" #已存在的通道名 执行list_dump_task_sample.py文件默认调用list_dump_task_test方法,获取响应200查询成功。
-
删除通道 - 数据接入服务 DIS
streamName = "myStream"; DeleteStreamRequest deleteStreamRequest = new DeleteStreamRequest(); deleteStreamRequest.setStreamName(streamName); 配置
-
创建APP - 数据接入服务 DIS
1 2 // APP名称 String appName = "myApp"; 配置APP名称之后,通过调用createApp的方法创建APP。 dic.createApp(myApp); 父主题: 使用SDK(Java)
-
查询通道列表 - 数据接入服务 DIS
配置参数如下: 1 start_stream_name = "" #可设置为空,或是已存在的通道名 执行listStream_sample.py文件默认调用listStream_test方法,获取响应200查询成功。
-
什么是分区? - 数据接入服务 DIS
-
更新转储任务 - 数据接入服务 DIS
(); // 配置待更新的转储任务所属通道的名称 request.setStreamName(streamName); // 配置待更新的转储任务名称 OBSDestinationDescriptorRequest descriptor = new OBSDestinationDescriptorRequest
-
自定义Flink Streaming作业 - 数据接入服务 DIS
在打开的配置页面中,“Program arguments”中输入运行参数,格式为 : DIS网关地址 Region名称 AK SK ProjectID 通道名称 https://dis.
-
查询转储详情 - 数据接入服务 DIS
new DescribeTransferTaskRequest(); // 指定待查询的通道名称 request.setStreamName(streamName); // 指定待查询的转储任务名称 request.setTransferTaskName(taskName); 配置
-
创建通道 - 数据接入服务 DIS
N*24,N的取值为1~7的整数 createStreamRequest.setDataDuration(24); // 通道的源数据类型:缺省值:BLOB createStreamRequest.setDataType(DataTypeEnum.BLOB.name()); 配置
-
查询Checkpoint - 数据接入服务 DIS
其中,“streamName”的配置值要与开通DIS通道中“通道名称”的值一致,“endpoint”,“ak”,“sk”,“region”,“projectId”信息请参见获取认证信息。
-
变更分区数量 - 数据接入服务 DIS
其中,“streamName”的配置值要与开通DIS通道中“通道名称”的值一致,“endpoint”,“ak”,“sk”,“region”,“projectId”信息请参见获取认证信息。
-
转储至DLI - 数据接入服务 DIS
此配置项仅支持选择,不可手动输入。 - DLI数据表 单击“选择”,在“选择DLI数据表”窗口选择一个数据表。仅支持数据位置为DLI类型的数据表,且用户需具有该表的插入权限。 此配置项仅支持选择,不可手动输入。 配置此项必须已配置“DLI 数据库”。
-
Protobuf格式上传流式数据 - 数据接入服务 DIS
'', ak=os.environ.get("HUAWEICLOUD_SDK_AK"), sk=os.environ.get("HUAWEICLOUD_SDK_SK"), projectid='', region='',bodySerializeType='protobuf') 配置参数如下