检测到您已登录华为云国际站账号,为了您更好的体验,建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
若测试结果为“测试连接成功!”,则继续下一步。 若测试结果为“测试连接失败!”,则检查数据源状态和数据源连接参数配置,然后单击“测试连接”,直到连接成功为止。 单击“保存”,完成数据源的接入。 父主题: 数据源管理
配置触发器节点。根据触发器节点类型,配置对应的触发参数,如Open API节点您可能需要配置API请求参数和请求Body等。 图3 配置Open API节点参数 单击“保存”,开启工作流调试。 执行调试操作,对工作流进行调试。 图4 调试工作流 添加断点:单击工作流中的节点,即可添加断点,工作流在调试过程中可
接入OBS数据源 概述 ROMA Connect支持把OBS(对象存储服务)作为一个数据源,并用于数据集成任务。在使用OBS数据源前,您需要先接入数据源。 前提条件 每个接入的数据源都要归属到某个集成应用下,在接入数据源前您需要有可用的集成应用,否则请提前创建集成应用。 操作步骤
配置请参见触发器。 执行动作:执行动作可选择各类型的连接器和处理器,具体触发器和连接器的配置请参考连接器和处理器。 编辑完成后单击右上角“保存”。 父主题: 订阅资产
60。x86架构可取值为30、60、240、1440和-1。除-1外,其它值的单位为“分钟”。实例无操作超过自动休眠时长后,将会被暂停(已保存的数据不会被删除)。-1表示实例不会自动停止。 repository_id 解放号的仓库ID,解放号场景下使用。 stack_id 技术栈
区域和可用区 什么是区域、可用区? 我们用区域和可用区来描述数据中心的位置,您可以在特定的区域、可用区创建资源。 区域(Region):从地理位置和网络时延维度划分,同一个Region内共享弹性计算、块存储、对象存储、VPC网络、弹性公网IP、镜像等公共服务。Region分为通用
数据源为IMF类型且mq_type为RabbitMQ时需要配置。 最小长度:1 最大长度:65535 database_name 否 String 数据库名称。 数据源为DWS、HANA、RABBITMQ、SAP、SNMP、IBMMQ,obs类型时需要配置。 数据源为MYSQL、SQLSER
当“执行动作”选择“FDI任务”时需要配置。 选择需要执行的下一个FDI任务。如当前任务执行完成而选择的FDI任务如果处于运行中,跳过本次调度。 完成配置后,单击“保存”,完成数据集成任务的配置。 父主题: 创建数据集成任务(普通任务)
数据源为IMF类型且mq_type为RabbitMQ时需要配置。 最小长度:1 最大长度:65535 database_name String 数据库名称。 数据源为DWS、HANA、RABBITMQ、SAP、SNMP、IBMMQ,obs类型时需要配置。 数据源为MYSQL、SQLSER
MQS消息堆积最佳实践 方案概述 Kafka将Topic划分为多个分区,消息被分布式存储在分区中。同一个消费组内,一个消费者可同时消费多个分区,但一个分区在同一时刻只能被一个消费者消费。 在消息处理过程中,如果客户端的消费速度跟不上服务端的发送速度,未处理的消息会越来越多,这部分
Kafka Kafka是一个分布式流处理平台,最初由LinkedIn开发。它是一个高吞吐量、低延迟的平台,可以处理大量的实时数据流。Kafka主要由三个部分组成:生产者、消费者和代理服务器。生产者将数据发布到Kafka集群,消费者从Kafka集群订阅数据并进行处理,代理服务器则是
Hive”。 数据源名称 选择接入数据源中已配置的MRS Hive数据源。 源端数据库名 选择MRS Hive数据源中要获取数据的数据库。 说明: 需要使用自建的数据库,不能使用MRS Hive自带的default数据库。 源端表 选择MRS Hive数据源中要获取数据的数据表。选择数据表
Kafka Kafka是一个分布式流处理平台,最初由LinkedIn开发。它是一个高吞吐量、低延迟的平台,可以处理大量的实时数据流。Kafka主要由三个部分组成:生产者、消费者和代理服务器。生产者将数据发布到Kafka集群,消费者从Kafka集群订阅数据并进行处理,代理服务器则是
/filebeat.yml:/usr/share/filebeat/filebeat.yml # 如果需要把Filebeat收集到的日志数据保存到本地log目录下,则取消本行代码注释 # - ./log:/usr/share/filebeat/data # fil
IBM MQ IBM MQ是IBM提供的一个消息队列软件,它可以在分布式系统中进行异步通信,确保数据的可靠传输。MQ是一种基于消息的中间件,它提供了一种可靠、安全的方式来传输消息,可以在不同的应用程序、平台和系统之间进行通信。MQ可以确保消息在传输过程中不会丢失、重复或失序,并且
使用ROMA Connect集成服务 概述 ROMA Connect支持将API、数据源和自定义函数封装成标准的RESTful API,并对外开放。ROMA Connect为API提供了完整的生命周期管理和多层的安全防护管理。 本章节通过完成一个使用ROMA Connect开放A
IBM MQ IBM MQ是IBM提供的一个消息队列软件,它可以在分布式系统中进行异步通信,确保数据的可靠传输。MQ是一种基于消息的中间件,它提供了一种可靠、安全的方式来传输消息,可以在不同的应用程序、平台和系统之间进行通信。MQ可以确保消息在传输过程中不会丢失、重复或失序,并且
数脚本。 函数脚本的编写说明请参考自定义后端开发(函数后端)。 当前函数API支持的脚本大小最大为32KB。 完成后在页面右上角单击“保存”,保存函数后端配置。 测试后端功能。 在页面右上角单击“测试”,在下方的“测试参数”处,根据后端服务的定义添加请求参数,然后单击“立即测试”,发送请求。
不覆盖:当导入的数据源存在同名数据源时,不做更新。 输入前缀。 同一实例的数据集成任务名不可以重复,如含有相同名称的FDI任务,请输入前缀。 在弹窗中选择本地保存的资产文件,并导入。 完成后单击“关闭”,您可以在实例中查看已导入的资产。 自定义认证名称全局唯一,若导入资产时实例中已有相同名称的自定义
若使用Excel工具编辑导入文件,在编辑完成后需要按如下操作保存。 在Excel中保存时,以另存的方式保存为“CSV(逗号分隔)(*.csv)”类型文件。 使用文本编辑器打开1中保存的csv格式文件,并再次另存,另存时编码选择“带有 BOM 的 UTF-8”,保存后即得到最终的csv格式导入文件。 导入设备