什么是消息服务MNS
队列模型 队列模型提供高可靠、高并发的一对一消费模型，即队列中的每一条消息都只能够被某一个消费者消费。队列就像一家旋转寿司店。寿司店中有多个寿司师傅（生产者）在制作精美的寿司，每一份寿司都是独特的，顾客（消费者）可以从传送...
队列模型快速入门
本文为您介绍如何在 消息服务MNS控制台 上快速上手使用队列模型。前提条件 开通消息服务MNS并授权 创建队列 登录 消息服务MNS控制台。在左侧导航栏，单击 队列列表。在顶部菜单栏，选择地域。在 队列列表 页面，单击 创建队列。在 创建队列...
快速入门概述
消息服务MNS 支持使用队列模型和主题模型收发消息，实现一对一或者一对多的消费模式，本文以简单明了的方式让您快速上手 消息服务MNS。背景信息 消息服务MNS 提供队列模型和主题模型。队列模型：支持一对一的消费模式。队列模型 队列模型...
消息服务MNS
目标端消息服务MNS参数配置 参数 说明 示例 队列名称 选择接收源端消息的目标 消息服务MNS 队列。test 开启 Base64编码 是：开启Base64编码，会帮助您将数据编码后投递至 消息服务MNS 中的队列。否：不开启Base64编码。是 在 数据处理 区域...
创建MNS Source Connector
参数 说明 示例 队列名称 选择MNS的队列。test-queue Base64 解码 勾选此项会帮助您将MNS的数据解码后进行投递。test 批量推送 批量推送可帮您批量聚合多个事件，当 批量推送条数 和 批量推送间隔（单位：秒）两者条件达到其一时即会触发...
创建MNS Sink Connector
参数 说明 示例 队列名称 选择已创建的 消息服务MNS 队列。test 开启 Base64 编码 选择是否开启Base64编码，如不开启，会导致接收到的消息为乱码。是 消息体（body）选择事件内容转换类型。更多信息，请参考 事件内容转换。完整事件 任务...
消息服务MNS
目标端消息服务MNS参数配置 参数 说明 示例 队列名称 选择接收源端消息的目标 消息服务MNS 队列。test 开启 Base64编码 是：开启Base64编码，会帮助您将数据编码后投递至 消息服务MNS 中的队列。否：不开启Base64编码。是 在 数据处理 区域...
消息服务MNS
目标端消息服务MNS参数配置 参数 说明 示例 队列名称 选择接收源端消息的目标 消息服务MNS 队列。test 开启 Base64编码 是：开启Base64编码，会帮助您将数据编码后投递至 消息服务MNS 中的队列。否：不开启Base64编码。是 在 数据处理 区域...
消息过滤
应用场景 云消息队列 RocketMQ 版 作为发布订阅模型的消息中间件广泛应用于上下游业务集成场景。在实际业务场景中，同一个主题下的消息往往会被多个不同的下游业务方处理，各下游的处理逻辑不同，只关注自身逻辑需要的消息子集。使用 云...
领域模型概述
发布订阅模型 发布订阅模型具有如下特点：消费独立：相比队列模型的匿名消费方式，发布订阅模型中消费方都会具备的身份，一般叫做订阅组（订阅关系），不同订阅组之间相互独立不会相互影响。一对多通信：基于独立身份的设计，同一个主题内...
消费者分类
该模型开发逻辑简单，但是不允许使用异步化和自定义处理流程。SimpleConsumer SimpleConsumer是一种接口原子型的消费者类型，消息的获取、消费状态提交以及消费重试都是通过消费者业务逻辑主动发起调用完成。使用方式 SimpleConsumer的使用...
将云消息队列 Kafka 版的数据迁移至MaxCompute
本文介绍如何使用DataWorks数据同步功能，将 云消息队列 Kafka 版 集群上的数据迁移至阿里云大数据计算服务MaxCompute，方便您对离线数据进行分析加工。前提条件 在开始本教程前，确保您在同一地域中已完成以下操作：云消息队列 Kafka 版 ...
代码示例
模型开发 打开Notebook 示例描述 Github DSW Gallery 使用MNIST数据集和PAI预置的PyTorch镜像开发简单的PyTorch模型。Github DSW Gallery 如何使用PAI快速开始（PAI-QuickStart）提供的模型和算法，完成模型的开发和部署。Github DSW ...
最佳实践
视频介绍 通过配置流程编排实现让天猫精灵随机播放一首歌曲 由于随机播放，我们可以根据您所处区域的天气来推荐一首歌曲，所以我们会用【API调用节点】调用天气接口，然后将天气结果传入【大模型节点】的Prompt中，最终大模型推荐了一首...
队列（MessageQueue）
云消息队列 RocketMQ 版 队列模型和Kafka的分区（Partition）模型类似。在 云消息队列 RocketMQ 版 消息收发模型中，队列属于主题的一部分，虽然所有的消息资源以主题粒度管理，但实际的操作实现是面向队列。例如，生产者指定某个主题，向...
模型训练
在需要加入更多知识的场景下，受限于API提示词的长度，加入的提示词不一定可以取得较好效果，通过fine-tuning，可以获得更好的效果 定制模型的主要流程，相对来说很简单，用户仅需要：根据示例进行数据准备以及预处理工作；发起定制服务...
直播互动解决方案
示例代码下载地址如下所示：服务端应用Java语言示例代码 老师的客户端示例代码 学生A的客户端示例代码 学生B的客户端示例代码 说明 代码中所涉及的参数请以代码注释描述为准。名词解释 MQTT 一个基于订阅/发布的长连接双向通信模型，订阅...
订阅关系（Subscription）
本文介绍 云消息队列 RocketMQ 版 中订阅关系（Subscription）的定义、模型关系、内部属性及使用建议。定义 订阅关系是 云消息队列 RocketMQ 版 系统中消费者获取消息、处理消息的规则和状态配置。订阅关系由消费者分组动态注册到服务端...
访问队列服务
向队列服务发送数据 使用 curl 命令向输入队列发送一条同步请求或异步推理请求，具体代码示例如下。curl-v http://182848887922*....
消费者（Consumer）
本文介绍 云消息队列 RocketMQ 版 中消费者（Consumer）的定义、模型关系、内部属性、行为约束、版本兼容性及使用建议。定义 消费者是 云消息队列 RocketMQ 版 中用来接收并处理消息的运行实体。消费者通常被集成在业务系统中，从 云消息...
延时消息
云消息队列 RabbitMQ 版 原生支持延时消息，使用方式比开源RabbitMQ更简单。什么是延时消息 延时消息是指在指定时间段之后才被消费者消费的消息。应用场景 延时消息适用于以下场景：对消息生产和消费有时间窗口要求的场景。例如，在电商...
什么是云消息队列 MQTT 版
消息收发模型 云消息队列 MQTT 版 主要包含以下两种消息收发模型：终端与云端服务交互模型 该模型中，云消息队列 MQTT 版 将终端与云端连接起来，实现设备端和云端的双向通信。设备端通过 云消息队列 MQTT 版 可直接和云端的业务应用进行...
消息（Message）
本文介绍 云消息队列 RocketMQ 版 中消息（Message）的定义、模型关系、内部属性、行为约束及使用建议。定义 消息是 云消息队列 RocketMQ 版 中的最小数据传输单元。生产者将业务数据的负载和拓展属性包装成消息发送到 云消息队列 RocketMQ...
消费者负载均衡
使用示例 队列粒度负载均衡策略不需要额外设置，对于历史版本（服务端4.x/3.x版本）的消费者类型PullConsumer默认启用。具体示例代码，请访问 RocketMQ代码库 获取。版本兼容性 消息粒度的负载均衡策略从 云消息队列 RocketMQ 版 服务端5.0...
模型调优
模型调优 模型调优是通过Fine-tuning训练模式提高模型效果的功能模块，作为重要的大模型效果优化方式，用户可以通过构建符合业务场景任务的训练集，调整参数训练模型，训练模型学习业务数据和业务逻辑，最终提高在业务场景中的模型效果。...
主题（Topic）
本文介绍 云消息队列 RocketMQ 版 中主题（Topic）的定义、模型关系、内部属性、行为约束、版本兼容性及使用建议。定义 主题是 云消息队列 RocketMQ 版 中消息传输和存储的顶层容器，用于标识同一类业务逻辑的消息。主题的作用主要如下：...
生产者（Producer）
本文介绍 云消息队列 RocketMQ 版 中生产者（Producer）的定义、模型关系、内部属性、版本兼容性及使用建议。定义 生产者是 云消息队列 RocketMQ 版 系统中用来构建并传输消息到服务端的运行实体。生产者通常被集成在业务系统中，将业务...
作为Input接入
云消息队列 Kafka 版 可以作为Input接入Filebeat。本文说明如何在公网环境下通过Filebeat从 云消息队列 Kafka 版 消费消息。背景信息 在开始本教程前，请确保您已完成以下操作：购买并部署 云消息队列 Kafka 版 实例。具体操作，请参见 ...
作为Output接入
云消息队列 Kafka 版 可以作为Output接入Filebeat。本文说明如何在VPC环境下通过Filebeat向 云消息队列 Kafka 版 发送消息。前提条件 在开始本教程前，请确保您已完成以下操作：购买并部署 云消息队列 Kafka 版 实例。更多信息，请参见 VPC...
命令行工具详情
介绍如何使用DashScope python命令行工具进行模型定制 前言 为了方便您使用模型定制功能，我们提供了python命令行工具，本文档介绍模型定制python命令行的详细使用方式 使用命令行进行模型定制及部署 前提条件 已开通服务并获得api-key：...
作为Output接入
云消息队列 Kafka 版 可以作为Output接入Filebeat。本文说明如何在公网环境下通过Filebeat向 云消息队列 Kafka 版 发送消息。前提条件 在开始本教程前，请确保您已完成以下操作：购买并部署 云消息队列 Kafka 版 实例。具体操作，请参见 ...
将云消息队列 Kafka 版接入阿里云Elasticsearch
随着时间的积累，云消息队列 Kafka 版 中的日志数据会越来越多。当您需要查看并分析庞杂的日志数据时，可通过阿里云Logstash将 云消息队列 Kafka 版 中的日志数据导入阿里云Elasticsearch，然后通过Kibana进行可视化展示与分析。本文介绍将...
作为Input接入
云消息队列 Kafka 版 可以作为Input接入Filebeat。本文说明如何在VPC环境下通过Filebeat从 云消息队列 Kafka 版 消费消息。背景信息 在开始本教程前，请确保您已完成以下操作：购买并部署 云消息队列 Kafka 版 实例。具体操作，请参见 VPC...
作为Input接入
云消息队列 Kafka 版 可以作为Input接入Logstash。本文说明如何在VPC环境下通过Logstash从 云消息队列 Kafka 版 消费消息。前提条件 在开始本教程前，请确保您已完成以下操作：购买并部署 云消息队列 Kafka 版 实例。具体操作，请参见 VPC...
快速使用MQTT.fx模拟SDK收发消息
背景信息 云消息队列 MQTT 版 最简单的使用场景即MQTT客户端消息的自发自收。如下图所示，您可以使用MQTT.fx作为MQTT客户端，在MQTT.fx客户端配置相关参数后接入 云消息队列 MQTT 版 实现消息的发送和接收。云消息队列 MQTT 版 同时提供了 ...
什么是云消息队列 RocketMQ 版？
云消息队列 RocketMQ 版 是阿里云基于Apache RocketMQ构建的低延迟、高并发、高可用、高可靠的分布式“消息、事件、流”统一处理平台，面向互联网分布式应用场景提供微服务异步解耦、流式数据处理、事件驱动处理等核心能力。为什么选择云...
Exchange
本文介绍 云消息队列 RabbitMQ 版 的Exchange的概念和类型，帮助您理解和选择Exchange。什么是Exchange Exchange是 云消息队列 RabbitMQ 版 的消息路由代理。生产者向 云消息队列 RabbitMQ 版 发送消息时，不会直接将消息发送到Queue，而是...
作为Output接入
云消息队列 Kafka 版 可以作为Output接入Logstash。本文说明如何在VPC环境下通过Logstash向 云消息队列 Kafka 版 发送消息。前提条件 购买并部署 云消息队列 Kafka 版 实例。具体操作，请参见 VPC接入。下载并安装Logstash。具体操作，请...
SDK参考概述
SDK兼容性说明 云消息队列 RocketMQ 版 服务端版本和客户端SDK版本的兼容情况如下：服务端版本 客户端版本 兼容性 约束限制 5.x版本实例 RocketMQ 5.x SDK 兼容 云消息队列 RocketMQ 版 5.x版本实例的所有功能完全支持。RocketMQ 4.x/3.x ...
作为Input接入
云消息队列 Kafka 版 可以作为Input接入Logstash。本文说明如何在公网环境下通过Logstash从 云消息队列 Kafka 版 消费消息。前提条件 在开始本教程前，请确保您已完成以下操作：购买并部署 云消息队列 Kafka 版 实例。具体操作，请参见 ...
- 产品推荐
- 这些文档可能帮助您