构建基于Serverless架构的弹性高可用音视频处理系统
如果想要搭建音视频处理系统，可以直接上云购买ECS服务器部署服务，通过OSS、CDN等技术完成音视频的存储和音视频的播放加速。Serverless方案 简单视频处理系统 如果您只需要对视频进行简单的处理，方案架构图如下。当用户上传一个视频到OSS...
接口和参数说明
该参数表示当TCP连接关闭时，消费者还可以继续处理消息的时间。消息发送接口 接口名称：sendMessage 类名称：com.alibaba.mqtt.server.ServerProducer 表 1.消息发送参数 参数 说明 mqttTopic 云消息队列 MQTT 版 的Topic，包括父级Topic和...
队列使用手册
并且在消息处理过程中，也可以调用changeMessageVisibility这个函数来延长消息的VisibilityTimeout时间。Console.WriteLine("DeleteMessage Failed!ErrorCode:"+me.ErrorCode);} catch(Exception ex){ Console.WriteLine("Delete message ...
主题使用手册
并且在消息处理过程中，也可以调用changeMessageVisibility这个函数来延长消息的VisibilityTimeout时间。Console.WriteLine("DeleteMessage Failed!ErrorCode:"+me.ErrorCode);} catch(Exception ex){ Console.WriteLine("Delete message ...
死信队列
对于消费失败且重试后依然失败的消息，云消息队列 RocketMQ 版 不会立丢弃，而是将消息转发至指定的队列中，即死信队列，这些消息即为死信消息。当消费失败的原因排查并解决后，您可以重发这些死信消息，让消费者重新消费；若您暂时无法...
系统防护
系统防护即从整体维度对应用入口流量进行控制，结合应用的Load、总体平均RT、入口QPS和线程数等几个维度的监控指标，让系统的入口流量和系统的负载达到一个平衡，让系统尽可能跑在最大吞吐量的同时保证系统整体的稳定性。背景信息 长期以来...
内容分割
背景信息 数据清洗功能提供常见的消息处理模板，包括内容分割、动态路由、内容富化和内容映射等。您可以直接利用模板处理消息，也可以根据业务情况在模板基础上修改代码。消息数据清洗任务提供基本的算子能力，底层逻辑使用函数计算。支持...
内容映射
背景信息 数据清洗功能提供常见的消息处理模板，包括内容分割、动态路由、内容富化和内容映射等。您可以直接利用模板处理消息，也可以根据业务情况在模板基础上修改代码。消息数据清洗任务提供基本的算子能力，底层逻辑使用函数计算。支持...
内容富化
背景信息 数据清洗功能提供常见的消息处理模板，包括内容分割、动态路由、内容富化和内容映射等。您可以直接利用模板处理消息，也可以根据业务情况在模板基础上修改代码。消息数据清洗任务提供基本的算子能力，底层逻辑使用函数计算。支持...
动态路由
背景信息 数据清洗功能提供常见的消息处理模板，包括内容分割、动态路由、内容富化和内容映射等。您可以直接利用模板处理消息，也可以根据业务情况在模板基础上修改代码。消息数据清洗任务提供基本的算子能力，底层逻辑使用函数计算。支持...
通过可观测性能力进行故障处理最佳实践
根据业务逻辑或指标的变化趋势定位具体原因，例如消息处理耗时变长，则可以查看消费者服务的内存、CPU等是否过载；或查看消费逻辑依赖的下游业务逻辑的运行状态进行进一步分析。生产异常场景实践方案 查看消息发送成功率（rocketmq_send_...
队列使用手册
并且在消息处理过程中，也可以调用changeMessageVisibility这个函数来延长消息的VisibilityTimeout时间。echo"DeleteMessage Failed:".$e;return;} 步骤五：删除队列 Sample里最后会删除这个测试队列。try {$this->client->deleteQueue($...
批处理
使用批处理对存储空间（Bucket）中存量文件进行批量处理。例如将Bucket某个目录中后缀为.docx...单击批处理ID前的展开按钮，可以查看批处理的所有任务信息，可以根据源文件路径和状态来搜索任务，单击 操作 列的 详情 可以查看任务详细信息。
监控报警接入
设置报警规则（接入云监控）背景信息 您可以使用媒体处理云监控服务获取系统性能、用量两方面的监控数据指标。您还可以使用自定义报警服务，监控服务稳定性、分析使用情况，及时发现以及诊断相关问题。如需了解基本概念或进行报警联系人和...
Exactly-Once投递语义
什么是Exactly-Once投递语义 Exactly-Once是指发送到消息系统的消息只能被消费端处理且仅处理一次，即使生产端重试消息发送导致某消息重复投递，该消息在消费端也只被消费一次。Exactly-Once语义是消息系统和流式计算系统中消息流转的最...
应用场景
前端的监控系统和大数据处理系统会利用 TSDB 的数据查询和计算分析能力进行业务监控和分析结果的实时展现。电力化工及工业制造监控分析 传统电力化工以及工业制造行业需要通过实时的监控系统进行设备状态检测，故障发现以及业务趋势分析。...
应用场景
其高性能的消息处理能力可以承接流量脉冲而不被击垮，在确保系统可用性的同时，通过快速有效的请求响应技术提升用户体验。其海量消息堆积能力确保下游业务在安全水位内平滑稳定地运行，避免流量高峰的冲击。分布式缓存同步 大量并发访问...
削峰填谷
上图中，黄色区域代表超出消息处理能力的部分。将黄色部分的消息平均分布到之后的空闲时间去处理，既可以保证系统负载处在一个稳定的水位，又可以尽可能地处理更多消息。通过配置流控规则，可以达到消息匀速处理的效果。功能原理 限流降级...
削峰填谷
上图中，黄色的部分代表超出消息处理能力的部分。把黄色部分的消息平均到之后的空闲时间去处理，这样既可以保证系统负载处在一个稳定的水位，又可以尽可能地处理更多消息。通过配置流控规则，可以达到消息匀速处理的效果。功能原理 AHAS流...
概述
应用场景 异步解耦消息队列的生产消费模型可以解耦上下游业务系统，并支持下游多个消费者对同一消息进行消费和处理。以金融场景为例，支付中心作为支付宝主站最核心的系统，每笔支付数据的产生会引起几百个下游业务系统的关注，包括账户...
应用场景
风控监测系统 实时计算Flink版可以处理复杂的流处理和批处理任务，也提供了强大的API，执行复杂的数学计算并执行复杂事件处理规则，帮助企业对实时数据进行实时分析，提高企业的风控能力。例如检测APP中的点击行为、识别loT数据流不规则...
接入 iOS
iOS 10 以下系统，通知栏消息处理方法-(void)application:(UIApplication*)application didReceiveRemoteNotification:(NSDictionary*)userInfo fetchCompletionHandler:(void(^)(UIBackgroundFetchResult result))completionHandler {/...
应用场景
营销风险识别 营销风险识别产品适用于帮助用户发现在营销活动中出现的作弊、薅羊毛、套利等风险，可以运用到限时抽奖、免费拉新、优惠折扣、推广返利等类型活动中，通过传入识别所需信息，系统自动返回营销风险情况，用户可以将风险返回...
主题使用手册
如果这里发生了程序崩溃或卡住等异常情况，对应的Message会在VisibilityTimeout之后重新可见，从而可以被其他进程处理，避免消息丢失。获取ReceiptHandle，这是一个有时效性的Handle，可以用来设置Message的各种属性和删除Message。更多...
事务消息
典型场景 在淘宝购物车下单时，涉及到购物车系统和交易系统，这两个系统之间的数据最终一致性可以通过分布式事务消息的异步处理实现。在这种场景下，交易系统是最为核心的系统，需要最大限度地保证下单成功。而购物车系统只需要订阅 云消息...
产品架构
发送的消息可以是网站的页面访问、服务器日志，也可以是CPU和内存相关的系统资源信息。Kafka Broker 用于存储消息的服务器。Kafka Broker支持水平扩展。Kafka Broker节点的数量越多，云消息队列 Kafka 版 集群的吞吐率越高。Group 通过pull...
工作流概述
工作流指媒体处理中的云端自动化处理工作流，音视频上传完毕后自动执行处理流程。本文介绍工作流的基本概念及使用方式。...当工作流开始和完成后，媒体处理服务会向MNS发送消息，您可以通过MNS接收消息，获取该次工作流执行的相关信息。
告警功能配置及使用
同时支持用户自定义是否接收系统的“已处理告警消息”，若不需要接收，可以在配置中将“通知已处理告警”按钮关闭。告警消息类型支持：text/markdown/ActionCard。所有内容都配置完毕后，用户可以点击屏幕右下脚的“保存且测试”按钮，对...
ECS系统事件汇总
您可以通过系统事件获取ECS资源的风险和异常信息，例如 某一实例到期、实例因底层升级需迁移或因系统维护重启了某一实例等，然后及时响应和处理系统事件，避免因ECS资源可用性或性能受损而影响业务。本文汇总了云服务器ECS支持的系统事件...
监控与日志
您可以通过VPN网关的系统事件和监控指标信息来判断系统是否按照预期运行，同时您也可以对系统事件和监控指标设置报警规则，以便在系统运行异常时，您可以收到报警通知，及时处理问题。系统事件监控 阿里云云监控服务的事件监控功能自动汇集...
配置消息监控告警实现风险预警
云消息队列 RocketMQ 版 支持通过云监控配置告警规则，以便您可以实时监控实例的运行状态和关键的业务指标，并能够及时收到异常的告警通知，实现生产环境的风险预警。背景信息 云消息队列 RocketMQ 版 提供全托管的消息服务，对于每个规格...
消费重试
例如，您预设消息处理耗时最多20 ms，但实际业务中20 ms内消息处理不完，您可以修改消息不可见时间，延长消息处理时间，避免消息触发重试机制。修改消息不可见时间需要满足以下条件：消息处理未超时 消息处理未提交消费状态 如下图所示，...
应用场景
消息队列作为分布式系统中的重要组件，可以很好的应对这些场景。下文以支付转账为场景说明消息队列如何实现以下功能：异步解耦 分布式事务的数据一致性 削峰填谷 异步解耦 传统处理方式 最常见的一个场景是支付转账成功后，需要生成交易...
处理挖矿程序最佳实践
服务器被挖矿病毒入侵后，挖矿病毒会消耗服务器的资源、降低生产效率、影响系统稳定性，对受感染的个人或企业用户构成严重的威胁。被入侵后，您需要及时响应并处理挖矿病毒，加固系统安全。本文介绍如何处理挖矿病毒。背景信息 挖矿程序的...
设置消息通知
然后您可以通过日志查看消息轨迹、消息延迟以及其他信息。更多信息，请参见 日志管理概述。单击 确定，完成创建主题，跳转至主题详情页面。单击 创建订阅，并配置相关参数。参数 说明 名称 订阅名称。说明 名称必须以英文字母开头，剩余...
概述
概念介绍—数据处理（Transform）数据处理是消息集成的重要功能组件，可以在配置消息流入或消息流出任务的同时选择性配置数据处理能力。依托 事件总线EventBridge 强大的自研数据处理及灵活的函数计算自定义能力，提供7种匹配模式（指定值...
概述
概念介绍—数据处理（Transform）数据处理是消息集成的重要功能组件，可以在配置消息流入或消息流出任务的同时选择性配置数据处理能力。依托 事件总线EventBridge 强大的自研数据处理及灵活的函数计算自定义能力，提供7种匹配模式（指定值...
概述
概念介绍—数据处理（Transform）数据处理是消息集成的重要功能组件，可以在配置消息流入或消息流出任务的同时选择性配置数据处理能力。依托 事件总线EventBridge 强大的自研数据处理及灵活的函数计算自定义能力，提供7种匹配模式（指定值...
步骤一：（可选）RAM用户授权
云消息队列 RabbitMQ 版的权限策略 云消息队列 RabbitMQ 版 提供以下系统策略，您可以根据权限范围为RAM用户授予相关权限。授权策略名称 说明 AliyunAMQPFullAccess 云消息队列 RabbitMQ 版 的管理权限，被授予该权限的RAM用户具有等同于...
任务管理
（6）运行状态是获取处理器执行权的就绪任务所处的状态，单处理器系统，任意时刻只有一个任务可以运行。AliOS Things允许任务处于组合状态，如阻塞挂起状态：任务在阻塞状态下，被其他任务挂起，则进入阻塞挂起状态。该状态下，若任务被...
- 产品推荐
- 这些文档可能帮助您