微消息队列MQTT版推送事件到函数计算

您可以通过 云消息队列 MQTT 版 的数据流出功能,将数据流转到 云消息队列 RocketMQ 版 的Topic中,并通过添加 事件总线EventBridge 的自定义事件源 云消息队列 RocketMQ 版,实现 云消息队列 MQTT 版 事件总线EventBridge 的集成。...

基本概念

本文主要对 云消息队列 RocketMQ 版 涉及的专有名词及术语进行定义和解析,方便您更好地理解相关概念并使用 云消息队列 RocketMQ 版。Topic 消息主题,一级消息类型,通过Topic对消息进行分类。更多信息,请参见 TopicTag最佳实践。消息...

产品优势

云消息队列 Kafka 版 100%兼容开源,支持0.10.x~2.6.x的开源版本,无需代码改造无缝迁移上云,体验全托管、免运维的分布式消息队列服务。开箱即用 云消息队列 Kafka 版 100%兼容开源,使您无缝迁移上云。兼容开源:云消息队列 Kafka 版 100...

应用场景

本文为您介绍 云消息队列 RocketMQ 版 的应用场景,以便您更好地判断如何在业务中使用 云消息队列 RocketMQ 版。例如,针对一家互联网电商企业,其业务涉及广泛,如注册、订单、库存、物流等;同时,也会涉及许多业务峰值时刻,如秒杀活动...

应用场景

传统架构不同,云消息队列 Kafka 版 以及Storm、Samza、Spark等数据处理引擎的出现,就是为了更好地解决这类数据在处理过程中遇到的问题,数据处理模型能实现在数据流动的过程中对数据进行实时地捕捉和处理,并根据业务需求进行计算分析...

应用场景

分布式事务可应用在多个涉及数据库操作的领域,尤其在金融领域可以做到全场景的覆盖落地验证,包括:支付转账、账务:对于吞吐量有很高的要求 金融理财:往往涉及的金额较大,所以对于产品的稳定性要求非常高 保险监管报送:参与方...

功能特性概述

本文列举 云消息队列 RocketMQ 版 所支持的所有功能特性。概览 云消息队列 RocketMQ 版 在阿里云多个地域(Region)提供了高可用消息云服务。单个地域内采用多机房部署,可用性极高,即使整个机房都不可用,仍然可以为应用提供消息发布...

概述

消息队列 SOFAStack 消息队列是基于 Apache RocketMQ 构建的分布式消息中间件,并金融分布式架构 SOFAStack 深度集成,为分布式应用系统提供异步解耦和削峰填谷的能力,支持事务消息、顺序消息、定时消息等多种消息类型,并具备高可靠、...

什么是云消息队列 RocketMQ 版?

云消息队列 RocketMQ 版 是阿里云基于Apache RocketMQ构建的低延迟、高并发、高可用、高可靠的分布式“消息、事件、流”统一处理平台,面向互联网分布式应用场景提供微服务异步解耦、流式数据处理、事件驱动处理等核心能力。为什么选择云...

在线教育视频直播

视频直播 视频直播(ApsaraVideo Live)基于内容接入分发网络和大规模分布式实时视频处理技术(含窄带高清TM)打造的音视频直播平台,提供易接入、低延迟、高并发、高清流畅的音视频直播服务。更多关于视频直播的介绍,参见 视频直播产品...

将云消息队列 Kafka 版的数据迁移至MaxCompute

MaxCompute和DataWorks一起向用户提供完善的数据处理和数仓管理能力,以及SQL、MR、Graph等多种经典的分布式计算模型,能够更快速地解决用户海量数据计算问题,有效降低企业成本,保障数据安全。本教程旨在帮助您使用DataWorks,将 云消息...

基于Flink的资讯场景实时数仓

解决的问题 通过 云消息队列 Kafka 版 和实时计算Flink实现实时数据处理和数据流。通过 云消息队列 Kafka 版 和实时计算Flink实现实时数据分析。通过 云消息队列 Kafka 版 和实时计算Flink实现事件触发。部署架构图 选用的产品 云消息队列 ...

新零售电子价签解决方案(MQTT)

新零售电子价签解决方案由阿里云 云消息队列 MQTT 版 推出,通过MQTT以实现商场超市、公共场所电子标签、多媒体屏幕的数据更新管理。本文将以电子价签为例详细描述该解决方案的系统架构、数据流设计以及注意事项,其他类似行业可参考该方案...

开源对比

云消息队列 RabbitMQ 版 是一款基于高可用分布式存储架构实现的AMQP 0-9-1协议的消息产品,能够兼容开源RabbitMQ客户端,开源RabbitMQ相比,能够解决各种稳定性痛点(例如消息堆积、脑裂等问题),同时具备高并发、分布式、灵活扩缩容等...

应用场景

本文为您介绍 SOFAStack 消息队列的适用场景,以便您更好地判断如何在业务中使用消息队列。在互联网金融场景里,其业务涉及广泛,如支付交易、收费计息、商户结算、业务营销、会员积分、风险核查等;同时,也会涉及许多业务峰值时刻,如双 ...

基于事件流实现RabbitMQ消息路由

本文介绍如何应用 事件总线EventBridge 的事件流功能实现 云消息队列 RabbitMQ 版 的消息路由。前提条件 您已 开通事件总线EventBridge并授权。您已购买并部署 云消息队列 RabbitMQ 版 实例,且实例处于 服务中 状态。具体步骤,请参见 ...

事件分析概述

事件总线EventBridge 支持对发布到事件总线的各种事件进行追踪查询、分析处理和可视化图表展示。本文介绍事件分析的类型、适用场景优势。背景信息 事件总线EventBridge 的实时事件分析平台依托事件的实时处理引擎,提供数值检索、可视化...

常见问题

本文介绍 事件总线EventBridge 相关的基本问题。什么是 事件总线EventBridge?阿里云 事件总线EventBridge 是阿里云自研全托管的无服务器事件驱动服务总线,具备高扩展性、高可靠性,支持事件查询、事件轨迹追踪、事件跨账号传输等一系列...

消息队列RabbitMQ版推送事件到函数计算

前提条件 您已完成以下操作:事件总线EventBridge 开通事件总线EventBridge并授权 创建自定义总线 函数计算 创建服务 创建函数 创建日志项目和日志仓库 配置SLS触发器 收集导入日志 云消息队列 RabbitMQ 版 创建实例 创建Vhost 创建...

消息队列RocketMQ版推送事件到函数计算

前提条件 您已完成以下操作:事件总线EventBridge 开通事件总线EventBridge并授权 创建自定义总线 函数计算 创建服务 创建函数 创建日志项目和日志仓库 配置SLS触发器 收集导入日志 消息队列RocketMQ版 开通消息队列服务并授权 创建实例、...

快速使用MQTT的Java SDK收发消息(终端和终端消息收发...

本文介绍如何快速使用 云消息队列 MQTT 版 的Java SDK实现MQTT终端终端消息的收发。前提条件 创建资源 获取AccessKey 安装 IDE。您可以使用IntelliJ IDEA或者Eclipse,本文以IntelliJ IDEA为例。下载安装 JDK。背景信息 云消息队列 MQTT ...

延时消息

如果您希望消息被投递后延迟一段时间被消费者消费,您可以使用 云消息队列 RabbitMQ 版 的延时消息。云消息队列 RabbitMQ 版 原生支持延时消息,使用方式比开源RabbitMQ更简单。什么是延时消息 延时消息是指在指定时间段之后才被消费者消费...

升级实例版本

升级版本 登录 云消息队列 Kafka 版 控制台,在 概览 页面的 资源分布 区域,选择地域。在 实例列表 页面,单击目标实例名称。在 实例详情 页面的 基础信息 区域,执行以下操作。升级大版本:单击 大版本 右侧的 开源版本升级。升级小版本...

RocketMQ全链路追踪解决方案

分布式应用系统中,多个服务间的交互涉及复杂的网络通信和数据传输,往往一次请求需要多个内部服务间的相互调用才能完成,任何一个环节出现问题都可能导致外部服务任务执行失败或延时,且很难快速定位问题根源。链路追踪功能可在多个服务...

名词解释

在使用 云消息队列 MQTT 版 前,需理解该产品和MQTT协议所涉及的基本概念和术语。基本概念 实例(Instance)创建购买 云消息队列 MQTT 版 服务的实体单元,每个 云消息队列 MQTT 版 实例都对应一个全局唯一的服务接入点URL。使用 云消息...

功能特性

SOFAStack 消息队列在阿里云多个地域(Region)提供了高可用消息云服务。单个地域内采用多机房部署,可用性极高,即使整个机房都不可用,仍然可以为应用提供消息发布服务。消息队列提供 TCP 协议语言接入方式,方便应用快速接入消息队列...

发布者最佳实践

本文介绍 云消息队列 Kafka 版 发布者的最佳实践,帮助您降低发送消息的错误率。本文最佳实践基于Java客户端。对于其他语言的客户端,其基本概念思想是相通的,但实现细节可能存在差异。发送消息 发送消息的示例代码如下:Future...

收发事务消息

云消息队列 RocketMQ 版 提供类似XA或Open XA的分布式事务功能,通过 云消息队列 RocketMQ 版 事务消息,能达到分布式事务的最终一致。交互流程 事务消息交互流程如下图所示。更多信息,请参见 事务消息。前提条件 您已完成以下操作:下载C...

阿里云官方事件源

事件总线EventBridge 支持将阿里云官方事件作为事件源发布到事件总线,事件总线EventBridge 作为统一的入口来处理、分发这些事件。本文介绍 事件总线EventBridge 支持的阿里云官方事件源对应的阿里云服务和云服务事件类型。事件类型 阿里...

异步任务完成通知

消息队列RocketMQ 消息队列RocketMQ版是阿里云基于Apache RocketMQ构建的低延迟、高并发、高可用、高可靠的分布式“消息、事件、流”统一处理平台,面向互联网分布式应用场景提供微服务异步解耦、流式数据处理、事件驱动处理等核心能力。...

收发事务消息

云消息队列 RocketMQ 版 提供类似XA或Open XA的分布式事务功能,通过 云消息队列 RocketMQ 版 事务消息,能达到分布式事务的最终一致。交互流程 事务消息交互流程如下图所示。更多信息,请参见 事务消息。前提条件 下载.NET SDK。更多信息...

查看消费状态

查看Topic被订阅的Group 登录 云消息队列 Kafka 版 控制台,在 概览 页面的 资源分布 区域,选择地域。在 实例列表 页面,单击目标实例名称。在左侧导航栏,单击 Topic管理。在 Topic管理 页面,找到目标Topic,在其 操作 列,选择 更多>...

服务支持

本文汇总了 云消息队列 Kafka 版 的常见问题与以及服务等级协议。服务支持 常见问题 相关协议

事件追踪概述

功能介绍 在 事件总线EventBridge 控制台发布事件后,如果事件目标未接收到事件或接收到的事件实际场景不符,您可以使用事件追踪功能,帮助您定位事件收发过程中出现问题的环节和原因。事件追踪功能还可以帮助您了解 事件总线EventBridge...

死信队列

对于消费失败且重试后依然失败的消息,云消息队列 RocketMQ 版 不会立丢弃,而是将消息转发至指定的队列中,即死信队列,这些消息即为死信消息。当消费失败的原因排查并解决后,您可以重发这些死信消息,让消费者重新消费;若您暂时无法...

EventBridge事件调度

MQTT调度 云消息队列 MQTT 版 作为事件源通过 事件总线 云工作流 调度集成后,通过云消息队列 MQTT 版调度能够触发关联工作流执行,通过 云工作流 可以对发布到 云消息队列 MQTT 版 的消息进行自定义处理。本文介绍如何在控制台创建MQTT...

仪表盘

借助于阿里云ARMS Prometheus监控服务和Grafana的指标存储和展示能力,云消息队列 RocketMQ 版 提供仪表盘功能。该功能可帮助您一站式、全方位、多维度地统计和观测指标,进而快速了解业务的运行状态。本文介绍仪表盘的应用场景、业务背景...

实例规格

可用性 99.99%(累计不可用时间最长不超过4.3分钟/月)99.95%(累计不可用时间最长不超过21.5分钟/月)专家尊享通道 产品专家研发专家在线支持,及时协助处理线上问题。提供保驾护航服务,例如大促保障护航、新业务上线等。云消息队列 ...

仪表盘

借助于阿里云ARMS Prometheus监控服务和Grafana的指标存储和展示能力,云消息队列 RocketMQ 版 提供可实时进行数据统计的仪表盘功能。该功能可帮助您一站式、全方位、多维度地统计和观测指标,进而快速了解业务的运行状态。本文介绍仪表盘...

队列(MessageQueue)

常见队列增加场景 需要增加队列实现物理节点负载均衡 云消息队列 RocketMQ 版 每个主题的多个队列可以分布在不同的服务节点上,在集群水平扩容增加节点后,为了保证集群流量的负载均衡,建议在新的服务节点上新增队列,或将旧的队列迁移到...
共有102条 < 1 2 3 4 ... 102 >
跳转至: GO
产品推荐
云服务器 安全管家服务 安全中心
这些文档可能帮助您
云消息队列 RocketMQ 版 云消息队列 Kafka 版 数据总线 DataHub 全局事务服务 (文档停止维护) 弹性公网IP 短信服务
新人特惠 爆款特惠 最新活动 免费试用