流式应用场景_解决方案实践
方案概述 本场景应用于数据流式处理，使用到BLS（百度Log Service）、BMS（百度消息服务）以及BMR（MapReduce）三个产品。 整个流程分为数据采集和数据计算两部分。 数据采集 数据采集过程通过BLS以及百度消息服务BMS实现。 创建消息服务BMS Topic 参考文档： 创建BMS主题 。
组件管理相关接口 - 容器引擎CCE | 百度智能云文档
Preemptgang : true # 是否开启队列间抢占 CCE RDMA Device Plugin 该组件不需要用户设置参数 CCE PaddleFlow global : PF_SELFED_DB_ENABLED : &selfd_mysql true PF_DB_DATABASE : &pf_db_database paddleflow PF_DB_HOST : &
产品概述 - 智能边缘BIE | 百度智能云文档
baetyl-broker：单机版消息订阅和发布中心，采用 MQTT3.1.1 协议，可在低带宽、不可靠网络中提供可靠的消息传输服务。其作为 baetyl 框架端侧的消息中间件，为所有服务提供消息驱动的互联能力。 baetyl-agent（仅限容器模式节点）：以DaemonSet的形式运行于边缘集群各节点上的守护进程。主要用于文件同步和各个节点网络磁盘信息监控。
编写集成代码 - 移动APP推送服务 | 百度智能云文档
其他字段： 字段名 类型 说明 conn_status boolean 当前连接状态，true为在线，false为不在线 3：接收到透传消息。 其他字段： 字段名 类型 说明 id string 消息id description string 描述 content string 消息内容 4：接收到一个通知栏消息。
产品优势 - 移动APP推送服务 | 百度智能云文档
产品优势 推送消息样式多 除通用样式外，还包括自定义推送标题、内容、图标，以及纯图展示、透传消息等消息样式。为摒弃盲目推送，触达精准用户，我们还提供了对比通知文案和对比用户群体两种分组对比测试方式，用来在小范围内进行区别推送测试，并根据数据反馈效果，选择最优推送方案。
训练任务相关接口 - 百舸异构计算平台AIHC | 百度智能云文档
请求参数 参数名称 类型 是否必须 参数位置 说明 resourcePoolId String 是 Query参数 标识资源池的唯一标识符 name String 是 Body参数 名称 queue String 否 Body参数 训练任务所属队列，默认为default队列 jobFramework String 否 Body参数 分布式框架，只支持 PyTorchJob，默认值：PyTorchJob
使用内置modbus驱动采集数据并进行边缘函数计算 - 智能边缘BIE | 百度智能云文档
配置消息流转 通过配置baetyl-rule实现消息流转，该应用可订阅 baetyl-broker 的消息主题，发送到自身的其他消息主题，同时支持函数处理。 点击rule应用，修改rule-conf的配置项，修改conf文件内容如下。
Redis常见面试题：ZSet底层数据结构，SDS、压缩列表ZipList、跳表SkipList 千帆社区
Stream 主要用于实现消息队列的功能，如 Apache Kafka。 应用场景 ： 消息队列：Stream 可以作为生产者消费者模型的一种实现，生产者添加消息到 Stream，消费者从 Stream 中读取消息并处理。 日志记录：由于 Stream 中的每个元素都有唯一的 ID，并且这个 ID 是自动递增的，因此非常适合用来记录日志。
工作流Agent：“金牌销售”车险续保Agent - 千帆AppBuilder-产品文档
目前信息收集节点的提问内容不支持流式输出，消息节点支持流式输出，因此出于对话时延的考虑，采用先通过消息节点输出话术，再通过信息收集节点收集用户回复内容的配置方式） 在收集到客户回复的拒绝原因之后，通过API节点获取该客户的历史情况，通过代码节点计算该客户可以享受的优惠折扣，然后通过大模型节点生成优惠方案及引导续保的话术，再通过消息节点输出该话术，通过信息收集节点收集客户回复内容。
ARApplicationController - AR开放平台 | 百度智能云文档
ARApplicationController AR实例的总控制器类，封装了AR实例ARApplication的创建、脚本中消息发送和接收、脚本虚拟机 Script VM的管理、平台共享信息数据接口、算法和传感器数据接口等。
