检测到您已登录华为云国际站账号,为了您更好的体验,建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
数据游标。 取值范围:1~512个字符。 说明: 数据游标有效期为5分钟。 最小长度:1 最大长度:512 请求示例 获取数据游标 GET https://{Endpoint}/v2/{project_id}/cursors 响应示例 状态码: 200 正常返回 { "partition_cursor"
d value String 值。 对应的是企业项目ID,需要在企业管理页面获取。 36位UUID。 请求示例 查询通道列表 GET https://{Endpoint}/v2/{project_id}/streams 响应示例 状态码: 200 正常返回 { "total_number"
单位:秒。 默认配置为1800。 配置为“0”表示DIS服务不会在转储失败时进行重试。 响应参数 无 请求示例 添加MRS转储任务 POST https://{Endpoint}/v2/{project_id}/streams/{stream_name}/transfer-tasks {
d value String 值。 对应的是企业项目ID,需要在企业管理页面获取。 36位UUID。 请求示例 查看通道详情 GET https://{Endpoint}/v2/{project_id}/streams/{stream_name} 响应示例 状态码: 200 正常返回
point即可 // props.setProperty(DISConfig.PROPERTY_ENDPOINT, "https://dis-${region}.myhuaweicloud.com"); Consumer<String, String>
用户所属区域的项目ID。 获取方式请参见检查认证信息。 请根据实际情况配置 endpoint 是 DIS对应Region的数据接口地址。 https://dis.cn-north-1.myhuaweicloud.com partitionNumber 否 通道的分区数量。 用于计算batchSize的大小。
DIS网关地址Region名称AK SK ProjectID 通道名称起始位置Streaming批次时间 如在华北-北京1测试,则参数示例为 https://dis.${region}.cloud.com ${region} YOU_AK YOU_SK YOU_PROJECTID YOU_STREAM_NAME
point即可 // props.setProperty(DISConfig.PROPERTY_ENDPOINT, "https://dis-${region}.myhuaweicloud.com"); Consumer<String, String>
用于记录数据格式错误信息的错误表表名。并行导入结束后查询此错误信息表,能够获取详细的错误信息。 响应参数 无 请求示例 添加DWS转储任务 POST https://{Endpoint}/v2/{project_id}/streams/{stream_name}/transfer-tasks {
point即可 // props.setProperty(DISConfig.PROPERTY_ENDPOINT, "https://dis-${region}.myhuaweicloud.com"); // Create dis producer
point即可 // props.setProperty(DISConfig.PROPERTY_ENDPOINT, "https://dis-${region}.myhuaweicloud.com"); // Create dis producer
DIS dic = DISClientBuilder.standard() .withEndpoint("https://dis.cn-north-1.myhuaweicloud.com:20004") .withAk("${your_AK}")
String 常量或通道内用户数据的JSON属性名称。 取值范围:1~32,只能包含英文字母、数字和下划线。 请求示例 查询转储任务详情 GET https://{Endpoint}/v2/{project_id}/streams/{stream_name}/transfer-tasks/{task_name}