检测到您已登录华为云国际站账号,为了您更好的体验,建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
连接名称 填写连接器实例名称。 主机IP地址 填写IBM MQ主机的IP地址。 端口 填写IBM MQ主机的端口。 队列管理器 提供队列服务和API及用于管理队列的管理功能的系统管理程序。 字符集标识 对消息中的字符串进行编码时要使用的字符集。 通道名称 通道是MQ系统中队列管理器之间传递消息的管道。
目的端数据格式选择“MySQL”,在选择表名后,目的端数据源页签会自动生成数据库表中的字段。 以下面的组合应用为例,该组合应用的主要功能是调用Open API获取OBS指定桶的对象列表,并将结果中的桶名称和对象名称通过数据映射,映射到MySql指定表中的相关字段,然后使用MySql添加记录的操作
仅当“配置类别”选择“高级”时需要配置。 填写DIS通道所在的区域。 Project ID 仅当“配置类别”选择“高级”时需要配置。 填写DIS通道所在的项目ID,您可以参考API凭证获取项目ID。 以接入其他区域的DIS为例,该DIS数据源的接入配置示例如下图所示。 图1 DIS数据源配置示例 完成数据源接入配置后,单击“开始检测”,检测ROMA
dasherize(string str) 使用kebab-case转换str中的单词,将str中的所有字母转换为小写,将所有空格转换为连字符(-)。 capitalize(string str) 使用大小写转换str中的单词,将每个单词的第一个字母变为大写,其余字母变为小写。 charCode(string
普通任务支持的集成模式(源端) 普通任务支持的集成模式(目标端) 组合任务支持的集成模式(源端) 组合任务支持的集成模式(目标端) 接入API数据源 定时 定时,实时 - - 接入ActiveMQ数据源 实时 定时,实时 - - 接入ArtemisMQ数据源 实时 定时,实时 -
网关登录 平台支持MQTT协议的connect消息接口,获取鉴权信息“clientId”、“Username”、“Password”。 参数说明 参数 必选/可选 类型 参数描述 clientId 必选 String(256) 一机一密的设备clientId由4个部分组成:dev
开发规范 开发建议 数据集成开发建议: ROMA Connect仅对连接器的RESTful接口做了规范定义,具体连接器对数据源的读写功能以及RESTful接口均需要您自行开发,您可以自行选择开发语言进行连接器开发。 连接器开发完成后,您需要自行部署连接器,并确保连接器所在网络与ROMA
Connect通过已发布的连接器实例接入自定义数据源,实现对数据源的读写。 前提条件 已完成连接器的线下开发和部署,连接器与ROMA Connect的对接接口开发请参考连接器RESTful接口规范。 已在ROMA Connect中创建连接器。 操作步骤 登录ROMA Connect控制台,在左侧的导航栏选择“资产管理”。
则使用内网连接地址。 TopicName为要生产消息的Topic名称。 ../config/producer.properties为配置文档所在的相对路径。 输入消息内容,向Topic发送消息。 >Message1 >Message2 >Message3 其中,Message1
Connect支持的数据源类型无法接入您使用的数据源,您可以自行开发一个数据源插件,用于实现对数据源的读写。 同时,这个数据源插件以标准RESTful接口形式供ROMA Connect接入,最终实现ROMA Connect对数据源的读写。 这个数据源插件称为连接器,这类通过连接器接入的数据源称为自定义数据源。
or.rar包。 如果使用自定义连接器来写数据,需要用户自行保证数据的可重复幂等写入。 RESTful接口单次请求的处理时间不能超过60s。 FDI端会循环调用RESTful接口地址,直到读完数据为止。 操作步骤 创建SpringBoot模板工程。 示例代码: @SpringBootApplication
data = "The msg is " + i; // 注意填写您创建的Topic名称。另外,生产消息的API有多个,具体参见Kafka官网或者下文的生产消息代码。 producer.produce("topicName"
根据实际业务需求,合理增加消费者个数(消费并发度),建议消费者数量和分区数保持一致。 提高消费者的消费速度,通过优化消费者处理逻辑(减少复杂计算、第三方接口调用和读库操作),减少消费时间。 增加消费者每次拉取消息的数量:拉取数据/处理时间 >= 生产速度。 生产者端 生产消息时,给消息Key加随机后缀,使消息均衡分布到不同分区上。
9093 MQS 公网访问端口 9094、9095、9096 MQS 公网SSL模式访问端口 9095、9096、9097 MQS RESTful接口访问端口 9292 可能是配置的Topic有误。 您需要使用有发布权限的Topic进行消息的发布,请检查您的Topic是否有发布权限。您可