在 Topic管理 页面，单击目标Topic 操作 列的 更多>体验发送消息。在 快速体验消息收发 页面，输入发送的 消息内容。本文以发送消息 1,a 和 2,b 为例。单击 确定。查询 云数据库ClickHouse 分布式表，确认数据是否同步成功，查询语句如下。...
Topic 详情 页面：在左侧导航栏单击 Topic 管理，在Topic列表中单击目标Topic名称，然后在 Topic 详情 页面单击 仪表盘 页签。Group 详情 页面：在左侧导航栏单击 Group 管理，在Group列表中单击目标Group名称，然后在 Group 详情 页面单击...
Topic 详情 页面：在左侧导航栏单击 Topic 管理，在Topic列表中单击目标Topic名称，然后在 Topic 详情 页面单击 仪表盘 页签。Group 详情 页面：在左侧导航栏单击 Group 管理，在Group列表中单击目标Group名称，然后在 Group 详情 页面单击...
单击目标实例名称，在左侧导航栏单击 Topic管理，然后单击目标Topic名称超链接，并单击 Prometheus监控 页签，可查看阿里云Kafka Topic监控大盘。使用 可观测监控 Prometheus 版 配置阿里云Kafka告警 登录 Prometheus控制台。在左侧导航栏...
单击目标实例名称，在左侧导航栏单击 Topic管理，然后单击目标Topic名称超链接，并单击 Prometheus监控 页签，可查看阿里云Kafka Topic监控大盘。使用 可观测监控 Prometheus 版 配置阿里云Kafka告警 登录 ARMS控制台。在左侧导航栏选择 ...
您可在 云消息队列 Kafka 版 控制台 的 Topic 管理 页面获取。group.id 实例的 Group。您可在 云消息队列 Kafka 版 控制台 的 Group 管理 页面获取。说明 如果应用运行producer.go发送消息，该参数可以不配置；如果应用运行consumer.go订阅...
您可以根据业务场景，将Topic进行分类，给相同业务场景的Topic设置同样的标签，设置完成后，您可以根据设置的标签键和标签值查询任一场景的Topic，以便您快速筛选和管理Topic资源。使用说明 标签都由一对键值对（Key-Value）组成。资源的任...
Topic管理的API API 描述 MQTT型实例下是否支持 CreateProductTopic 创建产品自定义Topic类。否。UpdateProductTopic 修改产品自定义Topic类。QueryProductTopic 查询产品自定义Topic类。DeleteProductTopic 删除产品自定义Topic类。...
登录 云消息队列 Kafka 版 控制台，在目标实例的 Topic 管理 页面查看Topic名称。消息数据格式 Kafka消息数据格式，目前仅支持JSON。参数配置完成后，单击 创建。新建同步链路 在左侧导航栏，单击 SLS/Kafka数据同步。在右上角，单击 新建...
在左侧导航栏单击 Topic 管理，然后在页面左上角，单击 创建 Topic。在创建Topic面板中，输入要创建的Topic 名称 和 描述，然后在左下角单击 确定。步骤三：创建Group ID Group ID详细信息，请参见 名词解释。登录 云消息队列 MQTT 版 控制...
您可在 云消息队列 Kafka 版 控制台 的 Topic 管理 页面获取。username SASL用户名。使用SSL接入点实例时，需配置该参数。说明 如果实例未开启ACL，您可以在 云消息队列 Kafka 版 控制台 的 实例详情 页面的 配置信息 区域获取默认的 用户...
步骤六：中间件初始化 消息队列初始化 创建 Topic 登录消息队列控制台，左侧导航栏选择 Topic 管理，进入 Topic 列表页面。单击列表左上方的 创建 Topic 按钮，在新弹出的对话框中，输入或选择 Topic 信息：Topic：Topic 名称，命名不能以...
在左侧导航栏单击 Topic 管理，然后在页面左上角，单击 创建 Topic。在创建Topic面板中，输入要创建的Topic 名称 和 描述，然后在左下角单击 确定。步骤三：创建Group ID Group ID详细信息，请参见 名词解释。登录 云消息队列 MQTT 版 控制...
您可以在 云消息队列 Kafka 版 控制台创建实例、...云消息队列 Kafka 版 V3系列Serverless实例管理 V2系列实例管理 Topic Group Connector生态集成 迁移 权限管理 云消息队列 Confluent 版 集群资源规格评估 实例管理 权限管理 集群配置与使用
本文介绍如何创建JDBC Connector，将MySQL和 云消息...在左侧导航栏，单击 Topic管理，然后单击目标Topic。在Topic详情页面右上角，单击 体验发送消息。在 快速体验消息收发 面板，设置消息内容。例如在目标表格中添加一条 id 为13，number ...
本文介绍如何创建JDBC Connector，将MySQL和 云消息...在左侧导航栏，单击 Topic管理，然后单击目标Topic。在Topic详情页面右上角，单击 体验发送消息。在 快速体验消息收发 面板，设置消息内容。例如在目标表格中添加一条 id 为13，number ...
在左侧导航栏单击 Topic 管理，然后在页面左上角，单击 创建 Topic。在创建Topic面板中，输入要创建的Topic 名称 和 描述，然后在左下角单击 确定。步骤三：创建Group ID Group ID详细信息，请参见 名词解释。登录 云消息队列 MQTT 版 控制...
在 Topic管理 页面，单击目标Topic名称users。单击 体验发送消息。填写消息内容。配置项 示例 发送方式 选中 控制台。消息Key 填写为flinktest。消息内容 将以下JSON内容复制粘贴到消息内容中。{"id":100001,"first_name":"Dennise","last_...
在左侧导航栏，单击 Topic管理，然后单击目标Topic。在Topic详情页面右上角，单击 体验发送消息。在 快速体验消息收发 面板，设置消息内容。例如在目标表格中添加一条 Key 为Key1，Value 为Value1的数据，消息内容如下。{"key1":"value1"} ...
在左侧导航栏，单击 Topic管理，然后单击目标Topic。在Topic详情页面右上角，单击 体验发送消息。在 快速体验消息收发 面板，设置消息内容。例如在目标表格中添加一条 Key 为Key1，Value 为Value1的数据，消息内容如下。{"key1":"value1"} ...
说明 开发者也可通过云端API实现物联网平台的云端管理能力，例如：产品管理、设备管理、Topic管理、服务端订阅、云产品流转、消息通信等。云端API具体内容，请参见 API列表。云端SDK使用方法，请参见 云端SDK。使用示例，请参见 使用Open...
云消息队列 Kafka 版 通过阿里云控制台和OpenAPI管理Topic数据，目前不支持也不建议自动化创建Topic，主要原因如下：自动化创建Topic不能进行细粒度的权限管控、资源操作审计等，存在安全管控问题。自动化创建Topic会有资源远远超过限制、...
云消息队列 Kafka 版 通过阿里云控制台和OpenAPI管理Topic数据，目前不建议自动化创建Topic，主要原因如下：自动化创建Topic不能进行细粒度的权限管控、资源操作审计等，存在安全管控问题。自动化创建Topic会有资源远远超过限制、资源不能...
云消息队列 Kafka 版 通过阿里云控制台和OpenAPI管理Topic数据，不建议在生产环境中开启自动化创建Topic，主要原因如下：自动化创建Topic不能进行细粒度的权限管控、资源操作审计等，存在安全管控问题。自动化创建Topic会有资源远远超过...
您可在 云消息队列 Kafka 版 控制台 的 Topic 管理 页面获取。group.id 实例的 Group。您可在 云消息队列 Kafka 版 控制台 的 Group 管理 页面获取。说明 如果应用运行producer.go发送消息，该参数可以不配置；如果应用运行consumer.go订阅...
相关API 自定义鉴权模式提供了身份认证和资源授权相关的管控API，您可以根据身份认证的相关API来管理身份信息，可以根据资源授权相关的API来管理Topic的收发权限。API 描述 AddCustomAuthIdentity-添加身份认证 调用AddCustomAuthIdentity...
删除方式 云消息队列 Kafka 版 控制台 云消息队列 Kafka 版 OpenAPI Kafka CLI Kafka Manager 云消息队列 Kafka 版 默认通过阿里云控制台和OpenAPI管理Topic数据，以实现细粒度的权限管控、资源操作审计等安全管控能力。说明 云消息队列 ...
更多信息，请参见 使用Terraform管理Kafka Topic。alicloud_alikafka_sasl_acl 提供Kafka的ACL资源。更多信息，请参见 使用Terraform为SASL用户授权。alicloud_alikafka_sasl_user 提供Kafka的SASL用户资源。更多信息，请参见 使用...
通过创建和执行系统运维管理（OOS）自定义模板，您可以将RocketMQ实例的标签继承到实例中的Topic和Group上。使用限制 默认情况下，某地域的OOS负责管理本地域的资源。例如，华东1（杭州）的OOS默认管理华东1（杭州）的ECS实例。但是，作为...
请求Topic：/sys/${productKey}/${deviceName}/thing/topo/get 响应Topic：/sys/${productKey}/${deviceName}/thing/topo/get_reply 网关类型的设备，可以通过该Topic获取该设备和子设备的拓扑关系。Alink请求数据格式：{"id":"123",...
基于MQTT Topic通信 设备管理 物模型 基于物模型对设备进行管理，无需关心设备与物联网平台之间的数据交互格式，降低开发成本。物模型开发 设备标签 为设备自定义标识，以便灵活管理设备。设备标签 设备影子 缓存设备状态。设备在线时，...
如果您需要同时向多个设备发送自定义Topic消息，可使用物联网平台的消息批量下发任务。本文介绍该任务的创建方法、运行中Topic及其数据格式的说明，查看状态的具体操作。前提条件 已在物联网平台为设备添加具有 订阅 或 订阅和发布 权限的...
50 Topic限制 每个Project内能创建的Topic数量限制，如有特殊请求请联系管理员 500 Topic Lifecycle限制 每个Topic中数据保存的最大时长，单位是天[1,7]单次batch写入条数 每次batch写入数据最大条数限制 10000条 命名规范 名词 描述 长度...
def on_message(self,event):message=event.message content=message.body.decode('utf-8')topic=message.properties.get("topic")message_id=message.properties.get("messageId")print("receive message:message_id=s,topic=s,content=s...
前提条件 已获取消费组ID，并订阅Topic消息。管理消费组：您可使用物联网平台默认消费组（DEFAULT_GROUP）或创建消费组。配置AMQP服务端订阅：您可通过消费组订阅需要的Topic消息。开发环境 本示例使用的开发环境要求如下表。Framework ...
topic=*/*/thing/event/property/post,message=2*7,content={"temperature":29,"humidity":29,"time":1617357297270} 参数 说明 topic 设备属性上报的Topic。messageId 消息的ID。content 消息的内容。失败：例如代码或网络环境有问题，...
保留字符 TBW102 BenchmarkTest SELF_TEST_TOPIC OFFSET_MOVED_EVENT SCHEDULE_TOPIC_XXXX RMQ_SYS_TRANS_HALF_TOPIC RMQ_SYS_TRACE_TOPIC RMQ_SYS_TRANS_OP_HALF_TOPIC 特殊前缀 rmq_sys_%RETRY%DLQ%rocketmq-broker-Topic命名应该尽量...
关于消息的Alink数据格式，请参见 管理拓扑关系 和 子设备上下线。void demo_subdev_recv_handler(void*handle,const aiot_subdev_recv_t*packet,void*user_data){ switch(packet->type){ case AIOT_SUBDEVRECV_TOPO_ADD_REPLY:case AIOT_...
让管理者随时了解物联网终端的安全状况，及时发现安全问题，进行排查和修复。基础版SOC SDK通过Core、Platform、Service三个层次，提供了应用集成，平台移植和服务扩展功能，旨在通过SOC服务一站式地保护物联网终端安全。具体架构如下图所...
128个字符 Topic相关 限制项 描述 限制 自定义Topic类数量 一个产品下最多可以定义Topic类的个数。200 权限 设备只能对自己的Topic进行消息发布与订阅。无 Topic长度 Topic长度不能超过160字节，UTF-8编码字符。160 Topic类目 一个Topic中...