检测到您已登录华为云国际站账号,为了您更好的体验,建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
流产生影响,推荐您使用独立的实例进行调试。 使用工作流在线调试功能,调试环境如果选择共享体验版实例,您可同时调试的最大工作流数量为1条;如果选择购买独立的ROMA Connect实例,可同时调试的最大工作流数量为5条。 使用工作流在线调试功能,工作流的触发器节点不会真实运行,如Open
表名存在乱码导致Camel访问数据库失败 原因分析 访问数据库使用参数不正确,导致组合任务启动失败,任务终止。 解决方案 检查数据库中是否有表名存在乱码的情况,如果存在请和数据库管理员沟通后删除乱码表名的表,然后重新启动任务。 父主题: 数据集成组合任务
boolean defaultValue) 字符串转换成对应的boolean类型 输入参数 value:需要转换的字符内容 defaultValue:默认的boolean值,在value值非法情况下,返回 返回信息 返回对应的boolean值 public static String
nce,阻塞消费。 ROMA Connect不能保证消费重复的消息,业务侧需保证消息处理的幂等性。 消费线程退出要调用Consumer的close方法,避免同一个组的其他消费者阻塞sesstion.timeout.ms的时间。 Producer使用建议 同步复制客户端需要配合使用:acks=-1
用户配置任务时多了一个表映射,将一个相似名称的源表配置采集数据到此目标表,导致向此字段写入空数据,需确保表映射正确。 Oracle产生的RedoLog中,UPDATE语句的字段中没有WHERE条件,导致缺少此字段的值,需添加UPDATE语句字段中的WHERE条件。 父主题: 数据集成组合任务
对于包年/包月计费模式的ROMA Connect实例,用户在购买时会一次性付费,服务将在到期后自动停止使用。 如果在计费周期内不再使用包年/包月资源,您可以执行退订操作,系统将根据资源是否属于五天无理由退订、是否使用代金券和折扣券等条件返还一定金额到您的账户。详细的退订规则请参见云服务退订规则概览。
示例代码中的参数说明,可参考获取MQS连接信息获取参数值。 brokers:MQS连接地址和端口。 topics:要生产消息的Topic名称。 user和password:开启SASL_SSL认证时所使用的用户名和密码。 caFile:开启SASL_SSL认证时所使用的客户端证书。
bytes:需要转换的字节数组 encoding:编码 返回信息 返回转换后的字符串 public static String toString(byte[] bytes) 将字节数组转换成UTF-8编码字符串 输入参数 bytes:需要转换的字节数组 返回信息 返回转换后的字符串 public
ROMA Connect对用户资源实现了严格的权限管理。 创建实例时,如果无法查看虚拟私有云、子网、安全组、弹性IP,可能原因是该用户无Server Administrator和VPC Administrator权限。 增加权限的详细步骤请参考修改用户组权限。 父主题: 实例管理
h> #include <curl/curl.h> #include "signer.h" 生成一个新的Signer, 输入API所授权凭据的Key和Secret,可参考获取API的调用信息获取。 // Directly writing AK/SK in code is risky
更新redis缓存内容 输入参数 key:待更新缓存的key值 value:待更新缓存的value值 返回信息 返回执行结果 public Long remove(String key) 删除指定key值的缓存消息 输入参数 key:待删除缓存的key值 返回信息 返回执行结果 父主题: 自定义后端开发(函数后端)
选择设备所属的产品,设备将继承该产品定义的物模型服务能力。 普通直连设备和网关子设备选择普通产品,网关设备选择网关产品。 设备标识 填写设备的唯一标识,如IMEI、MAC地址等。设备标识为普通直连设备和网关子设备的deviceId,为网关设备的gatewayId。 设备密码 填写
<curl/curl.h> #include "signer.h" 生成一个sig_params_t类型的变量,输入API所授权凭据的Key和Secret,可参考获取API的调用信息获取。 sig_params_t params; sig_params_init(¶ms);
MQS基于Kafka社区版本1.1.0、2.7,您可以在ROMA Connect实例控制台的“实例信息”页面,在“MQS基本信息”下查看Kafka版本信息。Python开源客户端的版本使用请参见客户端版本使用建议。 执行以下命令,安装对应版本的Python Kafka客户端: pip install kafka-python==2
FDI任务只能采集单张表到单张表吗? 普通任务只能从源端的单个表采集到目标端单个表,组合任务可以配置多个表采集到多个表。 父主题: 数据集成普通任务
查询实例信息 功能介绍 查询对应实例ID的详细信息。 URI GET /v1/{project_id}/link/instances/{instance_id} 表1 参数说明 参数 类型 是否必填 说明 project_id string 是 租户每个区域对应的项目ID。 instance_id
套餐包计费:根据购买的套餐包规格提供对应的RCU时额度,使用过程中优先抵扣套餐包中的RCU时额度,超过额度的使用量按需计费。套餐包按月购买,当月生效的套餐包额度仅当月有效,额度余量过期失效,不可结转到下月使用。 例如购买了1000RCU时/月规格的套餐包,开通5RCU的实例,则当月内该
在安全组配置页面中,根据准备工作中获取的源实例安全组信息和新实例的实际组网需求,修改安全组的规则配置。 ROMA Connect实例的安全组规则要求请参见表2。 修改实例路由信息,仅资产迁移场景需要,否则跳过此步。 在“实例信息”页面的“基本信息”页签下,更改路由信息。 修改实例配置参数,仅资产迁移场景需要,否则跳过此步。
接入数据源 概述 在创建采集任务之前,您需要先接入数据源,确保可以正常从数据源采集模型。根据数据源类型的不同,数据源的接入配置有所差异。 操作步骤 接入DWS数据源 接入GaussDB数据源 接入FI Hive数据源 接入MySQL数据源 接入MongoDB数据源 接入MRS Hive数据源
Project”对话框,选择“Go”,单击“Next”。 图2 New Project 单击“...”,在弹出的对话框中选择解压后的SDK路径,单击“Finish”。 图3 选择解压后的SDK路径 完成工程创建后,目录结构如下。 图4 新建工程的目录结构 “demo.go”为示例代码,请根据实际情况修改参数后使用。具体代码说明请参考调用API示例。