正在生成
详细信息:
检测到您已登录华为云国际站账号,为了您更好的体验,建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
控制台。 在左侧的导航栏选择“应用业务模型ABM > 模型采集 > 集群管理”,单击“注册集群实例”,分别填写扩展采集器名称,描述,ak/sk认证基本信息,远端ABM服务节点D的Url地址,新增集群实例。 集群实例创建完成后,在左侧的导航栏选择“应用业务模型ABM > 模型采集 >
在左侧的导航栏选择“设备集成 LINK > 设备管理”。 获取设备的连接信息。 MQTT/MQTTS连接地址:在设备管理页面上方获取设备的接入地址,如果使用MQTT接入,则获取“MQTT连接地址”;如果使用MQTTS接入,则获取“MQTTS连接地址”,并下载SSL证书。 客户端ID/
Kafka的机机类型用户名。 上传配置文件 单击“上传文件”,上传MRS Kafka配置文件。配置文件获取请参考获取MRS Kafka配置文件。 获取MRS Kafka配置文件 获取“krb5.conf”和“user.keytab”文件。 参考下载用户认证文件,在MRS Manag
填写Kafka的Brokers地址。 认证方式 选择Kafka的认证方式。 SSL认证 无认证 SASL鉴权方式 仅当“认证方式”选择“SSL认证”时需要配置。 选择SASL鉴权方式。 PLAIN SCRAM-SHA-512 SSL用户名 仅当“认证方式”选择“SSL认证”时需要配置。
com”或“IP:PORT”形式。 认证方式 选择连接WebSocket使用的认证方式。 None:表示无需认证授权,任何人都可以访问WebSocket。 Basic Auth:表示基础认证,需要输入用户名和密码进行认证。认证通过后,允许用户访问WebSocket。 用户名 仅当“认证方式”选择“Basic
连接数据库的用户密码。 描述 填写连接器的描述信息,用于识别不同的连接器。 支持的动作 获取数据库变更 实时获取数据库变更 ,需要在数据库中启动CDC配置。 配置参数 表1 获取数据库变更 参数 说明 表名 填写或者选择要获取数据变更的数据表名。 数据库操作 选择数据库变更的操作。 父主题: 触发器
连接数据库的用户密码。 描述 填写连接器的描述信息,用于识别不同的连接器。 支持的动作 获取数据库变更 实时获取数据库变更 ,需要在数据库中启动LogMiner。 配置参数 表1 获取数据库变更 参数 说明 表名 填写或者选择要获取数据变更的数据表名。 数据库操作 选择数据库变更的操作。 父主题: 触发器
普通任务支持的集成模式(源端) 普通任务支持的集成模式(目标端) 组合任务支持的集成模式(源端) 组合任务支持的集成模式(目标端) 接入API数据源 定时 定时,实时 - - 接入ActiveMQ数据源 实时 定时,实时 - - 接入ArtemisMQ数据源 实时 定时,实时 -
是否开启SSL认证 ROMA Connect与RabbitMQ的连接是否使用SSL认证加密。 SSL认证协议 仅当“是否开启SSL认证”选择“是”时需要配置。 选择SSL认证所使用的协议,固定为“TLS”。 公钥库文件 仅当“是否开启SSL认证”选择“是”时需要配置。 SSL认证过程中,客户端(ROMA
合并结果的格式,当前仅支持“Json”,表示合并结果以JSON字符串的格式输出。 可通过如下两种方法获取某一分支的结果: 后续节点为“脚本处理”时,使用JSON.parse('${body}')方式将合并结果转换为JSON对象,然后通过分支名称获取分支的结果。如: var result=JSON.parse('${body}');
Key ID)。请参考访问密钥获取AK,如果已生成过AK/SK,找到原来已下载的AK/SK文件,文件名一般为:credentials.csv。 Secret Access Key 当前账号的SK(Secret Access Key)。请参考访问密钥获取SK,如果已生成过AK/SK,
n。 登录方式 选择连接数据库模式。 租户:即以华为云账户密码的方式进行连接。 ak/sk:即获取“访问密钥”进行连接。AK/SK是用户在云服务平台的长期身份凭证,您可以参考访问密钥获取AK/SK。 租户名称 仅当“登录方式”选择“租户”时需要配置。即华为云租户账号。 IAM用户名称
MQ的用户密码。 是否开启SSL认证 ROMA Connect与IBM MQ的连接是否使用SSL认证加密。 密钥算法套件 仅当“是否开启SSL认证”选择“是”时需要配置。 填写“通道名称”所指队列管理器通道中,使用的密钥算法套件名称。 公钥库文件 仅当“是否开启SSL认证”选择“是”时需要配置。
开启CDC。 使用SSMS客户端连接到SQL Server数据库所在服务器,以sa用户登录数据库。 其中,密码为数据库用户sa的密码,可向数据库管理员获取。 单击“新建查询”,选择你需要开启CDC的数据库。执行以下命令,开启SQL Server数据库CDC。 if exists(select
dbname为要接入的数据库名。 用户名 数据库的登录用户名。 上传认证文件 单击“上传文件”,上传FI HBase配置文件。配置文件获取请参考获取FI HBase配置文件。 获取FI HBase配置文件: 参考下载用户认证文件,在FI Manager下载用户认证文件,解压后得到“krb5.conf”和
Connect实例的消息集成MQS连接地址。 重启消费业务,使得消费者从ROMA Connect实例中消费消息。 观察消费者是否能正常从ROMA Connect实例中获取数据。 迁移结束。 方案二:同时消费,后迁生产 方案介绍 本方案中,消费者业务启用多个消费客户端,分别从原Kafka和ROMA Conne
在路由栏单击“更改”,然后单击“添加地址”按钮,添加路由后单击“保存”即可。 请检查安全组是否放通。 登录ROMA Connect控制台,在“实例”页面单击实例上的“查看控制台”,进入实例信息界面。 在安全组栏单击安全组名称,如下图的“default”,页面跳转至安全组控制台。 选择“出方向规则”页签,查看创建数据源配置的IP是否在目的地址中。
连接RabbitMQ的用户名。 密码 连接RabbitMQ的用户密码。 虚拟主机 连接RabbitMQ的虚拟主机。 是否开启SSL认证 连接RabbitMQ时是否使用SSL认证。 描述 填写连接器的描述信息,用于识别不同的连接器。 支持的动作 监听exchange 配置参数 表1 监听exchange
SFTP(SSH File Transfer Protocol,安全文件传输协议)是FTP的安全版本,也是SSH协议的一部分,可通过安全SHELL数据流轻松进行数据传输和数据访问。SFTP也被称为SSH文件传输协议,它提供了一个安全的连接来传输文件,并在本地和远程系统上遍历文件系统。 默
链接ArtemisMQ的端口号。 用户名 连接ArtemisMQ的用户名。 密码 连接ArtemisMQ的用户密码。 是否开启SSL认证 连接ArtemisMQ时是否使用SSL认证。 描述 填写连接器的描述信息,用于识别不同的连接器。 支持的动作 无 配置参数 无 父主题: 消息系统