说明 Operation 为 SUB（订阅）时，才可以使用通配符+和#自定义Topic类，以便设备实现批量订阅Topic。通配符使用方法请参见 带通配符的自定义Topic。对于云网关产品，Topic类完全由用户自定义输入。支持使用${deviceName} 通配 DeviceName...
在左侧导航栏，选择 监控运维>日志服务，选择夜灯开关产品后，查看设备上线、订阅Topic和上报消息的日志。说明 您可以忽略关于订阅Topic/sys/a18wP*/LightSwitch/thing/deviceinfo/update_reply 的日志。该订阅为SDK自带默认功能，不影响您...
GB/T 32960协议云网关设备不具备Topic订阅能力，所以不支持将GB/T 32960协议云网关设备数据流转至另一个Topic。云产品流转的数据源，仅支持 自定义、设备状态变化通知 和 设备生命周期变更，配置自定义数据源时，需您手动输入车辆设备的 ...
只有设备操作权限为 订阅 时，才可以使用通配符+和#自定义Topic类，以便设备实现批量订阅Topic。通配符使用方法，请参见 带通配符的自定义Topic。上行通信：设备端到服务端 设备端向通信Topic发布消息，服务端可通过物联网平台的AMQP订阅或...
Topics Map 否["rm_bp15jj3qi1p8f*"]分布式订阅任务下所有的订阅Topic。多个订阅Topic间以英文逗号（,）分隔。说明 本参数和参数 SubMigrationJobIds 两者中至少传入一个。推荐填入参数 SubMigrationJobIds。RegionId String 否 ...
配置 AMQP服务端订阅 后，物联网平台会自动将设备消息转发到AMQP客户端，不需要在代码中订阅Topic，只要AMQP客户端在线就可以接收消息。不能通过 AMQP服务端订阅 向设备 下发消息，如果需要请调用 消息通信的API。使用场景 业务服务器接收...
为自增 Long 型 Topic String test-mq_topic 订阅的 Topic 名称 TagsSet Array of String*订阅的 Tag 集合 DetailInTopicList Array of DetailInTopicList 各个 Topic 的消费情况 TotalDiff Long 0 该 Topic 消费总堆积数 DelayTime Long 0...
使用MQTT协议接入的设备和物联网平台，通过订阅Topic或向Topic发布消息的方式进行通信。Topic分为系统Topic、物模型Topic和自定义Topic，其中自定义Topic需要用户在控制台定义。本文为您介绍设备使用自定义Topic与物联网平台进行上下行通信...
使用MQTT协议接入的设备和物联网平台，通过订阅Topic或向Topic发布消息的方式进行通信。Topic分为系统Topic、物模型Topic和自定义Topic，其中自定义Topic需要用户在控制台定义。本文为您介绍设备使用自定义Topic与物联网平台进行上下行通信...
订阅Topic：Kafka Topic的名称，一个入湖任务仅支持订阅一个Topic，不支持同时订阅多个Topic。数据预处理。目前Kafka入湖任务中需要通过定义预处理算子的方式，对Kafka Topic中的消息进行解析、过滤等处理。详情请参见 数据预处理。配置...
JT/T 808协议云网关设备不具备Topic订阅能力，所以不支持将JT/T 808协议云网关设备数据流转至另一个Topic。云产品流转的数据源，仅支持 自定义、设备状态变化通知 和 设备生命周期变更，配置自定义数据源时，需您手动输入厂商ID、设备型号...
Topic API 标题 API概述 GetTopicSubscribeStatus 获取订阅 Topic 的 Group 信息 获取订阅 Topic 的 Group 信息。CreateTopic 创建Topic 创建Topic。DeleteTopic 删除Topic 删除Topic。ModifyPartitionNum 修改Topic的分区数 修改Topic的...
订阅Topic device.subscribe(checkStatusTopic);测试设备状态 System.out.println("we will check device online status now.");device.checkStatus();准备测试设备离线状态，请拔掉网线 System.out.println("pls close network，we will ...
保留消息用于确保新订阅Topic的设备能及时收到最新状态的消息，即使消息在设备订阅之前发布。服务端向Topic发布消息时，如果消息携带保留标记（Reatin），物联网平台将会保存这个消息并实时发布给订阅者，后续订阅该Topic的设备都会收到 ...
ConfigureTopicSubscription 配置Topic订阅文件。ConfirmReverseTaskDetail 保存模型逆向任务配置。CopyApi 克隆数据。Create 登录产品售卖页面进行的购买操作。CreateAccount 创建账号。CreateAdjunct 创建修饰词。CreateAlisaTask 创建...
[removeDownStreamListener:]上行数据[publish:data:qos:resultBlock:][uploadData:data:qos:complete:]，或者[publish:params:complete:]订阅Topic[subscribe:resultBlock:][subscribe:complete:]取消订阅Topic[unsubscribe:resultBlock:...
建议您提前订阅Topic以免漏失信息。示例：设备向Topic A发送SUB请求，10秒后，订阅生效，设备开始收到实时消息，除非取消订阅，设备会一直接收Topic A的消息。10秒 广播Topic 要广播的消息主体报文大小不能超过64 KB。需要转换消息原文为...
如果使用MQTT 5.0版本协议，此场景下，客户端在订阅Topic时，可以设置此选项为 true，客户端将不会接收到自己发布的消息。取值：true：不接收。false：接收。Retain As Publish：服务端向客户端转发消息时是否保留其中的 RETAIN 标识。取值...
而使用MQTT 5.0版本协议，此场景下，设备在订阅Topic时，可以设置此选项为 1，设备将不会接收到自己发布的消息。可取值：1：不接收。0：接收。设备通配订阅时，使用该特性，既简化订阅动作，又可以避免收到无意义的消息。如下图所示：...
时间格式，如："2021-05-22 11:00:00"如果没有指定，则默认从 OFFSET_END 开始订阅Topic下的所有Partition。示例如下。kafka_partitions"="0,1,2,3","kafka_offsets"="101,0,OFFSET_BEGINNING,OFFSET_END""kafka_partitions"="0,1,2,3",...
订阅topic-1中Tag消息属性为tag-1的所有消息。const char*tag_1="tag-1;const char*topic_2="topic-2;订阅topic-2的所有消息。const char*tag_2="*;请注册自定义侦听函数用来处理接收到的消息，并返回响应的处理结果。...
订阅Topic device.subscribe(rrpcTopic);}/*初始化*@param pk productKey*@param dn deviceName*@param ds deviceSecret*@throws InterruptedException*/public void init(String pk,String dn,String ds)throws InterruptedException { ...
例如给user1授予了Topic A的消息发布权限，则客户端使用user1的用户名密码通过了身份认证后，只能向Topic A发送消息，不能订阅Topic A的消息。若ACL用户创建后未进行授权，则该用户默认没有任何消息发布和订阅的权限。设置访问控制类型 ...
示例产品功能描述 示例产品连接到阿里云物联网平台之后，将会订阅TOPIC“/${ProductKey}/${deviceName}/user/get”的数据，然后每4秒发送一个消息到该topic，意味着这个消息会被发送到物联网平台，然后由于设备自己订阅了这个topic，因此...
订阅Topic。consumer.subscribe(factoryInfo.getPublishTopics(),"*",new MyMsgListener());启动客户端实例。consumer.start();该设置仅供Demo使用，实际生产环境中请保证进程不退出。Thread.Sleep(300000);在进程即将退出时，关闭消费者...
Spark Streaming消费DataHub 准备工作 使用DataHub的订阅功能订阅Topic，详细信息请参见 创建订阅。消费DataHub数据 运行Spark Streaming作业消费DataHub数据有两种使用方式：指定特定的ShardId，消费该ShardId的数据。datahubStream=...
SubscribeTopic String cn_hangzhou_rm_bp1162kryivb8*_dtstest_version2 订阅Topic。说明 当该订阅实例为新版，且调用 CreateConsumerGroup 接口创建了消费组时，才会返回本参数。SubscriptionDataType Struct 订阅数据的类型。DDL ...
步骤五：子设备订阅Topic 子设备通过网关设备接入物联网平台后，可以调用 aiot_mqtt_sub，订阅子设备的Topic，接收对应Topic的消息。注意 订阅Topic时，注意区分子设备和网关设备的 ProductKey 和 DeviceName，确保订阅所需设备的Topic。...
fd=6(cost 44763 bytes in total,max used 47675 bytes)[1583135792.888][LK-0313]MQTT connect success in 147 ms AIOT_MQTTEVT_CONNECT 订阅Topic日志：如果要向指定产品下所有设备发送广播消息，设备需订阅该Topic，例如/broadcast/a18...
SubscribeTopic String cn_hangzhou_rm_bp1162kryivb8*_dtstest_version2 订阅Topic。说明 当该订阅实例为新版，且调用 CreateConsumerGroup 接口创建了消费组时，才会返回本参数。SubscriptionDataType Struct 订阅数据的类型。DDL ...
在物联网平台控制台的设备详情页面的 已订阅Topic列表 中也不会显示该Topic。{"deviceSendTime":"1571724098000","serverRecvTime":"1571724098110","serverSendTime":"1571724098115"} 设备端计算出服务端当前精确的Unix时间。假设基于...
智能灯设备需要订阅Topic：/al123456789/light/user/set，才能接收指令。接收指令后，需要开发执行指令的逻辑方法。设备端SDK开发详情，请参见 设备接入Link SDK。配置消息转发解析器 设置消息转发解析器，将手机App发布的指令流转到智能灯...
前提条件 已获取消费组ID，并订阅Topic消息。管理AMQP消费组：您可使用物联网平台默认消费组（DEFAULT_GROUP）或创建消费组。配置AMQP服务端订阅：您可通过消费组订阅需要的Topic消息。准备开发环境 示例使用的开发环境如下：操作系统：...
服务端可以直接订阅产品下所有类型的消息，配置服务端...订阅Topic为/sys/${productKey}/${deviceName}/thing/downlink/reply/message，需要根据 requestId 关联请求和响应。requestId 为阿里云和设备产生通信时的信息ID。后续步骤 设备运行时
消息通信的API API 描述 MQTT型实例下是否支持 SubscribeTopic 为指定设备订阅Topic。否。UnsubscribeTopic 为指定设备取消已订阅的指定Topic。否 QueryDeviceSubTopic 查询设备已订阅的Topic列表。否。UpdateTopicConfig 设置自定义Topic...
函数原型 public boolean listenTopics(List<String>topics,EventHandler handler,EventModelType type)请求参数 参数 必选 类型 说明 topics true List 订阅Topic 列表 handler true EventHandler 当收到响应、超时或发生错误时回调 type ...
前提条件 已获取消费组ID，并订阅Topic消息。管理消费组：您可使用物联网平台默认消费组（DEFAULT_GROUP）或创建消费组。配置AMQP服务端订阅：您可通过消费组订阅需要的Topic消息。准备开发环境 本示例所使用的开发环境为Python 2.7版。...
device 设备到云消息：uplink 云到设备消息：downlink API调用：ApiService 服务端订阅：ServiceSubscribe 设备影子：DeviceShadow 规则引擎（云产品流转）：RuleEngine 订阅（订阅Topic）：subscribe 取消订阅（取消订阅Topic）：...
参数 必选 类型 说明 topics true List订阅 Topic 列表 handler true IEventCallback 当收到主题事件响应后回调。vmType true VMTypeEnum 合约类型。1：EVM，2：WASM type true EventModelType 事件模型类型。1：PULL；2：PUSH 返回字段 ...
AMQP客户端：启动 解析器 后，物联网平台会自动将设备消息转发到AMQP客户端，不需要在AMQP客户端代码中订阅Topic，只要AMQP客户端在线就可以接收消息。说明 云产品流转不支持从AMQP客户端下发消息给设备，如果需要下发指令给设备，请调用 ...