检测到您已登录华为云国际站账号,为了您更好的体验,建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
实例节点出现故障的情况下,单副本Topic查询消息时会出现内部错误问题,因此不建议使用单副本Topic。 老化时间(小时) 设置Topic中存储消息的老化时间,超过老化时间的消息将会被删除。 同步复制 客户端向Topic生产消息时,是否把消息复制给所有副本,然后才向消息客户端返回响应。
是否开启同步复制,开启后,客户端生产消息时相应的也要设置acks=-1,否则不生效,默认关闭。 retention_time 否 Integer 消息老化时间。默认值为72。取值范围1~168,单位小时。 tag 否 String 权限类型对应的标签。 当权限类型是all时,发布和订阅的标签用符号“&”隔开。
组。 表2 messages参数 参数 类型 必选 说明 content Object 是 消息内容。 id String 是 消息序号,序列号不能重复。 请求示例 { "messages": [ { "content": "hello roma-1"
后端服务调用失败 原因分析 可能是以下三种原因导致,请逐一排查: 后端服务地址错误。 后端超时时间设置不合理。 当后端服务没有在设置的后端超时时间内返回时,API网关提示后端服务调用失败。 如果“后端服务地址”在ECS(Elastic Cloud Server),ECS的安全组无法被外部访问。
product_id integer 产品ID。 product_name string 产品名。 product_serial string 产品序列号。 remark string 描述信息,不能超过200个字符。 user_name string 用户名。 响应示例 { "product_id":
查看某个API的调用统计,包括“请求次数”、“出错统计”、“数据流量”和“调用延时”。 选择“集成应用”和“API”,筛选要查看统计数据的API,并可以选择要查看数据的时间段范围。 近1小时数据每2分钟刷新一次。 近6小时数据每2小时刷新一次。 近一天数据每2小时刷新一次。 近一周和近一月数据每天刷新一次。 父主题:
product_id integer 产品ID。 product_name string 产品名。 product_serial string 产品序列号。 remark string 描述信息,不能超过200个字符。 user_name string 用户名。 响应示例 { "total":
Hive读写文件格式只支持rcfile和textfile类型。 MRS Hive作为源端最大只支持100万数据量表的同步。 API数据源类型 超时时间为60秒,服务端响应时间若超过60秒会触发任务执行报错。 API作为源端,单次请求最大支持读取的数据大小为20M,超过此大小必须分页分批读取。 API
ROMA Connect会自动在每个副本上备份数据,当其中一个副本故障时数据依然可用,Topic的副本数越多,可靠性越高。 老化时间(小时) 超过老化时间后,Topic中存储的消息将会被删除。 同步复制 客户端向Topic生产消息时,是否把消息复制给所有副本,然后才向消息客户端返回响应,此处不启用。
按需计费适用于具有不能中断的短期、突增或不可预测的应用或服务,例如电商抢购、临时测试、科学计算。 计费周期 按需计费的新版ROMA Connect资源按秒计费,每一个小时整点结算一次费用(以GMT+8时间为准),结算完毕后进入新的计费周期。计费的起点以新版ROMA Connect实例创建成功的时间点为准,终点以实例删除时间点的小时整点为准。
服务集成请求后端服务的超时时间。最大超时时间可通过实例特性backend_timeout配置修改,可修改的上限为600000 单位:毫秒。 最小值:1 authorizer_id String 后端自定义认证ID id String 编号 register_time String 注册时间 status
服务集成请求后端服务的超时时间。最大超时时间可通过实例特性backend_timeout配置修改,可修改的上限为600000 单位:毫秒。 最小值:1 authorizer_id String 后端自定义认证ID id String 编号 register_time String 注册时间 status
设备数字化与统一集成 ROMA Connect使用MQTT、网关等多种方式协议连接各种类型设备与企业后台,实现企业后台与设备双向通讯。 故障预测与告警 在控制台上集成所有设备的信息,进行实时监控和预警分析,一旦设备的参数出现异常,ROMA Connect会在控制台上生成告警信息,提
益。 长期项目:对于周期较长的项目,如科研项目、大型活动策划等,包年/包月计费模式可以确保在整个项目周期内资源的稳定使用。 业务高峰预测:如果能预测到业务高峰期,如电商促销季、节假日等,可提前购买包年/包月资源以应对高峰期的需求,避免资源紧张。 数据安全要求高:对于对数据安全性要
HBase),且该MRS数据源均开启了Kerberos认证,则这两个数据集成任务不能同时运行,否则会导致集成任务运行失败。 任务列表中的“开始调度时间”为已创建且未启动的定时任务调度计划的开始生效时间。 已启动的任务,如果需要进行其他操作,例如修改等,需要先停止任务才可进行相关操作。 启动任务 登录ROMA Co
all -1 0 1 KeySerializer 键的序列化方式,默认为org.apache.kafka.common.serialization.StringSerializer。 ValueSerializer 值的序列化方式,默认为org.apache.kafka.common
group。 KeyDeserializer 键的反序列化方式,默认为:org.apache.kafka.common.serialization.StringDeserializer。 ValueDeserializer 值的反序列化方式,默认为:org.apache.kafka.common
预算来管理成本和使用量,在实际或预测超过预算阈值时,自动发送通知给指定消息接收人。企业还可以创建预算报告,定期将指定预算进展通知给指定消息接收人。 例如企业需要创建一个ROMA Connect实例的按需成本预算,每月预算金额为20000元,当预测金额高于预算金额的80%时发送预算告警。那么,创建的预算如下:
提交确认消费的超时时间,客户端需要在该时间内提交消费确认,如果超过指定时间,没有确认消费,系统会报消息确认超时或handler无效,则默认为消费失败。取值范围:1~300s。默认值:15s time_wait Integer 否 设定队列可消费的消息为0时的读取消息等待时间。 如果在等
Connect,部分还涉及将持久化的消息文件迁移到ROMA Connect上。 在业务迁移过程中,连续性要求高的业务,需要平滑迁移,不能有长时间的中断。 迁移准备 确保消息生产与消费客户端与ROMA Connect实例的消息集成MQS连接地址网络互通。您可以在ROMA Connec