检测到您已登录华为云国际站账号,为了您更好的体验,建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
系统数说明:系统指的是用户的业务系统,系统数指ROMA Connect实例集成对接的业务系统数量。一个业务系统与ROMA Connect实例之间可以有多个连接。 连接数说明:业务系统和ROMA Connect的交互即为连接,使用不同功能所占用的连接数不同,具体的资源和连接数换算关系如下。 表2
建议由数据库管理员进行CDC功能的配置操作。 开启日志归档和XStream。 在命令行工具中执行以下命令以sys用户连接到数据库。 在实际使用过程中,可以有多种方式连接数据库,此处以命令行方式为例进行说明。 sqlplus /nolog CONNECT sys/password@host:port
本模式配置请参见脚本配置示例。 流控类型 选择流控的类型,推荐使用高性能流控。 高精度流控:单位时间内流控没有误差,但高并发场景下实例内部有一定的性能损耗,适用于并发量较小的场景。 高性能流控:单位时间内流控偶现较小误差,但高并发场景下实例内部性能损耗较小,适用于并发量较大的场景。
的数据集成任务。 步骤四:启动数据集成任务 数据集成任务创建后,“任务状态”为“停止”状态,此时任务不会执行,需先启动任务。 数据集成任务有两种启动方式: 启动任务计划,任务按照创建任务时所设置的计划执行。 在数据集成任务左侧勾选上要启动的任务,单击任务列表上方的“启动”,启动任务计划,然后等待任务按计划时间执行。
命名空间 最大长度:64 workload_type 是 String 工作负载类型 deployment:无状态负载 statefulset:有状态负载 daemonset:守护进程集 app_name 否 String APP名称 最大长度:64 label_key 否 String
命名空间 最大长度:64 workload_type 是 String 工作负载类型 deployment:无状态负载 statefulset:有状态负载 daemonset:守护进程集 app_name 否 String APP名称 最大长度:64 label_key 否 String
的IP。 值为负数时,按倒序方式从X-Forwarded-For头中获取IP。 例如到达API网关的X-Forwarded-For头中依次有IP1,IP2,IP3三个IP地址,xff_index取0时获取IP1,xff_index取1时获取IP2,xff_index取-1时获取I
则优先级最低,至多绑定一个default类型的规则; 每个API仅允许选择一个参数绑定编排规则,且编排规则不能重复,支持绑定的编排规则数量有配额限制,具体请参见产品介绍的“配额说明”章节 id String 参数编号 状态码: 401 表7 响应Body参数 参数 参数类型 描述
List<Column> 目标端选择的列名列表。 support_part_update 否 Boolean 是否仅更新更改的字段。 如果开启此选项,仅更新值有变化的表字段。如果关闭此选项,则更新所有表字段。 meta_data 否 List<MetaData> 任务目标端数据源类型元数据定义。 path
命名空间 最大长度:64 workload_type String 工作负载类型 deployment:无状态负载 statefulset:有状态负载 daemonset:守护进程集 app_name String APP名称 最大长度:64 label_key String 标签名
命名空间 最大长度:64 workload_type 是 String 工作负载类型 deployment:无状态负载 statefulset:有状态负载 daemonset:守护进程集 app_name 否 String APP名称 最大长度:64 label_key 否 String
命名空间 最大长度:64 workload_type 是 String 工作负载类型 deployment:无状态负载 statefulset:有状态负载 daemonset:守护进程集 app_name 否 String APP名称 最大长度:64 label_key 否 String
查找。 集成应用 选择数据源所归属的集成应用。 描述 编辑数据源的描述信息。 连接地址 填写Kafka的连接地址和端口号。 如果Kafka有多个副本(Broker),可单击“添加地址”填写多个连接地址。 是否SSL ROMA Connect与Kafka的连接是否使用SSL认证加密。
小写形式,按照字符代码对消息头进行排序,并使用“;”来分隔多个消息头。 Lowercase表示将所有字符转换为小写字母。 举例: 以下表示有两个消息头参与签名:host、x-sdk-date GET /app1/ a=1&b=2 host:30030113-3657-4fb6-a7ef-90764239b038
磁盘挂载。 以下操作需在每台虚拟机上都执行。 以root用户登录待挂载虚拟机。 查看磁盘情况。 fdisk -l 系统显示如下类似信息表示系统有两个磁盘,一个是空间大小300G盘符为/dev/vdb的磁盘,一个是空间大小200G盘符为/dev/vdc的磁盘,需将300G磁盘/dev/
- type: filestream # id需要替换为数字,不同SHUBAO组件所在节点之间相互唯一。例如SHUBAO组件所在节点有3个,则id可分别配置为site_log_filebeat_01,site_log_filebeat_02,site_log_filebeat_03
have the permissions required to operate the application. 没有权限操作应用程序。 可选择有操作权限账号。 400 ROMA.12002 The user does not support this feature. 此用户不支持该特性。
data = "The msg is " + i; // 注意填写您创建的Topic名称。另外,生产消息的API有多个,具体参见Kafka官网或者下文的生产消息代码。 producer.produce("topicName"
型、数据字段的映射规则、数据集成的过滤条件等。ROMA Connect支持两种数据集成任务: 数据集成任务(普通任务):普通数据集成任务,有定时任务和实时任务两种集成模式,支持所有默认类型的数据源,对于数据库类型数据源,只支持单数据表的集成。 - 定时任务:根据制定的任务计划,定时获取源端数据并集成到目标端。
命名空间 最大长度:64 workload_type String 工作负载类型 deployment:无状态负载 statefulset:有状态负载 daemonset:守护进程集 app_name String APP名称 最大长度:64 label_key String 标签名