检测到您已登录华为云国际站账号,为了您更好的体验,建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
延时 “延时”处理器用于创建指定时间的延迟。其典型使用场景是若某步骤为耗时任务,且后续步骤依赖于该步骤的执行结果时,可在两步骤之间添加“延时”处理器,以保证后续步骤可正常执行。 配置参数 参数 说明 延迟时间(ms) 延迟的时长,单位为ms。 父主题: 处理器
源数据库重启等操作对组合任务是否有影响? 在业务使用过程中,Oracle等数据库可能需要扩容、重启等操作,这些操作对组合任务的影响主要包含以下两种: 如果变更中重启耗时较短,组合任务中会重试连接,恢复正常运行任务。 如果变更中重启耗时较长,任务会报错失败,等变更完成,需重启组合任务。
千条数据超过5秒,一般是性能劣化的表现。 解决方案 如果对DWS的某个表频繁访问,会导致写入性能逐渐降低,需要对DWS进行调优,例如,定时使用analyze规划表、VACUUM FULL等。 父主题: 数据集成组合任务
“数据筛选”组件会作为“数据拆分”组件的后续步骤以配合使用。 配置参数 参数 说明 表达式 数据筛选的表达式。 使用表达式对数据进行筛选,并传递给后续节点。例如数据拆分出的多个数据块为{"id":1}和{"id":2},可使用表达式${payload.id} > 1,筛选出数据块{"id":2}。
常“数据拆分”组件后续会连接“数据筛选”组件以配合使用。 “数据拆分”为异步处理组件,如果一个任务中存在“数据拆分”节点,最终开放的API将返回传入“数据拆分”节点时的数据。 配置参数 参数 说明 表达式 数据拆分的表达式。 使用表达式将数据拆分为数据块,各个数据块将并行地执行后
Connect实例开启了MQS的SASL_SSL时,需要配置Topic的连接授权,把消息收发权限授权给集成应用。客户端向Topic发布和订阅消息时,需要使用授权集成应用的Key和Secret进行安全认证。 Topic所属的集成应用默认具备向Topic发布和订阅消息的权限。 修改或删除Topic
是否SASL_SSL ROMA Connect与Kafka的连接是否使用SASL_SSL认证加密。 用户名/应用Key 仅当“是否SASL_SSL”选择“是”时需要配置。 SASL_SSL认证所使用的用户名,如果使用ROMA Connect的消息集成作为Kafka数据源,则用户名为集成应用的Key。
导入组合应用:支持导入JSON格式组合应用文件。 导出组合应用:支持导出JSON格式组合应用文件。 约束与限制 带有自定义连接器的组合应用导出后,暂不支持导入到其他环境使用。 连接器的连接实例信息不支持导出。 导出组合应用 登录新版ROMA Connect控制台。 在左侧导航栏选择“组合应用”,在组合应用页面找到要导出的组合应用。
选择前端API的安全认证方式,推荐使用APP认证方式。 APP认证:表示由ROMA Connect对API请求进行安全认证。用户调用API时,使用集成应用的Key和Secret进行API请求的安全认证。 华为IAM认证:表示由IAM对API请求进行安全认证。用户调用API时,使用Token或AK/SK进行API请求的安全认证。
选择前端API的安全认证方式,推荐使用APP认证方式。 APP认证:表示由ROMA Connect对API请求进行安全认证。用户调用API时,使用集成应用的Key和Secret进行API请求的安全认证。 华为IAM认证:表示由IAM对API请求进行安全认证。用户调用API时,使用Token或AK/SK进行API请求的安全认证。
接入Redis数据源 概述 ROMA Connect支持把Redis数据库作为一个数据源,并用于数据集成任务或用于创建数据API。在使用Redis数据源前,您需要先接入数据源。 前提条件 每个接入的数据源都要归属到某个集成应用下,在接入数据源前您需要有可用的集成应用,否则请提前创建集成应用。
集成应用的用户授权信息为非资产数据,在导入集成资产后根据需要重新配置。 对于资产恢复场景,需要对导入的集成应用进行配置。 对于资产迁移场景,可根据实际使用逐步配置。 前提条件 已完成集成资产的导入。 操作步骤 在实例控制台的“集成应用”页面,单击集成应用右侧的“应用授权管理”。 在应用授权管理弹窗中,配置应用的授权信息。
接入FTP数据源 概述 ROMA Connect支持把FTP作为一个数据源,并用于数据集成任务。在使用FTP数据源前,您需要先接入数据源。 前提条件 每个接入的数据源都要归属到某个集成应用下,在接入数据源前您需要有可用的集成应用,否则请提前创建集成应用。 操作步骤 登录ROMA
低下。 停车用户无法实时了解停车场的空余车位情况,在找车位过程中需要耗费大量时间,进一步增加道路交通压力。 交通部门无法实时掌握城市停车位使用情况,难以针对停车问题制定有效的交通缓解措施。 解决方案 本章节介绍如何通过ROMA Connect对传统停车场的管理系统进行数字化改造,
一机一密的设备“Username”。 使用deviceId接入时填写为设备注册成功后返回的“deviceId”值。 使用nodeId接入时填写为设备注册成功时的“nodeId”值。 Password 必选 String(256) Password的值为使用“HMACSHA256”算法以时
填写API的发布说明信息。 发布API后,在API列表中单击该API的名称,进入API运行页面。在页面右上角单击“更多 > 发布历史”,可以查看API的发布历史信息。另外还可以查看每个发布版本的API配置以及切换API到历史的发布版本。 父主题: 开放API
Object> config) 将对象转换为json字符串,使用config中的配置。 例如,config中可设置"date-format"为"yyyy-MM-dd HH:mm:ss" 输入参数 object:输入对象 config:转换使用的配置 返回信息 转换得到的json字符串 public
生产消息 不能直接返回方法produce(String topic, String message),否则会导致返回信息为空。例如在使用示例中,不能直接使用“return record”句式,否则返回的信息为空。 方法详情 public org.apache.kafka.clients
自定义HTTP响应 配置参数 参数 说明 响应头 配置API响应信息中的响应头参数。可使用常量值,也可通过引用变量的方式引用前序节点中的数据。 响应体 配置API响应信息中的响应体内容,可使用常量值,也可通过引用变量的方式引用前序节点中的数据。 响应码 配置API响应信息中的响应
”。 资产恢复场景,选择“覆盖导入”。 资产迁移场景,选择“新增导入”。 在弹窗中选择本地保存的资产文件,并导入。 完成后单击“关闭”,您可以在实例中查看已导入的资产。 父主题: 恢复/迁移集成资产