检测到您已登录华为云国际站账号,为了您更好的体验,建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
的实际消息内容,一行为一条消息。 若要断开与Topic的连接,按“Ctrl+C”断开连接。 从Topic消费消息。 一个消费者从一个Topic的多个分区消费消息时,一次只能消费一个分区的消息,多个分区会分多次进行消费。 执行以下命令,与Topic建立消费消息的连接并读取消息。 .
发布+订阅:表示支持对Topic发布消息和订阅消息。 发布:表示仅支持对Topic发布消息。 订阅:表示仅支持对Topic订阅消息。 分区数 设置Topic的分区数,合理设置分区数量,可以提升消息生产与消费的并发性能。 分区数设置为1时,消费消息时可按照先入先出的顺序进行消费。 副本数
响应消息头 调用API时,APIC增加如下响应消息头。 X-Apig-Mode: debug表示响应消息头增加APIC调试信息。 响应消息头 描述 说明 X-Request-Id 请求ID 所有合法请求,都会返回此参数 X-Apig-Latency 从APIC接收请求到后端返回消息头的用时
业务对接适配和验证 概述 在ROMA Connect实例中完成集成资产的恢复或迁移后,周边对接的业务应用也需要完成相应的对接适配,才能正常处理业务。 业务对接适配 与ROMA Connect对接的业务应用或设备,需要修改如下对接配置。 分类 业务场景 配置数据 服务集成 调用API
getPlainCertificate(String key) 解密密码箱中证书密码的key值 输入参数 key:证书密码的key值 返回信息 返回解密后的证书密码消息体,消息体如下格式: { "cipherType": "CERTIFICATE", "passphrase": "xxx", "privateKey":
开发说明 开发场景 开发规范 客户端使用建议 客户端参数配置建议 父主题: 消息集成开发指导
Kafka业务迁移 概述 Kafka业务迁移指将连接其他Kafka的生产与消费消息的客户端切换成连接ROMA Connect,部分还涉及将持久化的消息文件迁移到ROMA Connect上。 在业务迁移过程中,连续性要求高的业务,需要平滑迁移,不能有长时间的中断。 迁移准备 确保消息生产与消费客户端与ROMA
topic_messages 队列消息总数 统计队列当前的消息总数。 ≥0 单位:个 队列 1分钟 produced_messages 生产消息数 统计目前生产的消息总数。 ≥0 单位:个 队列 1分钟 partition_messages 分区消息数 统计分区中当前的消息个数。 ≥0 单位:个
数据同步验证 连接Mysql数据源,在源端数据表中插入一条数据。 连接Oracle数据源,根据定时器设置的同步时间间隔等待一分钟,在目标端数据表中查看源端插入的数据是否已同步到Oracle。 父主题: 定时同步MySQL中的数据到Oracle
息的最终目的在于将消息内容传递给其他系统,使对方能按照约定处理该消息。 消费者 消费者为从消息主题(Topic)订阅消息的一方,订阅消息的最终目的在于处理消息内容。如日志集成场景中,监控告警平台作为消费者从Topic订阅日志消息,识别出告警日志并发送告警消息/邮件。 分区 Kaf
创建函数API 概述 ROMA Connect支持把自定义函数定义为后端服务,把函数的能力以API的形式对外开放。 前提条件 如果后端服务需要使用签名密钥请求发送方进行认证,请提前创建签名密钥。 部署并发布后端服务时,如果需要使用自定义认证方式进行API的安全认证,请提前创建自定义认证。
操作。 消息集成API MQS实例管理 MQS实例相关API,可查询实例相关信息。 主题管理 消息Topic相关API,包括Topic查询、删除等操作。 应用权限管理 消息Topic权限相关API,包括Topic权限更新、查询等操作。 消息管理 消息相关API,包括消息的查询、重发等操作。
请求Header参数 参数 是否必选 参数类型 描述 X-Auth-Token 是 String 用户Token。通过调用IAM服务获取用户Token接口获取(响应消息头中X-Subject-Token的值)。 响应参数 状态码: 200 表4 响应Body参数 参数 参数类型 描述 -
简易认证。 操作步骤 登录ROMA Connect控制台,在“实例”页面单击实例上的“查看控制台”,进入实例控制台。 在左侧的导航栏选择“服务集成 APIC > 凭据管理”,在“凭据管理”页签中单击API所授权凭据的名称,进入凭据详情页面。 在页面的“AppCodes”下,单击“添加AppCode”。
配置API授权(可选) 概述 仅使用APP认证方式的API,才需要配置调用授权,把API授权给指定集成应用。用户调用API时,使用集成应用的Key和Secret进行API请求的安全认证。 若API开启了简易认证,可直接使用集成应用中配置的AppCode进行简易安全认证,无需使用Key和Secret进行签名认证。
None 功能操作 应用与数据集成平台 ROMA Connect 介绍怎样创建ROMA Connect实例 04:08 创建ROMA Connect实例 应用与数据集成平台 ROMA Connect 介绍怎样接入数据源 01:54 接入数据源 应用与数据集成平台 ROMA Connect
校验API定义 功能介绍 校验API定义。校验API的路径或名称是否已存在 调试 您可以在API Explorer中调试该接口,支持自动认证鉴权。API Explorer可以自动生成SDK代码示例,并提供SDK代码示例调试功能。 URI POST /v2/{project_id}
Connect实例生命周期 到期预警 包年/包月ROMA Connect实例在到期前第7天内,系统将向用户推送到期预警消息。预警消息将通过邮件、短信和站内信的方式通知到华为账号的创建者。 到期后影响 当您的包年/包月ROMA Connect实例到期未续费,首先会进入宽限期,资源状态变为
上线V2版本数据集成API和设备集成API。 消息集成的“查询MQS实例列表”、“查询Topic列表”、“重发消息”接口补充了query参数,优化了部分参数描述。 2020-12-24 上线公共资源API和消息集成API。 2020-09-29 上线V2版本服务集成API,修改设备集成API参数问题。
请求Header参数 参数 是否必选 参数类型 描述 X-Auth-Token 是 String 用户Token。通过调用IAM服务获取用户Token接口获取(响应消息头中X-Subject-Token的值)。 表3 请求Body参数 参数 是否必选 参数类型 描述 topics 是 Array