消息(Message) 消息队列服务对外服务的基本实体单元,消息由Header(标签)和Body(消息体)组成。Header是消息生产者添加的各种属性的集合,包括消息是否被持久化,由哪个队列接受,优先级是多少等等。Body是消息体,是真正需要被传输的数据。 队列(Queue) 消息的容器,存储被生产者投递过来但尚未被消费的消息。生产者把消息发送到队列,消费者从队列中获取并消费消息。
网络扩容后的问题如下: 不同系统之间的数据同步 系统扩展问题 第三阶段:新增Kafka模块提供消息队列,Web应用数据只需向队列中添加数据,网络中的各组件从队列中依次读取数据并自行处理,如下图所示: 网络扩容带来的问题迎刃而解,而且降低了系统组网复杂度;降低编程复杂度,各个子系统不在是相互协商接口,各个子系统类似插口插在插座上,Kafka承担高速数据总线的作用。
使用规则引擎将设备消息流转到业务服务器 概述 天工平台将设备上报的数据流转至百度kafka中,之后,业务应用服务器可以消费kafka中的数据进行业务处理。 应用场景 场景说明: 通过百度消息服务kafka削峰填谷,缓冲消息,减轻服务器同时接收大量设备消息的压力。 持久化设备上报的业务数据,防止业务处理应用故障导致消息丢失造成损失。 前提条件 已开通百度消息服务。
创建队列 概述 通过队列,您可以更灵活地管理转码任务。当创建一个任务时,您必须为该任务指定所属的队列。您可通过本文档了解如何使用控制台创建队列。 注意事项 队列容量为队列中可以并行进行的转码任务数。每个账号的队列总容量为 100 。您可以创建多个队列分配队列容量。当队列总量不满足业务需求时,可以通过 工单 申请扩容。 创建队列 登录 音视频处理 MCP 控制台 。
队列容量需要小于等于剩余队列总容量。 输入/输出bucket 设置您的音视频输入/输出Bucket。输入bucket和输出bucket可以是同一个bucket。当您的BOS中不存在bucket时,需要在BOS中新建一个bucket。 通知模板 (选填)可以选择一个通知回调地址,当队列中的任务处理完成时,通过通知回调地址通知您。 编辑完成,点击 更新队列 ,完成对队列的编辑。
删除队列 概述 在队列详情页,可以删除队列。 注意:删除队列后将不能恢复,正在处理任务的队列不允许删除 。 删除队列 登录 音视频管理 MCP 控制台 。 在左侧导航栏选择 产品配置 > 任务队列 ,进入任务队列列表。 点击目标队列操作栏下的 删除 按钮,弹出确认删除对话框。 点击 确定 ,完成队列的删除。
队列接口 创建队列 接口描述 基本接口,用户向服务请求创建任务队列。
Pipeline(队列) 队列分为免费型与私有型: 免费型队列中的转码任务分享百度智能云为音视频转码所提供的约400路720P转码计算资源。 私有型队列需额外采购,以便更好的满足那些对于转码时效性和稳定性有更高要求的用户的业务需求。 用户可以利用队列实现任务优先级。
Pipeline队列 队列分为免费型与专享型: 免费型队列中的转码任务分享百度智能云为音视频转码所提供的约400路720P转码计算资源。 专享型队列需额外采购,以便更好的满足那些对于转码时效性和稳定性有更高要求的用户的业务需求。 用户可以利用队列实现任务优先级。
Pipeline队列 队列分为免费型与专享型: 免费型队列中的转码任务分享百度智能云为音视频转码所提供的约400路720P转码计算资源。 专享型队列需额外采购,以便更好的满足那些对于转码时效性和稳定性有更高要求的用户的业务需求。 用户可以利用队列实现任务优先级。