微消息队列MQTT版_微消息队列MQTT版文档介绍内容-天翼云

查看监控数据
前提条件已创建Kafka实例,且实例中有可消费的消息。操作步骤步骤 1 登录管理控制台。步骤 2 在管理控制台右上角单击,选择区域。说明请选择Kafka实例所在的区域。步骤 3 在管理控制台左上角单击,选择“企业中间件”-“分布式消息服务”-“Kafka专享版”,进入分布式消息服务Kafka专享版页面。步骤 4 通过以下任意一种方法,查看监控数据。在Kafka实例名称后,单击。跳转到云监控页面,查看实例、节点、队列和消费组的监控数据,数据更新周期为1分钟。

来自：
帮助文档
分布式消息服务Kafka
用户指南
监控
查看监控数据
使用Logstash处理数据
这里以Kafka为例:auto_offset_reset:会决定从哪个位置开始消费消息bootstrap_servers:Kafka集群的地址consumer_threads:控制 Kafka 消费者线程的数量group_id:消费者组IDtopics:Kafka的主题列表codec:指定数据格式 filter部分可以进行消息处理、数据解析等操作。根据实际业务规则来处理。 output部分用于将处理后的数据推送到外部系统(如数据库、消息队列、搜索引擎等)。

来自：
帮助文档
云搜索服务
快速入门
使用Logstash处理数据
设置RabbitMQ告警规则
步骤 3 在管理控制台左上角单击,选择“企业中间件”-“分布式消息服务”->“RabbitMQ专享版”,进入分布式消息服务RabbitMQ专享版页面。步骤 4 通过以下任意一种方法,查看监控数据。在RabbitMQ实例名称后,单击“查看监控数据”。跳转到云监控页面,查看实例、节点和队列的监控数据,数据更新周期为1分钟。单击RabbitMQ实例名称,进入实例详情页。在左侧导航栏单击“监控”,进入监控页面,查看实例、节点和队列的监控数据,数据更新周期为1分钟。

来自：
帮助文档
分布式消息服务RabbitMQ
用户指南
监控
设置RabbitMQ告警规则
查询设备订阅信息
本文为您介绍分布式消息服务MQTT的API-设备客户端-查询设备订阅信息。

来自：
帮助文档
分布式消息服务MQTT
API参考
API
设备客户端
查询设备订阅信息
RocketMqProducer监控
clientIdclientId客户端实例标识-ENUMLASTgroup生产者组生产者组-ENUMLASTqueue消息队列消息队列标识-ENUMLASTpidpidpid-STRINGLASTconcurrentMax最大并发推送消息最大并发-INTMAXerrorCount错误次数推送消息的错误次数-INTSUMerrorTraceId错误traceId采集周期内发生错误的调用链对应的traceid-STRINGLASTinvokeCountinvokeCountPublish调用次数-INTSUMpublishedMsgCountpublishedMsgCount

来自：
帮助文档
应用性能管理
产品介绍
指标总览
消息队列
RocketMqProducer监控
步骤四：配置必须的监控告警
表1 RabbitMQ实例配置告警的指标指标名称告警策略指标说明解决方案内存高水位状态告警阈值:原始值=1连续触发次数:1告警级别:致命告...消息生产加快消费采用生产者确认的发送模式,并监控生产端消息生产速度和时长,当消息生产时长有明显增加时进行流控措施磁盘高水位状态告警阈值:原始值>=1连续触发次数:1告警级别:致命告警阈值为1表示触发磁盘高水位,会阻塞消息生产减少惰性队列的消息堆积减少持久化队列的消息堆积删除队列内存使用率告警阈值:原始值>业务预期使用率(推荐

来自：
帮助文档
分布式消息服务RabbitMQ
快速入门
步骤四：配置必须的监控告警
请求状态码
本文介绍分布式消息服务MQTT的API请求状态码。正常状态码描述 800 成功 900 失败

来自：
帮助文档
分布式消息服务MQTT
API参考
调用前须知
请求状态码
产品规格
1、实例规格分布式消息服务RabbitMQ兼容开源RabbitMQ 3.8.9,实例规格分为基础版,高级版。具体的规格分为基础版3节点4C8G,高级版3节点8C16G。存储类型为普通I/O。 2.目前基础版和高级版规格如下: 实例规格节点参考性能(TPS) 建议队列数最大连接数 4核 8GB 3 45000 600 3000*3 8核16GB 3 85000 1200 5000*3

来自：
帮助文档
分布式消息服务RabbitMQ
产品简介
产品规格
开启消息轨迹
本章节介绍了如何开启分布式消息服务RocketMQ实例的消息轨迹功能。操作场景查询消息轨迹前,需要先在客户端开启消息轨迹。本章节介绍使用Java和Go开启消息轨迹的方法。

来自：
帮助文档
分布式消息服务RocketMQ
用户指南
消息查询
开启消息轨迹
操作类常见问题
升级Broker可能产生消息乱序、客户端连接中断、消息量不均衡等影响。升级Broker包含以下影响: 升级过程中,会逐个重启云消息队列 Kafka 版集群中所有的Broker。在重启Broker的过程中服务不会中断,但是从每个Broker重启完成之后的5分钟内消费的分区消息可能会发生乱序。重启过程中已有的客户端连接可能会中断。客户端要有自动重连功能,服务端的其他Broker会自动接替服务。

来自：
帮助文档
分布式消息服务Kafka
常见问题
操作类
操作类常见问题
响应消息头
本章主要介绍响应消息头。调用API时,API网关增加如下响应消息头。 X-Apig-Mode: debug表示响应消息头增加API网关调试信息。

来自：
帮助文档
API网关
调用API网关
调用已发布的API
响应消息头
开启网卡多队列功能
说明云主机开启网卡多队列功能后,如果后续有新增或删除网卡,切换VPC等操作,需要重新对云主机设置网卡多队列,详细操作请参考执行网卡多队列的配置脚本。网卡多队列支持列表网卡多队列的支持情况和实例规格、虚拟化类型、镜像的操作系统有关,只有同时满足这些要求,弹性云主机才能开启网卡多队列功能。支持网卡多队列的实例规格请参见“实例规格(X86)规格清单、实例规格(鲲鹏)规格清单(鲲鹏)”。说明网卡多队列数为大于1的值,表示支持网卡多队列。虚拟化类型必须为KVM。

来自：
帮助文档
弹性云主机
用户指南
网卡
开启网卡多队列功能
开启网卡多队列功能
查看网卡队列数开启网卡多队列功能登录弹性云主机。

来自：
帮助文档
弹性云主机
用户指南
网卡
开启网卡多队列功能
队列弹性扩缩容
前提条件新创建的队列需要运行作业后才可进行弹性扩缩容。注意事项 16CUs队列不支持扩容和缩容。 64CUs队列不支持缩容。如果在“弹性扩缩容”页面提示“Status of queue xxx is assigning, which is not available”,表示需要等待队列资源分配完毕才可进行扩缩容。弹性扩容当前队列规格不满足业务需要时,可以通过手动变更队列规格来扩容当前队列。

来自：
帮助文档
数据湖探索
用户指南
队列管理
队列弹性扩缩容
创建方式简介
创建实时数据流集群:实时数据流集群提供高效的流式计算、消息队列等组件能力,支持实时数据ETL和日志采集分析的业务需求。创建自定义集群:自定义集群提供丰富灵活的服务搭配,支持自行选择业务所需服务。

来自：
帮助文档
翼MapReduce
用户指南
配置集群
创建方式简介
退订
本文为您介绍分布式消息服务MQTT退订内容。针对天翼云分布式消息服务MQTT退订操作,具体请参考退订流程。退订规则说明客户(天翼云用户)可根据需要,在符合天翼云退订规则的前提下,灵活退订资源。目前退订包含七天无理由全额退订和非七天无理由退订以及其他退订。七天无理由全额退订。

来自：
帮助文档
分布式消息服务MQTT
计费说明
退订
信息的获取
本文为您介绍分布式消息服务MQTT的API参考-如何调用API。登录云网门户,在“控制台”->“个人中心”->“ 第三方账号绑定 ”,通过创建或者查看获取ak,sk。

来自：
帮助文档
分布式消息服务MQTT
API参考
如何调用API
信息的获取
认证鉴权
介绍分布式消息服务MQTT认证鉴权内容。认证鉴权 AK/SK认证:通过AK(Access Key ID)/SK(Secret Access Key)加密调用请求。 AK/SK认证就是使用AK/SK对请求进行签名,在请求时将签名信息添加到消息头,从而通过身份认证。 AK(Access Key ID):访问密钥ID。与私有访问密钥关联的唯一标识符;访问密钥ID和私有访问密钥一起使用,对请求进行加密签名。 SK(Secret Access Key):私有访问密钥。

来自：
帮助文档
分布式消息服务MQTT
API参考
如何调用API
认证鉴权
公共参数
本文为您介绍分布式消息服务MQTT的API参考-如何调用API。请求头header参数参数名示例值参数类型是否必填参数描述 regionId 921d904cca2211e99aa20242ac110006 String 是资源池编码

来自：
帮助文档
分布式消息服务MQTT
API参考
如何调用API
公共参数
产品组件
支持文件、数据库、消息队列等多种数据源采集支持灵活的数据处理,如字段提取、数据脱敏等内置健康检查机制,支持通过API或可视化界面监控数据管道运行状态CerebroCerebro 是一个功能强大且易于使用的云搜索服务管理工具,适合开发、运维和数据分析等多种场景。通过Cerebro可以对实例进行Web可视化管理,如监控实时的磁盘、集群负载、内存使用率等,通过其直观的界面和丰富的功能,用户可以更高效地管理和监控云搜索实例。云搜索服务兼容开源Cerebro,适配0.9.4。

来自：
帮助文档
云搜索服务
产品介绍
产品组件
Kafka业务迁移
异步通信和消息队列:Kafka作为消息队列,可以用于异步通信和解耦系统之间的依赖关系。通过将同步的请求和响应转换为异步的消息,可以提高系统的可伸缩性和响应性能,实现松耦合的系统架构。日志收集和分析:Kafka可以用作日志收集和分析的中间件,用于接收和传递系统和应用程序的日志数据。通过将日志数据发送到Kafka中,可以实现日志的集中存储和分发。同时,可以使用Kafka的消费者来实时消费和分析日志数据,帮助进行故障排查、性能监控和安全审计等工作。

来自：
帮助文档
分布式消息服务Kafka
最佳实践
Kafka业务迁移
应用场景
结合消息队列Kafka、Logstash对日志数据进行采集清洗,进入Elasticsearch或OpenSearch中存储检索分析,并通过Kibana或Dashboards进行可视化呈现。高稳定:通过读写限流、查询熔断、集群监控等方式保障。性能优化:通过支持压缩算法、内核增强节省存储空间,增强读写速率、降低响应延迟。易用性:支持多种统计分析方法、划分维度,丰富的可视化查询,可对接BI实现拖拽式报表。

来自：
帮助文档
云搜索服务
产品介绍
应用场景
弹性资源池队列管理
弹性资源池优先满足两个队列的最小CU,队列A先分配32CU,队列B分配64CU,剩余CU数为32CU:弹性资源池的最大CU-两个队列的最小CU之和=128-32-64=32CU。2. 因为两个队列的优先级相同,则剩余32CU随机分配给两个队列。弹性资源池扩缩容CU分配场景说明(有任务场景) 场景弹性资源池实际CUs队列A资源分配队列B资源分配弹性资源池CU数分配说明弹性资源池添加了两个队列,分别为队列A和队列B。

来自：
帮助文档
数据湖探索
用户指南
弹性资源池
弹性资源池基本操作
弹性资源池队列管理
弹性资源池添加队列
弹性资源池队列添加完成后,可以参考弹性资源池队列管理查看弹性资源池添加的所有队列配置和策略信息。

来自：
帮助文档
数据湖探索
用户指南
弹性资源池
弹性资源池基本操作
弹性资源池添加队列
配置消息通知
向主题添加订阅要接收发布至主题的消息,您必须添加一个订阅终端节点到该主题。消息通知服务会发送一条订阅确认的消息到订阅终端,订阅确认的消息将在48小时内有效。如果订阅者在48小时之内确认订阅,将会收到推送至主题的消息。如果订阅者在48小时之内没有确认订阅,则需要再次给订阅者发送订阅确认的消息。 1.登录管理控制台。 2.选择“管理与监管 > 消息通知服务”。进入消息通知服务页面。 3.在左侧导航栏,选择“主题管理 > 主题”。进入主题页面。

来自：
帮助文档
翼MapReduce
用户指南
管理集群
集群运维
配置消息通知
日志处理工具Logstash接入Kafka
Kafka与Logstash互联 1、将Kafka作为消息输出目的地使用logstash将命令行输入的信息,传输到Kafka中名为“Logstash-test”的Topic队列。

来自：
帮助文档
分布式消息服务Kafka
最佳实践
日志处理工具Logstash接入Kafka
使用IAM授权的云服务
RabbitMQ全局是是是是有分布式消息服务RocketMQ全局是是是是有微服务云应用平台全局是是是是有云容器引擎全局是是是是有弹性容器实例全局是是是是有函数计算全局是是是是有云日志服务LTS全局是是是是有容器镜像服务全局是是是是有分布式消息服务MQTT全局是是是是有应用服务网格全局是是是是有微服务引擎全局是是是是有数据库云服务名称区域控制台OpenAPI系统策略支持IAM支持企业项目支持IAM支持企业项目分布式关系型数据库全局是是是是有关系数据库SQL Server版全局是是是是有关系数据库MySQL

来自：
帮助文档
统一身份认证（一类节点）
产品概述
使用IAM授权的云服务
设置自定义告警规则
如果某个用户不希望收到告警,则需要使用该用户的账号登录天翼云官网进入数据库管理平台消息中心 > 消息订阅,在告警信息设置中取消该用户的邮件、短信、企业微信和钉钉等。新建告警策略1.在天翼云官网首页的顶部菜单栏,选择产品 > 数据库 > 关系型数据库 > 关系数据库MySQL版,进入关系数据库MySQL产品页面。然后单击管理控制台,进入概览页面。2.在左侧导航栏,选择管理中心 > 告警中心 > 告警设置。3.单击新建告警策略,设置告警规则,您也可以对已创建的策略进行编辑修改。

来自：
帮助文档
关系数据库MySQL版
用户指南
监控与告警
设置自定义告警规则
创建虚拟主机
介绍分布式消息服务RabbitMQ创建虚拟主机操作内容。背景信息虚拟主机,用作逻辑隔离,分别管理各自的交换器、队列和绑定,使得应用安全地运行在不同的虚拟主机上,相互之间不会干扰。一个实例下可以有多个虚拟主机,一个虚拟主机里面可以有若干个交换器和队列。生产者和消费者连接分布式消息服务 RabbitMQ 版需要指定一个虚拟主机。操作步骤 (1)登录管理控制台。 (2)进入RabbitMQ管理控制台。 (3)在实例列表页在操作列,目标实例行点击“管理”。

来自：
帮助文档
分布式消息服务RabbitMQ
用户指南
虚拟主机管理
创建虚拟主机
消息通知概览
本文介绍消息通知的功能。消息通知是什么消息通知功能是网络管理与业务运营系统中的关键组件,它主要负责及时、精准地将各类重要事件信息传达给相关人员。无论是网络监测中带宽使用超量,还是业务流程出现异常状况,该功能都能自动生成对应的消息通知,让相关人员第一时间掌握情况,为后续处理争取时间,保障系统稳定运行和业务顺利开展。消息通知特点拥有高度灵活的配置能力,支持对消息类型、通知方式和接收对象进行自由组合设置。

来自：
帮助文档
边缘安全加速平台
零信任网络服务
设置
消息通知
消息通知概览
删除认证用户
本文为您介绍分布式消息服务MQTT的API-认证授权-删除认证用户。

来自：
帮助文档
分布式消息服务MQTT
API参考
API
认证授权
删除认证用户
应用拓扑
信息拓扑图通常包括以下信息: 应用或服务的组成部分:例如数据库、缓存、消息队列、Web 服务器等,当前版本支持的插件见下表,暂未支持的插件会显示为unknown。

来自：
帮助文档
应用性能监控
用户指南
应用列表
应用拓扑

天翼云最新活动

818算力跃迁·礼遇盛夏

爆款云主机2核2G限时秒杀，28.8元/年起！

免费体验DeepSeek，上天翼云息壤

新老用户均可免费体验2500万Tokens，限时两周

云上钜惠

爆款云主机全场特惠，更有万元锦鲤券等你来领！

算力套餐

让算力触手可及

天翼云AI产品特惠

8折特惠，新老同享不限购

中小企业服务商合作专区

国家云助力中小企业腾飞，高额上云补贴重磅上线

出海产品促销专区

爆款云主机低至2折，高性价比，不限新老速来抢购！

天翼云电脑专场

移动办公新选择，爆款4核8G畅享1年3.5折起，快来抢购！

智算服务

应用商城

定价

合作伙伴

开发者

支持与服务

了解天翼云

天翼云最新活动

产品推荐

弹性云主机

镜像服务

轻量型云主机

一体化计算加速平台·异构计算

天翼云CTyunOS系统

算力互联调度平台

训推服务

科研助手

智算一体机

推荐文档

文档下载

产品价格