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

清除队列容量配置
本章节主要介绍翼MapReduce的清除队列容量配置操作。操作场景当队列不再需要某个资源池的资源,或资源池需要与队列取消关联关系时,管理员可以在FusionInsight Manager清除队列配置。清除队列配置即取消队列在此资源池中的资源容量策略。前提条件如果队列需要清除与某个资源池的绑定关系,该资源池不能作为队列的默认资源池,需要先将队列的默认资源池更改为其他资源池,请参见配置队列。操作步骤登录FusionInsight Manager界面。

来自：
帮助文档
翼MapReduce
用户指南
FusionInsight Manager操作指导（适用于3.x）
租户资源
使用Capacity调度器的租户业务
管理资源
清除队列容量配置
使用Logstash处理数据
这里以Kafka为例:auto_offset_reset:会决定从哪个位置开始消费消息bootstrap_servers:Kafka集群的地址consumer_threads:控制 Kafka 消费者线程的数量group_id:消费者组IDtopics:Kafka的主题列表codec:指定数据格式 filter部分可以进行消息处理、数据解析等操作。根据实际业务规则来处理。 output部分用于将处理后的数据推送到外部系统(如数据库、消息队列、搜索引擎等)。

来自：
帮助文档
云搜索服务
快速入门
使用Logstash处理数据
修改队列网段
本章节主要介绍修改队列网段。使用增强型跨源时,如果DLI队列的网段和用户数据源的网段发生冲突,您可以通过修改网段操作更改队列的网段。说明如果待修改网段的队列中有正在提交或正在运行的作业,或者改队列已经绑定了增强型跨源,将不支持修改网段操作。修改队列网段步骤在DLI管理控制台左侧,选择“资源管理 > 队列管理”。选择待修改的队列,单击“操作”列“更多”中的“修改网段”。填写需要的网段后,单击“确定”。

来自：
帮助文档
数据湖探索
用户指南
队列管理
修改队列网段
消息订阅
本页介绍天翼云TeleDB数据库消息订阅。消息订阅可以对不同类型的消息进行订阅,选择需要的消息类型,保存后,订阅类型的消息会在触发时进行推送。

来自：
帮助文档
分布式融合数据库HTAP
私有云产品
管理平台使用手册
数据库资源与生命周期管理服务操作指南
消息中心
消息订阅
查询设备订阅信息
本文为您介绍分布式消息服务MQTT的API-设备客户端-查询设备订阅信息。

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

来自：
帮助文档
分布式消息服务RabbitMQ
用户指南
监控
设置RabbitMQ告警规则
RocketMqProducer监控
clientIdclientId客户端实例标识-ENUMLASTgroup生产者组生产者组-ENUMLASTqueue消息队列消息队列标识-ENUMLASTpidpidpid-STRINGLASTconcurrentMax最大并发推送消息最大并发-INTMAXerrorCount错误次数推送消息的错误次数-INTSUMerrorTraceId错误traceId采集周期内发生错误的调用链对应的traceid-STRINGLASTinvokeCountinvokeCountPublish调用次数-INTSUMpublishedMsgCountpublishedMsgCount

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

来自：
帮助文档
分布式消息服务RabbitMQ
快速入门
步骤四：配置必须的监控告警
生产消息
介绍分布式消息服务Kafka生产拨测功能操作内容。场景描述通过生产拨测,确保Kafka集群能够稳定接收并传递生产者发送的消息,同时消费者能够成功订阅并处理这些消息,以此确认集群的基本功能和网络连接均处于正常状态。操作步骤 (1)登录管理控制台。 (2)进入Kafka管理控制台。 (3)在实例列表页在操作列,目标实例行点击“管理”。 (4)点击“主题管理”后进入主题管理页面后点击“更多”,出现如下图弹窗 (5)点击“生产拨测”

来自：
帮助文档
分布式消息服务Kafka
用户指南
Topic管理
生产消息
产品规格
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
产品简介
产品规格
创建方式简介
创建实时数据流集群:实时数据流集群提供高效的流式计算、消息队列等组件能力,支持实时数据ETL和日志采集分析的业务需求。创建自定义集群:自定义集群提供丰富灵活的服务搭配,支持自行选择业务所需服务。

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

来自：
帮助文档
分布式消息服务MQTT
API参考
如何调用API
信息的获取
设置自定义告警规则
如果某个用户不希望收到告警,则需要使用这个用户的账号登录天翼云官网进入“数据库管理平台”-消息中心-消息订阅,取掉告警信息栏关于邮件、短信、企业微信和钉钉等。设置告警规则1.在天翼云官网首页的顶部菜单栏,选择产品 > 数据库 > 关系型数据库 > 关系数据库MySQL版,进入关系数据库MySQL产品页面。然后单击管理控制台,进入概览页面。2.在左侧导航栏,选择管理中心 > 告警中心 > 告警设置。3.单击新建策略,设置告警规则,您也可以对已创建的策略进行编辑修改。

来自：
帮助文档
关系数据库MySQL版
用户指南
监控与告警
设置自定义告警规则
公共参数
本文为您介绍分布式消息服务MQTT的API参考-如何调用API。请求头header参数参数名示例值参数类型是否必填参数描述 regionId 921d904cca2211e99aa20242ac110006 String 是资源池编码

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

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

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

来自：
帮助文档
数据湖探索
用户指南
队列管理
队列弹性扩缩容
开启消息轨迹
本章节介绍了如何开启分布式消息服务RocketMQ实例的消息轨迹功能。操作场景查询消息轨迹前,需要先在客户端开启消息轨迹。本章节介绍使用Java和Go开启消息轨迹的方法。

来自：
帮助文档
分布式消息服务RocketMQ
用户指南
消息查询
开启消息轨迹
响应消息头
本章主要介绍响应消息头。调用API时,API网关增加如下响应消息头。 X-Apig-Mode: debug表示响应消息头增加API网关调试信息。

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

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

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

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

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

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

来自：
帮助文档
分布式消息服务RabbitMQ
用户指南
虚拟主机管理
创建虚拟主机
弹性资源池队列管理
弹性资源池优先满足两个队列的最小CU,队列A先分配32CU,队列B分配64CU,剩余CU数为32CU:弹性资源池的最大CU-两个队列的最小CU之和=128-32-64=32CU。2. 因为两个队列的优先级相同,则剩余32CU随机分配给两个队列。弹性资源池扩缩容CU分配场景说明(有任务场景) 场景弹性资源池实际CUs队列A资源分配队列B资源分配弹性资源池CU数分配说明弹性资源池添加了两个队列,分别为队列A和队列B。

来自：
帮助文档
数据湖探索
用户指南
弹性资源池
弹性资源池基本操作
弹性资源池队列管理
删除认证用户
本文为您介绍分布式消息服务MQTT的API-认证授权-删除认证用户。

来自：
帮助文档
分布式消息服务MQTT
API参考
API
认证授权
删除认证用户
日志处理工具Logstash接入Kafka
Kafka与Logstash互联 1、将Kafka作为消息输出目的地使用logstash将命令行输入的信息,传输到Kafka中名为“Logstash-test”的Topic队列。

来自：
帮助文档
分布式消息服务Kafka
最佳实践
日志处理工具Logstash接入Kafka
弹性资源池添加队列
弹性资源池队列添加完成后,可以参考弹性资源池队列管理查看弹性资源池添加的所有队列配置和策略信息。

来自：
帮助文档
数据湖探索
用户指南
弹性资源池
弹性资源池基本操作
弹性资源池添加队列
产品价格
产品规格产品形态售价(元/月)备注云快销(小微特惠版)SaaS服务8按月计费云快销(小微入门版)SaaS服务10按月计费云快销(小微基础版)SaaS服务15按月计费云快销(小微起订版)SaaS服务20按月计费云快销(企业入门版)SaaS服务120按月计费云快销(企业基础版)SaaS服务1200按月计费云快销(企业标准版)SaaS服务2160按月计费云快销(企业高级版)SaaS服务2880按月计费云快销(企业视频版)SaaS服务1999按月计费云快销(商客入门版)SaaS服务30按月计费云快销(商客基础版

来自：
帮助文档
翼云快销
购买指南
产品价格
应用拓扑
信息拓扑图通常包括以下信息: 应用或服务的组成部分:例如数据库、缓存、消息队列、Web 服务器等,当前版本支持的插件见下表,暂未支持的插件会显示为unknown。

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

天翼云最新活动

618智算钜惠季

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

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

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

云上钜惠

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

算力套餐

让算力触手可及

天翼云脑AOne

连接、保护、办公，All-in-One！

中小企业应用上云专场

产品组合下单即享折上9折起，助力企业快速上云

息壤高校钜惠活动

天翼云息壤杯高校AI大赛，数款产品享受线上订购超值特惠

天翼云电脑专场

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

智算服务

应用商城

合作伙伴

开发者

支持与服务

了解天翼云

天翼云最新活动

产品推荐

弹性云主机

物理机

轻量型云主机

弹性伸缩服务

弹性高性能计算

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

天翼云息壤一体化智算服务平台

科研助手

智算一体机

推荐文档

如何修改发票抬头

导入数据

Android客户端需求

管理员

天翼云进阶之路①：Linux / windows 系统修改远程端