检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
Connect控制台，在“实例”页面单击实例上的“查看控制台”，进入实例控制台。 在左侧的导航栏选择“消息集成 MQS > Topic管理”，单击Topic右侧的“设置集成应用权限”。 在设置集成应用权限弹窗中，为集成应用配置授权。 在“应用列表”处勾选要授权的集成应用，然后在“已选择”处为已选择的集成应用配置权限。
自定义API响应的header参数。为简单起见，此处不设置。 配置返回结果的响应示例，用于帮助API调用者了解API请求的响应信息。 图5 返回结果信息 表5 返回结果信息 参数 配置说明 成功响应示例 根据后端服务的成功响应消息来设置响应示例。此处成功响应示例设置为“ROMA TEST!”。 失败响应示例
勾选要授予API调用权限的集成应用。 访问参数 为授权的集成应用设置访问参数。访问参数会被添加到后端签名认证信息中，并发送给后端服务，后端服务根据携带的访问参数返回不同的响应参数。 绿色通道 选择是否开启绿色通道，开启绿色通道后，需要设置白名单和黑名单。 白名单 仅当“绿色通道”开启时需要配置。
勾选要授予API调用权限的集成应用。 访问参数 为授权的集成应用设置访问参数。访问参数会被添加到后端签名认证信息中，并发送给后端服务，后端服务根据携带的访问参数返回不同的响应参数。 绿色通道 选择是否开启绿色通道，开启绿色通道后，需要设置白名单和黑名单。 白名单 仅当“绿色通道”开启时需要配置。
日志采集 “日志采集”处理器用于自定义日志信息，并显示在当前任务的运行日志中（日志级别为Debug）。 配置参数 参数 说明 日志信息 设置日志内容，可使用常量，也可通过变量的方式引用前序步骤中的数据，具体请参考引用变量。 父主题： 处理器
任务源端数据源类型元数据定义。 数据源为API配置。 path 否 String 文件路径。 FTP服务器中要访问的文件夹路径，例如“/data/FDI”。 file_name 否 String 文件名。 FTP服务器中要访问的文件。 file_name_charset 否 String 文件名称字符编码。
表1 资源规划 资源 资源说明 数量 MySQL 2核 4GB 1 Oracle 2核 4GB 1 新版ROMA Connect实例 配额设置为组合应用，2RCU 1 父主题： 定时同步MySQL中的数据到Oracle
持实时任务，此处选择“实时”。 任务标签 添加任务标签，用来对任务进行分类，方便用户快速查询。为简单起见，此处不设置。 企业项目 选择任务所属的企业项目，保持默认设置“default”。 配置源端MQS数据源信息。 表4 源端配置信息 参数 配置说明 源端实例 选择当前正在使用的ROMA
应用管理 校验应用是否存在 查询应用列表 创建应用 查询应用详情 更新应用 删除应用 查询应用密钥 重置应用密钥 查询用户成员列表 设置用户成员 查询候选用户成员 父主题： 公共资源API
Milvus Milvus连接器用于连接Milvus数据库，负责建立和维护应用程序和Milvus数据库之间的连接，并管理数据的传输。 Milvus是一种高性能、高扩展性的向量数据库，可在从笔记本电脑到大型分布式系统等各种环境中高效运行。它既可以开源软件的形式提供，也可以云服务的形式提供。
展示，填写完成后单击“确定”。 根据规划的架构拖拽“节点”或“分组”到右侧绘制框中。 右键拖拽的“节点”或“分组”，可进行属性设置。 表2 节点属性设置 参数 参数说明 名称 自定义此节点的名称。 背景颜色 自定义修改此节点的背景颜色。 高度 自定义此节点边框高度，也可在绘制框中直接拖拽。
lock_scene String 限制操作场景： TO_PERIOD_LOCK：按需转包周期场景锁，不允许进行删除、规格变更、按需转包周期等 SPEC_CHG_LOCK：包周期规格变更场景锁，不允许进行删除、规格变更等 lock_source_id String 发起限制操作对象的标志
接入Modbus协议设备 接入OPC UA协议设备 配置数据转发规则 订阅设备通知 06 实践 通过提供多种场景的ROMA Connect使用样例，方便您快速了解如何使用ROMA Connect完成应用和数据集成。 传统停车场管理系统数字化改造 企业数据以API形式开放共享 跨系统业务数据集成和转换 搭建企业业务开放中台
消费者的消费能力不足（消费者并发低、消息处理时间长），导致消费效率低于生产效率。 消费者异常（如消费者故障、消费者网络异常等）导致无法消费消息。 Topic分区设置不合理，或新增分区无消费者消费。 Topic频繁重平衡导致消费效率降低。 实施步骤 从消息堆积的原因看，消息堆积问题可以从消费者端、生产者端和服务端三个方面进行处理。
object, Map<String,Object> config) 将对象转换为Json字符串，使用config中的配置。 例如，config中可设置“date-format”为“yyyy-MM-dd HH:mm:ss” static Map<String,Object> toMap(String
任务标签 添加任务标签，用来对任务进行分类，方便用户快速查询。为简单起见，此处不设置。 企业项目 选择任务所属的企业项目，保持默认设置“default”。 配置任务计划信息。 为简单起见，任务计划信息保持默认设置。 配置源端API数据源信息。 图1 源端配置信息 表4 源端配置信息 参数
er参数。多个字段间使用英文逗号（,）分隔，支持使用*进行通配设置。 日志包含请求QueryString信息：勾选后，需填写日志中要携带的请求Query参数信息。多个字段间使用英文逗号（,）分隔，支持使用*进行通配设置。 日志包含请求Body体信息：勾选后，日志中会携带API请求的Body体信息。
返回给定的日期时间，分钟数和秒数设置为0。 atBeginningOfMonth(string datetime) 返回给定的日期时间，日期设置为月份的第一天，时间设置为午夜。 atBeginningOfWeek(string datetime) 返回当前星期第一天的给定的日期时间，并将时间设置为午夜。
用direct交换器生产消息，把消息路由到bindingKey与routingKey完全匹配的Queue中。 输入参数 routingKey：消息路由键 props：消息持久化设置，非必填 message：消息内容 public void produceWithTopicExchange(String bindingKey
连接器 触发器 HTTP 数据库 华为云服务 SaaS应用 邮箱 其他 消息系统 自定义连接器
长按/截图保存，微信识别二维码
或者关注公众号“华为云”
