为方便 Python 程序使用 ACM 管理应用配置,ACM 提供了 Python SDK。ACM Python SDK 现已开源,使用方法请参考 Github。
云消息队列 MQTT 版 通过Token鉴权模式向MQTT客户端提供临时访问权限。您可通过MQTT Token服务来给本地账号系统管理的用户颁发临时的访问凭证,并限制访问权限,以实现对单一客户端、单一资源的细粒度权限控制。本文介绍使用流程以及相关...
云消息队列 MQTT 版 通过Token鉴权模式向MQTT客户端提供临时访问权限。您可通过MQTT Token服务来给本地账号系统管理的用户颁发临时的访问凭证,并限制访问权限,以实现对单一客户端、单一资源的细粒度权限控制。本文介绍使用流程以及相关...
您可以在服务器上(或者多台服务器)部署多个生产者和消费者实例,也可以在同一个生产者或消费者实例里采用多线程发送或接收消息,从而提高消息发送或接收TPS。重要 请避免为每个线程创建一个客户端实例。顺序消息不建议使用多线程发送。云...
对于本地已有的Python项目,或在本地开发Python应用后,您可以将该应用打包成ZIP格式的压缩包并部署至 Serverless应用引擎SAE(Serverless App Engine)。本文介绍ZIP打包规范以及如何使用ZIP包部署应用。ZIP打包规范 打包代码根目录文件...
当设备与 云消息队列 MQTT 版 建立连接时,需要将设备访问凭证中的信息按照约定的形式设置到Username和Password中,向 云消息队列 MQTT 版 发起认证请求,云消息队列 MQTT 版 认证通过后激活设备,设备与 云消息队列 MQTT 版 间才可传输...
队列大小 是 线程队列的大小取决于应用程序的需求和系统资源的可用性。在多线程编程中,当队列大小过小时,可能会导致任务排队等待的时间过长,从而降低程序的性能;而当队列大小过大时,可能会导致系统资源的消耗过多,从而导致系统崩溃...
本文介绍如何在创建任务时直接编写Shell、Python和Go脚本以便创建脚本任务。接入方式 脚本任务支持两种接入方式:依赖jar包嵌在应用进程中。Agent接入(非Java SDK方式)。创建方式 脚本任务在创建调度任务时编写脚本即可。更多信息,请...
如果您想创建一个只有自己可见的队列,不允许其他用户访问,您可以使用 云消息队列 RabbitMQ 版 的排他性队列特性,将指定的队列声明为排他性。什么是排他队列 排他性队列的特点如下:排他队列只对首次声明它的连接(Connection)可见,...
云消息队列 RocketMQ 版 所提供的TCP Java SDK支持多线程消费,且适用于所有消息类型,本文介绍如何设置消费线程数的方法。在启动Consumer时,设置一个ConsumeThreadNums属性即可。具体示例如下所示。public static void main(String[]args...
在使用Python SDK收发消息前,您需按照本文提供的内容来准备环境。环境要求 安装Python。更多信息,请参见 安装...安装完成后,您可以执行 python-V 命令查看Python语言版本。安装SDK 执行以下命令,安装Python SDK。pip install mq_http_sdk
您可获取社区版TCP协议的SDK,来访问阿里云 云消息队列 RocketMQ 版。重要 所有社区版的SDK均由Apache RocketMQ社区提供,您可获取源码自行编译,但不在阿里云RocketMQ的SLA范围。和社区版SDK相比,商业版的SDK提供了更加丰富的功能特性并...
本文介绍 SOFARPC 可用的配置项和常见配置。基础配置项说明 您可以根据自身环境的需求,在 application.properties 文件中添加以下配置项:配置项 类型 说明 默认值 sofa_runtime_local_mode BOOLEAN 本地优先调用开关。false run_mode ...
本文介绍如何使用队列分组管理计算节点,包括创建和删除队列,以及在队列之间移动节点。背景信息 创建集群时会自动创建一个默认队列,计算节点默认会加入到该队列中。操作步骤 打开 节点与队列 页面。登录 弹性高性能计算控制台。在顶部...
应用场景 云消息队列 MQTT 版 拥有多协议、多语言和多平台的支持能力,且广泛应用于移动互联网以及物联网领域,覆盖移动直播、车联网、金融支付、智能餐饮、即时聊天等多种应用场景。购买云消息队列 MQTT 版 您可以在 商品购买页 购买 云...
SchedulerX支持定时调度程序、多语言脚本和HTTP接口,也支持调度原生的K8s Job或者Pod。本文介绍如何在Kubernetes环境中部署SchedulerX。前提条件 接入SchedulerX,具体操作,请参见 在Kubernetes集群中部署SchedulerX。创建K8s任务 Shell...
SchedulerX支持定时调度程序、多语言脚本和HTTP接口,也支持调度原生的K8s Job或者Pod。本文介绍如何在Kubernetes环境中部署SchedulerX。前提条件 接入SchedulerX,具体操作,请参见 在Kubernetes集群中部署SchedulerX。创建K8s任务 Shell...
生产者发送消息到 云消息队列 RocketMQ 版 服务端时,云消息队列 RocketMQ 版 将根据生产者负载均衡策略将消息均匀的存储在多个队列中,避免产生热点队列和性能瓶颈。本文介绍 云消息队列 RocketMQ 版 生产者的负载均衡策略。背景信息 了解...
本章节介绍 云消息队列 Kafka 版 的 正式商用公告细则。正式商用细则 云消息队列 Kafka 版 的正式商用细则如下:为提高服务质量和用户体验,云消息队列 Kafka 版 全部以商用实例方式提供服务。实例的基本规格和定价信息请参见 计费概述。...
本文介绍如何进行 云消息队列 Confluent 版 集群的网络访问与安全设置。网络访问类型 云消息队列 Confluent 版 集群提供阿里云VPC访问和公网访问方式。阿里云VPC访问 VPC访问是指您在 云消息队列 Confluent 版 集群所在网络VPC内或者其它...
本文介绍如何使用Python SDK通过接入点接入 云消息队列 Kafka 版 并收发消息。环境准备 安装Python 说明 Python版本为2.7或3.X。安装pip 添加Python依赖库 执行以下命令安装依赖库。pip install confluent-kafka=1.9.2 重要 建议您安装...
本文介绍 云消息队列 RocketMQ 版 的SDK和API的支持情况,供您进行对应的开发操作。云消息队列 RocketMQ 版 消息收发需要通过调用SDK完成,云消息队列 RocketMQ 版 的SDK支持Java、C++、.NET、Go等多语言开发。SDK参考提供了各语言的SDK的...
Workers Workers是用于承载Connectors实例和Tasks线程运行的进程,支持两种运行模式:单机模式(Standalone mode)和分布式模式(Distributed mode),一个Worker进程中可以运行多个Connector实例线程和Task线程。Standalone mode:只有...
云消息队列 RocketMQ 版 的所有主题都是由多个队列组成,以此实现队列数量的水平拆分和队列内部的流式存储。队列通过QueueId来做唯一标识和区分。更多信息,请参见 队列(MessageQueue)。消息(Message)消息是 云消息队列 RocketMQ 版 中...
普通消息是指 云消息队列 RocketMQ 版 中无特性的消息,区别于有特性的定时和延时消息、顺序消息和事务消息。说明 您在调用SDK收发消息时需注意,云消息队列 RocketMQ 版 提供的四种消息类型所对应的Topic不能混用,例如,您创建的普通消息...
本文介绍如何获取和使用 云消息队列 RabbitMQ 版 多语言SDK。SDK下载 云消息队列 RabbitMQ 版 的多语言SDK的下载地址及说明文档如下。语言 下载地址 说明文档 Java Alibaba Cloud AMQP SDK for Java 开始使用 Go Alibaba Cloud AMQP SDK ...
云消息队列 RocketMQ 版 的所有主题都是由多个队列组成,以此实现队列数量的水平拆分和队列内部的流式存储。队列的主要作用如下:存储顺序性 队列天然具备顺序性,即消息按照进入队列的顺序写入存储,同一队列间的消息天然存在顺序关系,...
云消息队列 RocketMQ 版 提供了通过HTTP协议的多语言SDK接入的能力,并支持公网访问。本文介绍HTTP协议下的多语言SDK的版本说明。多语言支持 云消息队列 RocketMQ 版 支持RESTful风格的HTTP协议通信,并提供了7种语言的SDK。HTTP协议的SDK...
云消息队列 RabbitMQ 版 支持的多语言或框架SDK如 云消息队列 RabbitMQ 版支持的多语言或框架SDK 所示。表 2.云消息队列 RabbitMQ 版 支持的多语言或框架SDK 语言或框架 SDK C++ amqp-cpp-demo....
云消息队列 RabbitMQ 版 是一款基于高可用分布式存储架构实现的AMQP 0-9-1协议的消息产品。云消息队列 RabbitMQ 版 兼容开源RabbitMQ客户端,解决开源各种稳定性痛点(例如消息堆积、脑裂等问题),同时具备高并发、分布式、灵活扩缩容等云...
是否支持可靠异步发送 是否支持Oneway发送 是否支持多线程发送 性能 普通消息 是 是 是 是 最高 事务消息 定时和延时消息 分区顺序消息 是 否 否 否 高 全局顺序消息 一般 消息特性 消息重试:在消费者返回消息重试的响应后,云消息队列 ...
云消息队列 RocketMQ 版 对实例的资源配额、实例规格和相关参数进行了约束和规范,您在使用 云消息队列 RocketMQ 版 时不要超过对应的限制值,避免应用出现异常。参数限制 以下参数中各资源的命名及备注等限制值不支持调整,请严格按照规范...
您也可以将批作业部署到指定资源队列,并配合任务编排功能确定调度优先级,以确保关键或重要作业获得更高的处理优先级和更多的资源,从而提高系统性能和资源利用率。您可以通过以下方式使用资源队列:部署作业时,部署目标选择为目标资源...
迁移成功后,目标 云消息队列 Kafka 版 实例下会创建对应的Topic和 Group。您可以在 Topic 管理 和 Group 管理 页面的列表中查看。前提条件 您已将自建Kafka集群迁移至 云消息队列 Kafka 版 实例中。迁移类型包括:通过命令行迁移 迁移...
这种机制可以带来顺序读写、高吞吐、高性能等优势,但缺点是不支持按主题和队列单独管理。安全生产和容量保障风险要求:即使 云消息队列 RocketMQ 版 按照主题或者队列独立生成存储文件,但存储层本质还是共享存储介质。单独根据主题或队列...
云消息队列 MQTT 版 V2.x.x版本强依赖 云消息队列 RocketMQ 版 作为消息存储,因此 云消息队列 MQTT 版 消息和 云消息队列 RocketMQ 版 天然打通,创建了Topic后即可天然使用 云消息队列 RocketMQ 版 和 云消息队列 MQTT 版 的SDK相互通信...
迁移元数据上云是指将开源RabbitMQ集群的元数据导出,并将其导入到阿里云 云消息队列 RabbitMQ 版 实例。云消息队列 RabbitMQ 版 会根据成功导入的元数据在目标 云消息队列 RabbitMQ 版 实例中创建对应的Vhost、Queue、Exchange、Binding,...
消费者从 云消息队列 RocketMQ 版 获取消息消费时,通过消费者负载均衡策略,可将主题内的消息分配给指定消费者分组中的多个消费者共同分担,提高消费并发能力和消费者的水平扩展能力。本文介绍 云消息队列 RocketMQ 版 消费者的负载均衡...
云消息队列 Kafka 版 提供全托管、免运维的迁移上云服务,用于自建实例或跨云云实例与 云消息队列 Kafka 版 实例之间的数据同步。本文介绍迁移上云的源实例类型、使用限制、跨VPC数据同步以及使用流程。前提条件 您已购买并部署 云消息队列...
本文介绍如何在 云消息队列 Kafka 版 控制台创建消息流出任务,将指定 云消息队列 Kafka 版 实例中的数据导出至其他的 云消息队列 Kafka 版。前提条件 您已购买并部署 云消息队列 Kafka 版 实例,且实例处于 服务中 状态。具体步骤,请参见...