检测到您已登录华为云国际站账号,为了您更好的体验,建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
搜索“定时同步”,选择“定时同步MySql中的数据到Oracle”模板,单击“使用模板”。 本实践中MySQL数据源表中的字段与Oracle中数据目标表中的字段类型保持一致。 将MySQL数据表中的aa、bb字段同步到Oracle数据表中的TEST_INTEGER、TEST_VA
将API与ACL策略进行绑定 功能介绍 将API与ACL策略进行绑定。 同一个API发布到不同的环境可以绑定不同的ACL策略;一个API在发布到特定环境后只能绑定一个同一种类型的ACL策略。 调试 您可以在API Explorer中调试该接口,支持自动认证鉴权。API Explorer可以自动
批量删除资产。 创建批量删除指定条件的资产的作业任务。 最大支持100个应用和任务。 一个用户同一时刻只能创建一个资产删除作业任务,没有Running状态的作业任务存在。 调试 您可以在API Explorer中调试该接口,支持自动认证鉴权。API Explorer可以自动生成SDK代码示例,并提供SDK代码示例调试功能。
捕获异常包含错误信息。只有当捕获的异常信息中包含指定错误信息时,会进行异常处理步骤。 重试次数 发生异常时对监控部分流程的最大重试次数。 重试间隔(秒) 发生异常时对监控部分流程的重试间隔,单位为秒。 配置示例 图中配置对mysql组件获取记录操作进行异常监控。若出现运行异常且错误消息中包含test,将对
据库类型数据源,只支持源端一个数据表到目标端一个数据表的集成同步。 创建数据集成任务(组合任务):组合任务,通过CDC(Change Data Capture,数据变更抓取)实现源端到目标端数据的实时同步及增量同步,支持一个源端多个数据表到一个目标端多个数据表的集成同步。当前支持Oracle、MySQL、SQL
插件和API本身相互独立,只有为API绑定插件后,插件才对API生效。为API绑定插件时需指定发布环境,插件只对指定环境上的API生效。 同一个API在同一个环境中只能绑定一个相同类型的插件。 已被API绑定的插件无法删除。 创建插件 登录ROMA Connect控制台,在“实例”页面单击实例上的“查看控制台”,进入实例控制台。
创建批量导出指定条件的资产的作业任务。 最大支持100个应用和任务。 一个用户同一时刻只能创建一个资产导出作业任务,请确保当前没有Running状态的资产导出作业任务存在。 调试 您可以在API Explorer中调试该接口,支持自动认证鉴权。API Explorer可以自动生成S
dbzxout为出站服务器名称,在3.b中设置。 xstrm为ROMA Connect连接用户名,在2.c中设置。 执行以下命令退出数据库连接。 exit; Oracle为CDB数据库时的配置 建议由数据库管理员进行CDC功能的配置操作。 开启日志归档和XStream。 在命令行工具中执行以下命令以sys用户连接到数据库。
同步数据库和缓存数据 概述 当模型采集中采集任务执行失败时,采集日志显示数据库和缓存不一致时,可以从数据源和任务的维度,执行同步任务,使数据库和缓存保持一致,解决采集任务异常。 前提条件 已完成采集技术模型和录入业务模型。 操作步骤 登录ROMA Connect,在“实例”页面单
数据同步验证 连接Mysql数据源,在源端数据表中插入一条数据。 连接Oracle数据源,根据定时器设置的同步时间间隔等待一分钟,在目标端数据表中查看源端插入的数据是否已同步到Oracle。 父主题: 定时同步MySQL中的数据到Oracle
单位 任务执行周期的单位,与“调度周期”配合使用,可设置为“分”、“时”、“日”、“周”或“月”。 调度周期 任务执行周期,根据“单位”选择的不同,可设置值的范围不同。 例如“单位”选择“日”,“调度周期”设置为“1”,则表示数据集成任务每天执行一次。需确保调度周期大于任务执行时间,否则将导致任务执行失败。
以配合使用。 “数据拆分”为异步处理组件,如果一个任务中存在“数据拆分”节点,最终开放的API将返回传入“数据拆分”节点时的数据。 配置参数 参数 说明 表达式 数据拆分的表达式。 使用表达式将数据拆分为数据块,各个数据块将并行地执行后续流程。如payload数据为{"data":[{"id":1}
增量获取时间补偿。 表3 添加记录 参数 说明 表名 填写要插入数据的数据表名。 插入数据 填写插入操作中目标字段的值。 表4 更新记录 参数 说明 表名 填写要更新数据的数据表名。 更新数据 填写更新操作中目标字段的值。 WHERE条件 填写要更新数据的条件。 表5 同步记录 参数 说明 表名
创建导入资产作业任务,资产版本和具体哪些资产从资产内容里读取。 最大支持100个应用和任务。 一个用户同一时刻只能创建一个资产导入作业任务,没有Running状态的作业任务存在。 调试 您可以在API Explorer中调试该接口,支持自动认证鉴权。API Explorer可以自动生成SDK代码示例,并提供SDK代码示例调试功能。
Kafka Kafka是一个分布式流处理平台,最初由LinkedIn开发。它是一个高吞吐量、低延迟的平台,可以处理大量的实时数据流。Kafka主要由三个部分组成:生产者、消费者和代理服务器。生产者将数据发布到Kafka集群,消费者从Kafka集群订阅数据并进行处理,代理服务器则是
创建API分组 功能介绍 API分组是API的管理单元,一个API分组等同于一个服务入口,创建API分组时,返回一个子域名作为访问入口。建议一个API分组下的API具有一定的相关性。 URI POST /v1/{project_id}/apic/instances/{instance_id}/api-groups
数,若“请求Path”中包含Path参数时,还需要配置对应的“Path”参数。 必填:在API请求中,请求参数是否必填。 默认值:仅当“必填”为“否”时可配置请求参数的默认值。如果调用API时未给该参数赋值,则会使用该默认值。 说明: 请求参数可在后续节点中通过自定义变量的形式被引用,具体请参见自定义变量。
返回信息 返回指定名称的所有HTTP请求头 public Set<String> getHeadersToSign() 获取签名中的请求头 返回信息 返回签名中的请求头 public String getHttpProxy() 获取Http代理 返回信息 返回Http代理 public
请求参数匹配编排规则的生效优先级与列表顺序保持一致,列表中靠前的配置匹配优先级较高 如果编排规则列表中包含none_value类型的规则,则none_value类型的规则优先级最高,至多绑定一个none_value类型的规则; 如果编排规则列表中包含default类型的规则,则default
SourceConfig config) 传入数据源配置,构造一个数据源连接器 方法列表 返回类型 方法和说明 Object execute(String sql, Object... prepareValue) 执行SQL语句、存储过程或NOSQL查询语句 方法详情 public