华为云用户手册

  • 命令下发响应测试 命令下发响应测试用于测试设备在接收 物联网平台 命令后主动上报执行结果的能力。当Profile中定义了“命令下发响应字段”,即设备需要返回命令执行结果时,开发者才需要进行命令下发响应测试。由于下发的命令是立即下发模式,设备需要在线。 在命令下发响应测试界面,单击“下一步”开始测试。 根据向导进入测试界面,物联网平台会根据Profile的定义向设备下发一条命令,如果是业务应用接入物联网平台,则操作业务应用向设备下发一条命令。 如果真实设备支持自动返回命令执行结果,则在真实设备收到命令后,直接查看测试用例执行结果。如果真实设备不支持自动返回命令执行结果,则根据真实设备收到的命令,手动操作真实设备上报命令执行结果后,查看测试用例执行结果。 测试成功,单击“下一步”进入下一阶段测试。 测试失败,排查并处理问题后,单击“重新测试”重测测试用例。
  • 通过网关接入平台 针对未实现TCP/IP协议栈的设备,由于无法直接同物联网平台通信,它需要通过网关进行数据转发。常见设备包括智慧园区中的照明系统、楼宇系统设备等。这些场景下的限制如下: 制约因素 详细描述 设备限制 设备非常简单,没有集成TCP/IP协议栈,无法提供IP通信网络能力,只能基于一些简单的近场通信协议如ZigBee、ZWave、Bluetooth或者是其他的一些非IP有线方式传输协议如串口、并口等接入,此时需要一个网关设备,先让设备接入到网关,再通过网关与华为物联网平台通信。 网络限制 设备部署在独立的网络内,由于安全等考虑,无法直接与物联网平台互通,需要借助网关进行网络桥接。 业务限制 下层设备的管理控制逻辑比较复杂,需要利用网关软件自身具有对应的逻辑控制能力配合物联网平台进行业务管理。 集成限制 子设备已经接入到现有系统,不愿意再进行设备改造,需要将现有系统通过网关接入到物联网平台。 针对此类设备,通过在网关上集成Agent Lite SDK, 设备将数据上报给网关,通过网关转发到华为物联网平台。华为公司协同合作伙伴,对已集成Agent Lite SDK的网关进行了认证,您可以访问华为云市场,购买符合自身业务的网关产品。目前Agent Lite SDK支持C、Java和Android三个版本。实际开发中,请根据开发时使用的语言、平台,选用合适的SDK集成: Agent Lite SDK集成开发指导(C) Agent Lite SDK集成开发指导(Java) Agent Lite SDK集成开发指导(Android)
  • 命令接收 当开发者希望设备或网关只接收topic为“/gws/deviceid/signaltrans/v2/categories/”的消息,且对消息中的header进行解析时,可以调用“设备命令接收”接口。 应用服务器可以调用物联网平台的应用侧API接口给设备或网关下发命令,所以网关得随时监听命令下发的广播,以便接收到命令时进行相应业务处理。 注册观察者对命令接收进行相应处理。 1 2 3 4 5 6 //注册观察者 AgentLiteDataTrans agentLiteDataTrans = AgentLiteDataTrans.getInstance(); DataTransService dataTransService = DataTransService.getInstance(); dataTransService.registerObserver(agentLiteDataTrans); //命令接收 agentLiteDataTrans.getCmdReceive(); 被动接收命令的方法getCmdReceive: 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 private void getCmdReceive(IotaMessage iotaMsg) { System.out.println("=========receive iotCMD ============"); String deviceId = iotaMsg.getString(DataTransService.DATATRANS_IE_DEVICEID); String requestId = iotaMsg.getString(DataTransService.DATATRANS_IE_REQUSTID); String serviceId = iotaMsg.getString(DataTransService.DATATRANS_IE_SERVICEID); String method = iotaMsg.getString(DataTransService.DATATRANS_IE_METHOD); String cmd = iotaMsg.getString(DataTransService.DATATRANS_IE_CMDCONTENT); if (method.equals("REMOVE_GATEWAY")) { //rmvGateway(context); } System.out.println ("Receive cmd :" + "ndeviceId = " + deviceId + "nrequestId = " + requestId + "nserviceId = " + serviceId + "nmethod = " + method + "ncmd = " + cmd); }
  • 非直连设备状态更新 注册观察者对非直连设备状态更新结果进行相应处理。 1 2 3 4 5 6 //注册观察者 AgentLiteHub agentLiteHub = AgentLiteHub.getInstance(); HubService hubService = HubService.getInstance(); hubService.registerObserver(agentLiteHub); //sensor状态更新 agentLiteHub.updataDeviceStatus(); 非直连设备添加上时,一般情况下是“离线”状态。所以在非直连设备添加成功后,或者在非直连设备上报数据前,要调用HubService.updateDeviceStatus(int cookie, String deviceId, String status, String statusDetail)进行设备状态更新。 1 2 3 4 5 6 7 8 9 10 11 public void updataDeviceStatus() { System.out.println(" ============= updataDeviceStatus ============== "); int cookie; Random random = new Random(); cookie = random.nextInt(65535); String sensorId = GatewayInfo.getSensorId(); System.out.println("cookie = " + cookie); System.out.println("sensorId = " + sensorId); HubService.updateDeviceStatus(cookie, sensorId, "ONLINE", "NONE"); }
  • 添加非直连设备 在添加非直连设备前,确认非直连设备的profile已经上传了,详见上传Profile并注册设备步骤。 修改非直连设备信息,包括“nodeId”(设备标识码)、“manufactureId”(厂商Id)、“deviceType”(设备类型)、“model”(设备模型)和“protocolType”(协议类型)。这里非直连设备的设备固有信息是测试数据,真实情况下,网关往往需要跟具体的非直连设备交互,才能得到具体的设备固有信息。 1 2 3 4 5 6 7 8 9 10 11 12 13 14 public void addSensor() { System.out.println(" ============= addSensor! ============== "); int cookie; Random random = new Random(); cookie = random.nextInt(65535); String nodeId = "5432154321"; String manufatrueId = "Huawei"; String deviceType = "Motion"; String model = "test01"; String protocolType = "MQTT"; deviceInfo = new IotaDeviceInfo(nodeId, manufatrueId, deviceType, model, protocolType); ... } 注册观察者对添加设备结果进行相应处理。 1 2 3 4 5 6 //注册观察者 AgentLiteHub agentLiteHub = AgentLiteHub.getInstance(); HubService hubService = HubService.getInstance(); hubService.registerObserver(agentLiteHub); //sensor添加 agentLiteHub.addSensor(); 在设备或网关登录成功后就可以调用HubService.addDevice(int cookie, IotaDeviceInfo deviceInfo)接口添加非直连设备。添加非直连设备成功后就能从广播中得到非直连设备的“deviceId”。 1 2 3 4 5 6 7 8 public void addSensor() { System.out.println(" ============= addSensor! ============== "); int cookie; Random random = new Random(); cookie = random.nextInt(65535); ... HubService.addDevice(cookie, deviceInfo); } 非直连设备添加成功后在“设备列表”中看到新增一条记录。
  • 数据上报和数据发布 设备或网关向物联网平台上报数据可以通过调用SDK的“设备服务数据上报”接口或“数据发布”接口: “设备服务数据上报”接口:deviceId,requstId和serviceId由SDK组装为消息的header;serviceProperties由SDK组装为消息的body。消息组装格式为JSON。 注册观察者对网关数据上报结果进行相应处理。 1 2 3 4 5 6 //注册观察者 AgentLiteDataTrans agentLiteDataTrans = AgentLiteDataTrans.getInstance(); DataTransService dataTransService = DataTransService.getInstance(); dataTransService.registerObserver(agentLiteDataTrans); //数据上报 agentLiteDataTrans.gwDataReport(); 设备或网关登录成功后可以调用DataTransService.dataReport(int cookie, String requstId, String deviceId, String serviceId, String serviceProperties)接口上报数据。 1 2 3 4 5 6 7 8 9 10 11 12 13 public void gwDataReport() { System.out.println(" ============= gwDataReport! ============== "); int cookie; Random random = new Random(); cookie = random.nextInt(65535); String deviceId = GatewayInfo.getDeviceID(); JsonObject data = new JsonObject(); data.addProperty("storage", "10240"); data.addProperty("usedPercent", "20"); DataTransService.dataReport(cookie, null, deviceId, "Storage", data.toString()); } 数据上报成功后可以在设备的“历史数据” 中看到上报的数据了。 “数据发布”接口:topic固定为“/cloud/signaltrans/v2/categories/data”;“serviceData”参数作为消息体(包括header和body),SDK只进行透传,不进行格式调整和组装。 注册观察者对网关数据上报结果进行相应处理。 1 2 3 4 5 6 //注册观察者 AgentLiteDataTrans agentLiteDataTrans = AgentLiteDataTrans.getInstance(); DataTransService dataTransService = DataTransService.getInstance(); dataTransService.registerObserver(agentLiteDataTrans); //数据发布 agentLiteDataTrans.gwDataReportByMqttDataPub(); 设备或网关登录成功后可以调用DataTransService. mqttDataPub(int cookie, String topic, int qos, byte[] serviceData)接口发布数据。 “topic”是要发布数据的topic。 “qos”是mqtt协议的一个参数。 “serviceData”实际上是一个json字符串,内容是健值对(可以有多组健值对)。每个健是profile中定义的属性名(propertyName),值就是具体要上报的内容了。 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 public void gwDataReportByMqttDataPub() { System.out.println(" ============= gwDataReportByMqttDataPub! ============== "); int cookie; Random random = new Random(); cookie = random.nextInt(65535); String deviceId = GatewayInfo.getDeviceID(); JsonObject headerData = new JsonObject(); headerData.addProperty("method", "PUT"); String fromStr = "/device/"+deviceId+"/services/Storage"; String toStr = "/data/v1.1.0/devices/"+deviceId+"/services/Storage"; headerData.addProperty("from", fromStr); headerData.addProperty("to", toStr); headerData.addProperty("access_token", GatewayInfo.getAccessToken()); SimpleDateFormat df = new SimpleDateFormat(MSG_TIMESTAMP_FORMAT); df.setTimeZone(TimeZone.getTimeZone("UTC")); String curTime = df.format(new Date(System.currentTimeMillis())); headerData.addProperty("timestamp", curTime); headerData.addProperty("eventTime", curTime); JsonObject bodyData = new JsonObject(); bodyData.addProperty("storage", "10240"); bodyData.addProperty("usedPercent", "18"); JsonObject mqttMsg = new JsonObject(); mqttMsg.add("header", headerData); mqttMsg.add("body", bodyData); DataTransService.mqttDataPub(cookie, "/cloud/signaltrans/v2/categories/data", 1, mqttMsg.toString().getBytes()); }
  • 绑定和登录 设备或网关第一次接入物联网平台时需要进行绑定操作,从而将设备或网关与平台进行关联。开发者通过传入设备验证码以及设备信息,将设备或网关绑定到物联网平台。 修改绑定参数。 绑定时使用的设备固有信息(如设备型号等)是从“AgentLiteBind.java”文件中读取的,所以需要修改./src/main目录下“AgentLiteBind.java”文件中的如下信息: 物联网平台的设备对接地址(MQ TTS )和端口,可参考平台对接信息获取。 1 2 3 //设置配置参数 private static final String PLATFORM_IP = "100.100.100.100"; private static final String HTTPS_PORT = "8943"; “verifyCode”(设备验证码)和必要的设备信息,包括“nodeId”(设备标识码)、“manufactureId”(厂商Id)、“deviceType”(设备类型)、“model”(设备模型)和“protocolType”(协议类型)。“verifyCode”的值与“nodeId”保持一致,“manufactureId”(厂商Id)、“deviceType”(设备类型)、“model”(设备模型)和“protocolType”(协议类型)与Profile文件中的定义保持一致。 如果开发者通过“设备管理服务控制台”注册设备,则“verifyCode”填写为设备注册时的“preSecret”(预置密钥)。 如果通过开发中心注册设备,则“verifyCode”填写为设备注册时设置的“nodeId”(设备标识)。 1 2 3 4 5 6 7 8 9 10 11 public void bindAction() { System.out.println(" ============= start bind ============== "); String nodeId = "1234568"; String verifyCode = "1234568"; String manufactrueId = "Huawei"; String deviceType = "Gateway"; String model = "AgentLite01"; String protocolType = "LWM2M"; deviceInfo = new IotaDeviceInfo(nodeId, manufactrueId, deviceType, model, protocolType); ... } 绑定设备。 注册观察者对设备绑定结果进行相应处理。 1 2 3 4 5 6 //注册观察者 AgentLiteBind agentLiteBind = AgentLiteBind.getInstance(); BindService bindService = BindService.getInstance(); bindService.registerObserver(agentLiteBind); //网关绑定 agentLiteBind.bindAction(); 调用API接口BindConfig.setConfig()设置绑定配置,接着调用API接口BindService .bind(String verifyCode, IotaDeviceInfo deviceInfo)绑定设备。 1 2 3 4 5 6 7 8 public void bindAction() { System.out.println(" ============= start bind ============== "); ... //绑定配置 configBindPara(); //发起绑定请求 BindService.bind(verifyCode, deviceInfo); } 1 2 3 4 5 6 7 //绑定配置 private static void configBindPara() { boolean res = false; res = BindConfig.setConfig(BindConfig.BIND_CONFIG_ADDR, PLATFORM_IP); res = BindConfig.setConfig(BindConfig.BIND_CONFIG_PORT, HTTPS_PORT); ... } 设备或网关绑定成功,后续就不需要再绑定了,除非设备或网关被删除,才需要重新绑定。 设备绑定成功会收到BindService发出的通知,通知内容请参考Agent Lite API接口文档中设备绑定接口的返回结果说明和demo中update函数的处理。 修改登录参数。 在demo的./src/main/AgentLiteLogin.java设置物联网平台的接入IP与端口。 1 2 3 private static final String PLATFORM_IP = "100.100.100.100"; private static final String MQTTS_PORT = "8883"; private static final String HTTPS_PORT = "8943"; 设备登录。 注册观察者对设备登录结果进行相应处理。 1 2 3 4 5 6 //注册观察者 AgentLiteLogin agentLiteLogin = AgentLiteLogin.getInstance(); LoginService loginService = LoginService.getInstance(); loginService.registerObserver(agentLiteLogin); //网关登录 agentLiteLogin.loginAction(); 调用API接口LoginConfig.setConfig()传入所需的登录信息,接着调用API接口LoginService.login()进行直连设备登录,具体API的参数使用参考Agent Lite接口文档中的设备登录接口说明。 “设备Id”(即网关Id, “ LOG IN_CONFIG_DEVICEID”),“appId”(“LOGIN_CONFIG_APPID”)和“密码”(“LOGIN_CONFIG_SECRET”),这些信息是都是从网关绑定成功的通知中得到的。 “平台HTTP地址”(“LOGIN_CONFIG_IOCM_ADDR”)和“MQTT地址”(“LOGIN_CONFIG_MQTT_ADDR”)一般是同一个地址。 1 2 3 4 5 public void loginAction() { System.out.println(" ============= start login ============== "); configLoginPara(); LoginService.login(); } 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 private static void configLoginPara() { if(AgentLiteUtil.isStringEmpty(GatewayInfo.getDeviceID()) || AgentLiteUtil.isStringEmpty(GatewayInfo.getAppID()) || AgentLiteUtil.isStringEmpty(GatewayInfo.getSecret())){ String jsonStr = AgentLiteUtil.readToString("./workdir/gwbindinfo.json"); JsonObject json = new Gson().fromJson(jsonStr, JsonObject.class); GatewayInfo.setDeviceID(json.get("deviceId").getAsString()); GatewayInfo.setAppID(json.get("appId").getAsString()); GatewayInfo.setSecret(json.get("deviceSecret").getAsString()); } LoginConfig.setConfig(LoginConfig.LOGIN_CONFIG_DEVICEID, GatewayInfo.getDeviceID()); LoginConfig.setConfig(LoginConfig.LOGIN_CONFIG_APPID, GatewayInfo.getAppID()); LoginConfig.setConfig(LoginConfig.LOGIN_CONFIG_SECRET, GatewayInfo.getSecret()); LoginConfig.setConfig(LoginConfig.LOGIN_CONFIG_IOCM_ADDR, PLATFORM_IP); LoginConfig.setConfig(LoginConfig.LOGIN_CONFIG_IOCM_PORT, HTTPS_PORT); LoginConfig.setConfig(LoginConfig.LOGIN_CONFIG_MQTT_ADDR, PLATFORM_IP); LoginConfig.setConfig(LoginConfig.LOGIN_CONFIG_MQTT_PORT, MQTTS_PORT); }
  • 使用必读 开发环境要求: 使用的SDK版本为jdk1.8.0_45,适用的操作系统为Windows系统。 工程目录结构及文件说明: 目录结构 目录 说明 AgentLiteDemo │ ├─src │ └─com │ └─huawei │ └─agentlitedemo ├─libs │ └─agentlite-0.0.1-SNAPSHOT │ └─usp_agentlite.jar │ └─.dll └─workdir │ └─conf src 存放Agentlite Demo代码。 libs 存放Agentlite提供的jar包和第三方jar包,以及.dll动态库(工程必须的三个文件,“agentlite-0.0.1-SNAPSHOT”,“usp_agentlite.jar”,“.dll”文件)。 workdir 存放工程日志文件,由agentlite初始化资源设置。 conf 存放TLS证书文件。 如果开发者没有设备,可以直接在X86 Linux系统进行开发。
  • 初始化 在发起业务前,需要先初始化Agent Lite相关资源,调用API接口BaseService.init(),初始化Agent Lite资源,具体API的参数使用参考Agent Lite API接口文档。 调用BaseService.init(String workPath, String logPath)初始化AgentLite资源。 1 res = BaseService.init("./workdir", null);
  • 配置平台信息及证书 配置文件(application.ini)以及证书都分别放置在工作路径“d:/python_sdk/”下面的cert 和resources文件夹中,用户也可自行设置工作路径。 平台IP、端口、appId和密码都是从配置文件中读取的,因此,当这些信息发生变化时,只要修改配置文件,不用修改应用服务器的代码。 [CLIENT_INFO] platformIp = 100.100.100.100 platformPort = 8743 appId = FT8EjQ8O****VbW60Qb8xvga secret = TtuK4Paf*****yAv66himUk8a 在“Constant.py”中,读取证书和CLIENT_INFO。 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 class Constant(object): # 工作路径 workPath = os.path.join('d:/python_sdk/') # 读取证书 def readCertificate(self): certFilePath = os.path.join(Constant.workPath, 'cert/client.crt') certFilePath2 = os.path.join(Constant.workPath, 'cert/client.key') cert = (certFilePath, certFilePath2) return cert # 读取配置文件 def readConfFile(self): configFilePath = os.path.join(Constant.workPath, 'resources/application.ini') cf.read(configFilePath) platformIp = cf.get("CLIENT_INFO", "platformIp") platformPort = cf.get("CLIENT_INFO", "platformPort") appId = cf.get("CLIENT_INFO", "appId") secret = cf.get("CLIENT_INFO", "secret") return platformIp, platformPort, appId, secret # 设置平台对接信息 def clientInfo(self): clientInfo = ClientInfo() clientInfo.setPlatformIp((Constant().readConfFile())[0]) clientInfo.setPlatformPort((Constant().readConfFile())[1]) clientInfo.setAppId((Constant().readConfFile())[2]) clientInfo.setSecret((Constant().readConfFile())[3]) clientInfo = DictUtil.dto2dict(clientInfo) return clientInfo
  • 业务接口调用方法 设置好Constant.py后才能调用其他业务接口。所有业务接口的测试都在“invokeapiTest”中。以如下几个接口为例说明如何调用业务接口: 关于哪些参数需要设置,请查看《应用侧Python SDK API参考》对于可选参数,如果业务不需要,可以不设置。 配置日志 1 2 3 4 5 6 7 8 9 10 11 # 在每个业务接口中都配置了日志,具体日志实现可参考LogUtil.py: # 开发者可通过修改入参来控制日志的输出,以下三个参数都可自行设置; # logPath:日志的输出路径,默认在工作路径d:/python_sdk/log/ # level:日志等级,默认DEBUG(最低等级,即大于等于该等级的日志级别都会输出),如果level=0没有日 志输出 # logFilename:日志名称 def setLogConfig(self, logPath=os.path.join(Constant.workPath, 'log/'), level=logging.DEBUG, logFilename="python_sdk.log"): 鉴权 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 # 在AuthenticationTest.py中对鉴权和刷新token接口进行测试: if __name__ == "__main__": from com.huawei.iotplatform.utils.LogUtil import Log # 实例化Authentication() authentication = Authentication() # 调用鉴权类实例authentication提供的业务接口,如getAuthToken ag = authentication.getAuthToken(Constant().clientInfo()) print("====== get access token ======") print("result:", ag + "\n") # 从返回的ag中获取需要的参数,如accessToken authOutDTO = AuthOutDTO() authOutDTO.setAccessToken(json.loads(ag)['accessToken']) print("token", authOutDTO.getAccessToken()) 订阅 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 # 在SubscriptionManagementTest.py中对订阅订阅平台业务数据接口进行测试: class SubscriptionManagementTest(object): def subDeviceBusinessData(self): sdbdInDTO = SubDeviceBusinessDataInDTO() sdbdInDTO.notifyType = "bindDevice" sdbdInDTO.callbackUrl = "https://XXX.XXX.XXX.XXX:443/callbackurltest" return sdbdInDTO if __name__ == "__main__": from com.huawei.iotplatform.utils.LogUtil import Log # 实例化 smTest = SubscriptionManagementTest() subscriptionManagement = SubscriptionManagement() # get accessToken at first result = Authentication().getAuthToken(Constant().clientInfo()) authOutDTO = AuthOutDTO() authOutDTO.setAccessToken(json.loads(result)['accessToken']) accessToken = authOutDTO.getAccessToken() # 调用订阅类实例subscriptionManagement提供的业务接口,如subDeviceData ss = subscriptionManagement.subDeviceBusinessData(smTest.subDeviceBusinessData(), accessToken) print("====== subscribe to device business data notification ======") print("result:", ss + "\n") 注册设备 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 # 在DeviceManagementTest.py中对注册设备接口进行测试: class DeviceManagementTest(object): def regDirectDeviceInfo(self): rddInDto = RegDirectDeviceInDTO() rddInDto.nodeId = "AAA" + str(random.randint(0, 9999)) return rddInDto if __name__ == "__main__": from com.huawei.iotplatform.utils.LogUtil import Log # 实例化 dmTest = DeviceManagementTest() deviceManagement = DeviceManagement() # get accessToken at first result = Authentication().getAuthToken(Constant().clientInfo()) authOutDTO = AuthOutDTO() authOutDTO.setAccessToken(json.loads(result)['accessToken']) accessToken = authOutDTO.getAccessToken() # 调用设备管理类实例deviceManagement提供的业务接口,如regDirectDevice dr = deviceManagement.regDirectDevice(dmTest.regDirectDeviceInfo(), None, accessToken) print("====== register a new device ======") print("result:", dr + "\n") # 从返回的dr中获取需要的参数,如deviceId rddod = RegDirectDeviceOutDTO() rddod.setDeviceId(json.loads(dr)['deviceId']) deviceId = rddod.getDeviceId() print("deviceId==", deviceId + "\n")
  • 我是模组厂商(联通用户专用) 非联通用户请查看 设备接入服务 。 芯片是一种把集成电路小型化的方式,并时常制造在半导体晶圆表面上。模组是由若干个显示模块、驱动电路、控制电路、芯片以及相应的结构件构成的一个独立的显示单元。模组与芯片关系就像是U盘和Flash芯片的关系,用户99%的情况是直接使用模组,没有人直接用芯片。当前模组厂商主要提供Wifi、NB-IoT、2/3/4/5G等通信模组。 在物联网解决方案中,作为模组厂商的您需要让模组实现MQTTS、LWM2M、CoAP等物联网协议栈及连接平台的能力,您只需要将Agent Tiny SDK集成在现有的模组固件包中,这样模组就具备了接入华为物联网平台的能力。 我们将提供华为IoT技术认证支持,帮助您快速完成SDK集成,通过华为认证的模组可以申请入驻华为云市场,我们将会推荐给物联网平台用户。查询华为已认证的模组。 Agent Tiny SDK具有普适性,可以广泛移植于WiFi模组、2/3/4/5G模组、NB-IoT模组,无需考虑模组类型(了解Agent Tiny SDK详情)。如何在模组中集成Agent Tiny SDK,请参考华为IoT技术认证流程,获取相关技术支持。 父主题: 从这里开始
  • 非直连设备状态更新 非直连设备添加上时,一般情况下是“离线”状态。所以在非直连设备添加成功后,或者在非直连设备上报数据前,要调用HubService.updateDeviceStatus(int cookie, String deviceId, String status, String statusDetail)进行设备状态更新。 1 2 3 4 5 6 7 8 9 10 11 12 13 private void updateDeviceStatus(String status, String statusDetail) { LogUtil.i(this, TAG, "updateDeviceStatus!"); int cookie; Random random = new Random(); cookie = random.nextInt(65535); SharedPreferences preferences = getSharedPreferences("AgentLiteDemo", MODE_PRIVATE); String deviceId = preferences.getString("SENSORID", null); if (deviceId != null) { HubService.updateDeviceStatus(cookie, deviceId, status, statusDetail); } } AgentLiteDemo中只添加了一个非直连设备,所以updateDeviceStatus()方法中使用的“deviceId”是直接从SharedPreferences中读取的。 注册广播接收器对非直连设备状态更新结果进行相应处理。 1 LocalBroadcastManager.getInstance(this).registerReceiver(devStatusUpdateReceiver, new IntentFilter(HubService.TOPIC_DEVSTATUS_RSP));
  • 添加非直连设备 在添加非直连设备前,确认非直连设备的profile已经上传了,详见上传Profile并注册设备步骤。 在设备或网关登录成功后就可以调用HubService.addDevice(int cookie, IotaDeviceInfo deviceInfo)接口添加非直连设备。 这里非直连设备的设备固有信息是测试数据。真实情况下,网关往往需要跟具体的非直连设备交互,才能得到具体的设备固有信息。 1 2 3 4 5 6 7 8 9 10 11 12 13 14 private void addSensor() { SharedPreferences preferences = getSharedPreferences("AgentLiteDemo", MODE_PRIVATE); if (preferences.getString("SENSORID", null) != null) { Toast.makeText(this, "The sensor is already added.", Toast.LENGTH_SHORT).show(); return; } LogUtil.i(this, TAG, "addSensor!"); int cookie; Random random = new Random(); cookie = random.nextInt(65535); IotaDeviceInfo deviceInfo = new IotaDeviceInfo("0123456test", "Huawei", "Motion", "test01", "MQTT"); HubService.addDevice(cookie, deviceInfo); } 注册广播接收器对添加设备结果进行相应处理。添加非直连设备成功后就能从广播中得到非直连设备的“deviceId”。 1 LocalBroadcastManager.getInstance(this).registerReceiver(addDeviceReceiver, new IntentFilter(HubService.TOPIC_ADDDEV_RSP)); 非直连设备添加成功后可以在“设备列表”中看到新增一条记录。
  • 编译安装程序 绑定和登录功能完成后,可以先测试一下网关是否能正常与平台对接,再进行后续功能开发。 将Android设备连到计算机上,点击“”按钮编译安装工程到Android设备上。 在Android设备上运行AgentLiteDemo,修改“平台IP”、“MQTT端口”、“HTTP端口”和“verifyCode”等值。 “平台IP”、“MQTT端口”和“HTTP端口”可以从物联网平台环境开发中心的“对接信息”界面获取。 “verifyCode”则是设备的标识,每个设备对应一个verifyCode,不可重复,所以建议使用IMEI或者MAC地址等天然的设备标识。AgentLiteDemo可以在界面上人工输入设备的verifyCode,测试时只要输入一个没有使用过的verifyCode即可。
  • 数据上报和数据发布 设备或网关向物联网平台上报数据可以通过调用SDK的“设备服务数据上报”接口或“数据发布”接口: “设备服务数据上报”接口:deviceId,requstId和serviceId由SDK组装为消息的header;serviceProperties由SDK组装为消息的body。消息组装格式为JSON。 设备或网关登录成功后可以调用DataTransService.dataReport(int cookie, String requstId, String deviceId, String serviceId, String serviceProperties)接口上报数据。 当设备主动上报数据时,“requstId”可以为空。 当上报的数据为某个命令的响应时,“requstId”必须与下发命令中的“requstId”保持一致。requestId可以从广播中获取,请参考API文档中“设备命令接收”接口的广播参数“DATATRANS_IE_REQUESTID”的说明。 “serviceId”要与profile中定义的某个serviceId保持一致,否则无法上报数据。 “serviceProperties”实际上是一个json字符串,内容是健值对(可以有多组健值对)。每个健是profile中定义的属性名(propertyName),值就是具体要上报的内容了。 1 2 3 4 5 6 7 8 9 10 private void gatewayDataReport() { LogUtil.i(this, TAG, "gatewayDataReport!"); int cookie; String deviceId = GatewayInfo.getDeviceID(); Random random = new Random(); cookie = random.nextInt(65535); LogUtil.i(this, TAG, "cookie = " + cookie); DataTransService.dataReport(cookie, null, deviceId, "Storage", "{\"storage\":10240,\"usedPercent\":20}"); } 注册广播接收器对网关数据上报结果进行相应处理。 1 LocalBroadcastManager.getInstance(this).registerReceiver(dataReportRsp, new IntentFilter(DataTransService.TOPIC_DATA_REPORT_RSP)); “数据发布”接口:topic固定为“/cloud/signaltrans/v2/categories/data”;“serviceData”参数作为消息体(包括header和body),SDK只进行透传,不进行格式调整和组装。 设备或网关登录成功后可以调用DataTransService. mqttDataPub(int cookie, String topic, int qos, byte[] serviceData)接口发布数据。 “Topic”是要发布数据的topic。 “Qos”是mqtt协议的一个参数。 “serviceData”实际上是一个json字符串,内容是健值对(可以有多组健值对)。每个健是profile中定义的属性名(propertyName),值就是具体要上报的内容了。 1 2 3 private void gatewayDataPub(int cookie, String topic, int qos, byte[] serviceData) { DataTransService. mqttDataPub(cookie, topic, qos, serviceData); } 注册广播接收器对网关数据上报结果进行相应处理。 1 LocalBroadcastManager.getInstance(this).registerReceiver(mqttDataPubRsp, new IntentFilter(DataTransService.TOPIC_MQTT_PUB_RSP));
  • 绑定和登录 设备或网关第一次接入IoT联接管理平台时需要进行绑定操作,从而将设备或网关与平台进行关联。开发者通过传入设备序列号以及设备信息,将设备或网关绑定到物联网平台。 设备或网关绑定成功后或重启后,需要进行登录的流程,在设备或网关成功登录物联网平台后,才可以进行其它服务操作,比如接入其他传感器,数据上报等等。如果设备或网关登录成功,那么设备或网关在平台的状态显示为已在线。 修改绑定参数。 绑定时使用的设备固有信息(如设备型号等)是从“config.properties”文件中读取的,所以需要修改./app/src/main/assets/conf目录下config.properties文件中的如下信息: “platformIP”:物联网平台的设备对接地址(MQTTS),可参考平台对接信息获取。 “verifyCode”(设备的标识)和必要的设备信息,包括“Manufacture”(厂商Id)、“deviceType”(设备类型)、“HardwareModel”(设备模型)和“protocolType”(协议类型),其中“manufacturerId”(厂商Id)、“deviceType”(设备类型)、“HardwareModel”(设备模型)和“protocolType”(协议类型)与Profile文件中的定义保持一致。 如果通过“设备管理服务控制台”注册设备,则“verifyCode”填写为设备注册时的“preSecret”(预置密钥)。 如果通过开发中心注册设备,则“verifyCode”填写为设备注册后返回的“nodeId”(设备标识)。 “config.properties”文件中设备固有示例: platformIP=100.100.100.100 mqttPort=8883 httpPort=8943 verifyCode=0123456789 Manufacturer=Huawei HardwareModel=AgentLite01 deviceType=Gateway protocolType=HuaweiM2M 绑定设备。 调用API接口BindConfig.setConfig()设置绑定配置。 1 2 3 4 5 6 private void startBind() { .... configBindPara(); registerBindReceiver(); ... } 1 2 3 4 private void configBindPara() { BindConfig.setConfig(BindConfig.BIND_CONFIG_ADDR, AgentLiteUtil.get(ConfigName.platformIP)); BindConfig.setConfig(BindConfig.BIND_CONFIG_PORT, AgentLiteUtil.get(ConfigName.httpPort)); } 注册广播接收器对设备绑定结果进行相应处理。 1 LocalBroadcastManager.getInstance(this).registerReceiver(mBindStatusReceiver, new IntentFilter(BindService.TOPIC_BINDDEVICE_RSP)); 调用API接口BindService .bind(String verifyCode, IotaDeviceInfo deviceInfo)绑定设备,主要入参为“verifyCode”(设备验证码)和必要的设备信息,包括“nodeId”(设备标识码)、“Manufacture”(厂商Id)、“deviceType”(设备类型)、“HardwareModel”(设备模型)和“protocolType”(协议类型),其中“verifyCode”的值与“nodeId”保持一致。 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 private void startBind() { LogUtil.i(this, TAG, "startBind"); String nodeId = AgentLiteUtil.get(ConfigName.verifyCode); String verifyCode = AgentLiteUtil.get(ConfigName.verifyCode); String manufacturerId = AgentLiteUtil.get(ConfigName.Manufacturer); String deviceType = AgentLiteUtil.get(ConfigName.deviceType); String model = AgentLiteUtil.get(ConfigName.HardwareModel); String protocolType = AgentLiteUtil.get(ConfigName.protocolType); IotaDeviceInfo deviceInfo = new IotaDeviceInfo(nodeId, manufacturerId, deviceType, model, protocolType); ... BindService.bind(verifyCode, deviceInfo); } 设备或网关绑定成功,后续就不需要再绑定了,除非设备或网关被删除,才需要重新绑定。 设备绑定成功会收到广播,广播内容请参考Agent Lite API接口文档中设备绑定接口的返回结果说明和demo中mBindStatusReceiver函数的处理。 配置登录参数。 登录前需要通过参数配置接口LoginConfig.setConfig()传入所需的登录信息。 “设备Id”(即网关Id, “LOGIN_CONFIG_DEVICEID”),“appId”(“LOGIN_CONFIG_APPID”)和“密码”(“LOGIN_CONFIG_SECRET”),这些信息是都是从网关绑定成功的广播中得到的。 “平台HTTP地址”(“LOGIN_CONFIG_IOCM_ADDR”)和“MQTT地址”(“LOGIN_CONFIG_MQTT_ADDR”)一般是同一个地址,可以从绑定成功的广播中得到。一般情况下,这个地址和Agent Lite设备或网关对接的平台地址一致。 绑定成功的广播参数获取可以参考mBindStatusReceiver函数的处理。 1 2 3 4 5 6 7 8 9 private void configLoginPara() { LoginConfig.setConfig(LoginConfig.LOGIN_CONFIG_DEVICEID, GatewayInfo.getDeviceID()); LoginConfig.setConfig(LoginConfig.LOGIN_CONFIG_APPID, GatewayInfo.getAppID()); LoginConfig.setConfig(LoginConfig.LOGIN_CONFIG_SECRET, GatewayInfo.getSecret()); LoginConfig.setConfig(LoginConfig.LOGIN_CONFIG_IOCM_ADDR, GatewayInfo.getHaAddress()); LoginConfig.setConfig(LoginConfig.LOGIN_CONFIG_IOCM_PORT, "8943"); LoginConfig.setConfig(LoginConfig.LOGIN_CONFIG_MQTT_ADDR, GatewayInfo.getHaAddress()); LoginConfig.setConfig(LoginConfig.LOGIN_CONFIG_MQTT_PORT, "8883"); } 设备登录。 注册广播接收器对设备登录结果进行相应处理。 1 LocalBroadcastManager.getInstance(this).registerReceiver(LoginConnectReceiver, new IntentFilter(LoginService.TOPIC_LOGIN_CONNECTED)); 调用LoginService.login()进行直连设备登录,具体API的参数使用参考Agent Lite接口文档中设备登录接口的说明。 1 2 3 4 5 private void startLogin() { LogUtil.i(this, TAG, "startLogin"); configLoginPara(); LoginService.login(); }
  • 初始化 在发起业务前,需要先初始化Agent Lite相关资源,调用API接口BaseService.init(),初始化Agent Lite资源,具体API的参数使用参考Agent Lite API接口文档。可参考“AgentLiteMain.java”中onCreate()方法对BaseService.init()的调用。 1 BaseService.init(WORK_PATH, LOG_PATH, context); “WORK_PATH”为工作路径,不能为空。 “LOG_PATH”为打印日志路径,当“LOG_PATH”为空时,打印路径默认为工作路径,开发者也可以自己定义打印日志路径。
  • 使用必读 开发环境要求: Android系统:API_LEVEL21及以上。 工程目录结构及文件说明: 目录结构 目录 说明 Agent LiteDemo │ ├─src │ └─com │ └─huawei │ └─agentlitedemo ├─gen ├─assets │ └─conf ├─bin ├─libs │ └─armeabi └─res src 存放Agent Lite Demo代码 libs 存放Agent Lite提供的jar包和第三方jar包 armeabi 存放Agent Lite编译后的库文件和第三方库文件 conf 存放TLS证书文件、配置文件 如果开发者没有设备,可以直接在X86 Linux系统进行开发。
  • 申请发布产品 产品在通过所有测试用例后,单击“申请发布”。 系统自动完成厂商信息和产品信息完整性的检查。如果没有重要信息缺失,则单击“发布”。 黄色信息缺失提示:部分信息不完整,不影响发布产品,但发布到产品中心可能会审核不通过,建议补充。 红色信息缺失提示:重要信息缺失,需补充完整才能发布产品。 选择发布方式:“公开发布”或“私有发布”,单击“发布”,提交发布申请。 注:一旦发布不可修改发布方式。 查看产品是否发布到产品中心。 登录认证产品中心,选择“产品”,在产品列表查看通过审核的产品。 (可选)申请关联云市场产品,以便用户通过产品中心直接购买该产品。 进入认证产品中心,鼠标移至右上角的用户名,单击下拉列表中的“我的产品”。 在产品列表,单击产品右侧的“云市场发布”。 系统弹出“云市场发布”窗口,单击“填入商品ID”,然后单击“确定”。 注:“商品ID”为云市场产品的产品ID,在产品审核上架后,可在云市场中该产品的商品详情页面获取。云市场发布产品请参考云市场商品接入。
  • 在线开发Profile(联通用户专用) 非联通用户请查看设备接入服务。 在线创建Profile前需要先创建项目并定义产品。创建产品需要输入manufactureId、manufactureName、deviceType、Model等信息,Profile会使用这些信息作为设备能力字段取值。在产品创建时,如果选择使用系统模板,则系统将会自动使用相应的Profile模板,您可以直接使用或在此基础上进行修改;如果选择自定义产品模板,则需要完整定义Profile。 本节定义包含一个服务的Profile为示例,该Profile包含设备上报数据、下发命令、下发命令响应、软固件升级等场景的服务和字段。 在“产品开发”界面选择产品,选择具体产品,进入该产品的开发空间。 在产品开发空间,点击“Profile定义”,然后点击“新建服务”。 在“新建服务”区域,对服务名称、属性和命令进行定义。每个服务下,可以包含属性和命令,也可以只包含其中之一,请根据此类设备的实际情况进行配置。 填写“服务名称”,“服务名称”采用首字母大写的命名方式,比如:WaterMeter、Battery。 点击“添加属性”,在弹出窗口中配置属性的各项参数,点击“确定”。 名称:首位必须为字母,建议采用驼峰形式,如batteryLevel、internalTemperature。 数据类型:配置可参考如下原则: int:当上报的数据为整数或布尔值时,可以配置为此类型。 decimal:当上报的数据为小数时,可以配置为此类型。配置“经纬度”属性时,数据类型建议使用“decimal”。 string:当上报的数据为字符串、枚举值或布尔值时,可以配置为此类型。如果为枚举值或布尔值,值之间需要用英文逗号(“,”)分隔。 DateTime:当上报的数据为日期时,可以配置为此类型。 jsonObject:当上报的数据为json结构体时,可以配置为此类型。 访问模式:设置应用服务器通过接口访问数据的模式: R:通过接口可以查询该属性。 W:通过接口可以修改该属性值。 E:应用服务器订阅了数据变化通知后,设备上报了属性,应用服务器会收到推送通知。 是否必选:设备上报的这个属性是不是必选。 点击“添加命令”,在弹出窗口中配置“命令名称”,点击“确定”。“命令名称”首位必须为字母,建议采用全大写形式,单词间用下划线连接的命名方式,如DISCOVERY,CHANGE_STATUS。 点击“添加下发命令字段”,在弹出窗口中配置下发命令字段的各项参数,点击“确定”。“下发命令字段名称”首位必须为字母,建议采用第一个单词首字母小写,其余单词的首字母大写的命名方式,比如valueChange;其余参数,请根据此类设备的实际情况进行配置。 如果要添加命令响应,点击“添加响应命令字段”,在弹出窗口中配置响应命令字段的各项参数,点击“确定”。“响应命令字段名称”首位必须为字母,建议采用第一个单词首字母小写,其余单词的首字母大写的命名方式,比如valueResult;其余参数,请根据此类设备的实际情况进行配置。 如果要添加软件/固件升级能力,在“维护能力配置 ”下,开启“软件升级”/“固件升级”。 提交后,Profile中会自动多出一个“DM服务”应用于升级。 父主题: 开发Profile
  • 数组及可变长数组数据类型 如果该烟感设备需要支持描述信息上报功能,描述信息描述信息支持数组和可变长度数组两种类型,则按照以下步骤创建消息。 Profile定义 在烟感产品的开发空间完成Profile定义。 编解码插件开发 在烟感产品的开发空间,选择“编解码插件开发”。 配置数据上报消息,上报数组类型的描述信息。 添加messageId字段,表示消息种类。在本场景中,0x0用于标识上报火灾等级和温度的消息,0x1用于标识只上报温度的消息,0x2用于标识上报描述信息(数组类型)的消息。 添加other_info字段,表示数组类型的描述信息。在本场景中,“长度”配置为5个字节。 配置数据上报消息,上报可变长度数组类型的描述信息。 添加messageId字段,表示消息种类。在本场景中,0x0用于标识上报火灾等级和温度的消息,0x1用于标识只上报温度的消息,0x3用于标识上报描述信息(可变长度数组类型)的消息。 添加length字段,表示数组长度。“数据类型”根据可变长度数组的长度进行配置,长度在255以内,配置为“int8u”。 添加other_info字段,表示可变长度数组类型的描述信息。“长度关联字段”选择“length”,“长度关联字段差值”和“数值长度”自动填充。 拖动右侧“设备模型”区域的属性字段,与数据上报消息的相应字段建立映射关系。 点击“保存”,并在插件保存成功后点击“部署”,将编解码插件部署到物联网平台。 调测编解码插件 在烟感产品的开发空间,选择“在线调测”,使用虚拟设备调试编解码插件。 勾选“没有真实的物理设备”,点击“创建”。 使用设备模拟器上报数组类型的描述信息。 十六进制码流示例:0211223344。02表示messageId,此消息上报数组类型的描述信息;11223344表示描述信息,长度为4个字节。 在“应用模拟器”区域查看数据上报的结果:{other_info=null}。描述信息不足5个字节,编解码插件无法解析。 十六进制码流示例:021122334455。02表示messageId,此消息上报数组类型的描述信息;1122334455表示描述信息,长度为5个字节。 在“应用模拟器”区域查看数据上报的结果:{other_info=ESIzRF=}。描述信息长度为5个字节,编解码插件解析成功。 十六进制码流示例:02112233445566。02表示messageId,此消息上报数组类型的描述信息;112233445566表示描述信息,长度为6个字节。 在“应用模拟器”区域查看数据上报的结果:{other_info=ESIzRF=}。描述信息长度超过5个字节,编解码插件截取前5个字节进行解析。 使用设备模拟器上报可变长度数组类型的描述信息。 十六进制码流示例:030101。03表示messageId,此消息上报可变长度数组类型的描述信息;01表示描述信息长度(1个字节),长度为1个字节;01表示描述信息,长度为1个字节。 在“应用模拟器”区域查看数据上报的结果:{other_info=AQ==}。AQ==是01经过base64编码后的值。 十六进制码流示例:03020102。03表示messageId,此消息上报可变长度数组类型的描述信息;02表示描述信息长度(2个字节),长度为1个字节;0102表示描述信息,长度为2个字节。 在“应用模拟器”区域查看数据上报的结果:{other_info=AQI=}。AQI=是01经过base64编码后的值。 十六进制码流示例:03030102。03表示messageId,此消息上报可变长度数组类型的描述信息;03表示描述信息长度(3个字节),长度为1个字节;0102表示描述信息,长度为2个字节。 在“应用模拟器”区域查看数据上报的结果:{other_info=null}。描述信息长度不足3个字节,编解码插件解析失败。 十六进制码流示例:0303010203。03表示messageId,此消息上报可变长度数组类型的描述信息;03表示描述信息长度(3个字节),长度为1个字节;010203表示描述信息,长度为3个字节。 在“应用模拟器”区域查看数据上报的结果:{other_info=AQID}。AQID是010203经过base64编码后的值。 十六进制码流示例:030301020304。03表示messageId,此消息上报可变长度数组类型的描述信息;03表示描述信息长度(3个字节),长度为1个字节;01020304表示描述信息,长度为4个字节。 在“应用模拟器”区域查看数据上报的结果:{other_info=AQID}。描述信息长度超过3个字节,编解码插件截取前3个字节进行解析,AQID是010203经过base64编码后的值。 base64编码方式说明 base64编码方式会把3个8位字节(3*8=24)转化为4个6位字节(4*6=24),并在每个6位字节前补两个0,构成4个8位字节的形式。如果要进行编码的码流不足3个字节,则在码流后用0填充,使用0填充的字节经编码输出的字符为“=”。 base64可以将16进制码流当做字符或者数值进行编码,两种方式获得的编码结果不同。以16进制码流01为例进行说明: 把01当作字符,不足3个字符,补1个0,得到010。通过查询ASCII码表,将字符转换为8位二进制数,即:0转换为00110000、1转换为00110001,因此010可以转换为001100000011000100110000(3*8=24)。再转换为4个6位字节:001100、000011、000100、110000,并在每个6位字节前补两个0,得到:00001100、00000011、00000100、00110000。这4个8位字节对应的10进制数分别为12、3、4、48,通过查询base64编码表,获得M(12)、D(3)、E(4),由于3个字符中,最后一个字符通过补0获得,因此第4个8位字节使用“=”表示。最终,把01当做字符,通过base64编码得到MDE=。 把01当作数值(即1),不足3个字符,补两个0,得到100。将数值转换为8位2进制数,即:0转换为00000000、1转换为00000001,因此100可以转换为000000010000000000000000(3*8=24)。在转换为4个6位字节:000000、010000、000000、000000,并在每个6位字节前补两个0,得到:00000000、00010000、00000000、00000000。这4个8位字节对应的10进制数分别为:0、16、0、0,通过查询base64编码表,获得A(0)、Q(16),由于3个数值中,最后两个数值通过补0获得,因此第3、4个8位字节使用“=”表示。最终,把01当作数值,通过base64编码得到AQ==。 总结 当数据类型为数组或可变长度数组时,插件是按照base64进行编解码的:上报数据时,将16进制码流进行base64编码,比如:01编码为“AQ==”;命令下发时,将字符进行base64解码,比如:“AQ==”解码为01。 当某字段的数据类型为可变长度数组时,该字段需要关联长度字段,长度字段的数据类型必须为int。 针对可变长度数组,命令下发和数据上报的编解码插件开发方式相同。 在线开发的编解码插件使用base64进行编码时,是将16进制码流当做数值进行编码。
  • 字符串及可变长字符串的编解码插件在线开发 如果该烟感设备需要支持描述信息上报功能,描述信息支持字符串和可变长度字符串两种类型,则按照以下步骤创建消息。 Profile定义 在烟感产品的开发空间完成Profile定义。 编解码插件开发 在烟感产品的开发空间,选择“编解码插件开发”。 配置数据上报消息,上报字符串类型的描述信息。 添加messageId字段,表示消息种类。在本场景中,0x0用于标识上报火灾等级和温度的消息,0x1用于标识只上报温度的消息,0x2用于标识上报描述信息(字符串类型)的消息。 添加other_info字段,表示字符串类型的描述信息。在本场景中,“长度”配置 6个字节。 配置数据上报消息,上报可变长度字符串类型的描述信息。 添加messageId字段,表示消息种类。在本场景中,0x0用于标识上报火灾等级和温度的消息,0x1用于标识只上报温度的消息,0x3用于标识上报描述信息(可变长度字符串类型)的消息。 添加length字段,表示字符串长度。“数据类型”根据可变长度字符串的长度进行配置,长度在255以内,配置为“int8u”。 添加other_info字段,表示可变长度字符串类型的描述信息。“长度关联字段”选择“length”,“长度关联字段差值”和“数值长度”自动填充。 拖动右侧“设备模型”区域的属性字段,与数据上报消息的相应字段建立映射关系。 点击“保存”,并在插件保存成功后点击“部署”,将编解码插件部署到物联网平台。 调测编解码插件 在烟感产品的开发空间,选择“在线调测”,使用虚拟设备调试编解码插件。 勾选“没有真实的物理设备”,点击“创建”。 使用设备模拟器上报字符串类型的描述信息。 十六进制码流示例:0231。02表示messageId,此消息上报字符串类型的描述信息;31表示描述信息,长度为1个字节。 在“应用模拟器”区域查看数据上报的结果:{other_info=null}。描述信息不足6个字节,编解码插件无法解析。 十六进制码流示例:02313233343536。02表示messageId,此消息上报字符串类型的描述信息;313233343536表示描述信息,长度为6个字节。 在“应用模拟器”区域查看数据上报的结果:{other_info=123456}。描述信息长度为6个字节,编解码插件解析成功。 十六进制码流示例:023132333435363738。02表示messageId,此消息上报字符串类型的描述信息;3132333435363738表示描述信息,长度为8个字节。 在“应用模拟器”区域查看数据上报的结果:{other_info=123456}。描述信息长度超过6个字节,编解码插件截取前6个字节进行解析。 十六进制码流示例:02013132333435。02表示messageId,此消息上报字符串类型的描述信息;013132333435表示描述信息,长度为6个字节。 在“应用模拟器”区域查看数据上报的结果:{other_info=\u000112345}。01在ASCII码表里表示“标题开始”,无法用具体字符表示,因此编解码插件解析为\u0001。 使用设备模拟器上报可变长度字符串类型的描述信息。 十六进制码流示例:030141。03表示messageId,此消息上报可变长度字符串类型的描述信息;01表示描述信息长度(1个字节),长度为1个字节;41表示描述信息,长度为1个字节。 在“应用模拟器”区域查看数据上报的结果:{other_info=A}。41是A的十六进制ASCII码。 十六进制码流示例:03024142。03表示messageId,此消息上报可变长度字符串类型的描述信息;02表示描述信息长度(2个字节),长度为1个字节;4142表示描述信息,长度为2个字节。 在“应用模拟器”区域查看数据上报的结果:{other_info=AB}。4142是AB的十六进制ASCII码。 十六进制码流示例:030341424344。03表示messageId,此消息上报可变长度字符串类型的描述信息;03表示描述信息长度(3个字节),长度为1个字节;41424344表示描述信息,长度为4个字节。 在“应用模拟器”区域查看数据上报的结果:{other_info=ABC}。描述信息长度超过3个字节,编解码插件截取前3个字节进行解析,414243是ABC的十六进制ASCII码。 十六进制码流示例:0304414243。03表示messageId,此消息上报可变长度字符串类型的描述信息;04表示字符串长度(4个字节),长度为1个字节;414243表示描述信息,长度为4个字节。 在“应用模拟器”区域查看数据上报的结果:{other_info=null}。描述信息长度不足4个字节,编解码插件解析失败。 总结 当数据类型为字符串或可变长度字符串时,插件是按照ASCII码进行编解码的:上报数据时,将16进制码流解码为对应字符串,比如:21解析为“!”、31解析为“1”、41解析为“A”;下发命令时,将字符串编码对应的16进制码流,比如:“!”编码为21,“1”编码为31,“A”编码为41。 当某字段的数据类型为可变长度字符串时,该字段需要关联长度字段,长度字段的数据类型必须为int。 针对可变长度字符串,命令下发和数据上报的编解码插件开发方式相同。 在线开发的编解码插件使用ASCII码16进制的标准表对字符串和可变长度字符串进行编解码。解码时(数据上报),如果解析结果无法使用具体字符表示,如:标题开始、正文开始、正文结束等,则使用\u+2字节码流值表示(例如:01解析为\u0001,02解析为\u0002);如果解析结果可以使用具体字符表示,则使用具体字符。
  • 数据上报和命令下发 场景说明 有一款烟感设备,具有如下特征: 具有烟雾报警功能(火灾等级)和温度上报功能。 支持远程控制命令,可远程打开报警功能。比如火灾现场温度,远程打开烟雾报警,提醒住户疏散。 Profile定义 在烟感产品的开发空间,完成Profile定义。 level:火灾级别,用于表示火灾的严重程度。 temperature:温度,用于表示火灾现场温度。 SET_ALARM:打开或关闭告警命令,value=0表示关闭,value=1表示打开。 编解码插件开发 在烟感产品的开发空间,选择“编解码插件开发”。 配置数据上报消息。 添加level字段,表示火灾级别。 “字段名”只能输入包含字母、数字、_和$,且不能以数字开头的字符。 “数据类型”根据设备上报数据的实际情况进行配置,需要和Profile相应字段的定义相匹配。 “长度”和“偏移值”根据“数据类型”的配置自动填充。 添加temperature字段,表示温度。在Profile中,temperature属性最大值1000,因此在插件中定义temperature字段的“数据类型”为“int16u”,以满足temperature属性的取值范围。 配置命令下发消息。 添加value字段,表示下发命令的参数值。 拖动右侧“设备模型”区域的属性字段和命令字段,数据上报消息和命令下发消息的相应字段建立映射关系。 点击“保存”,并在插件保存成功后点击“部署”,将编解码插件部署到物联网平台。 调测编解码插件 在烟感产品的开发空间,选择“在线调测”,使用虚拟设备调试编解码插件。 勾选“没有真实的物理设备”,点击“创建”。 使用设备模拟器进行数据上报。十六进制码流示例:02013A。02表示火灾级别,长度为1个字节;013A表示温度,长度为2个字节。 在“应用模拟器”区域查看数据上报的结果:{level=2, temperature=314}。2为十六进制数02转换为十进制的数值;314为十六进制数013A转换为十进制的数值。 使用应用模拟器进行命令下发:{ "serviceId": "Smoke", "method": "SET_ALARM", "paras": "{\"value\":1}" }。 在“设备模拟器”区域查看命令接收的结果:01。01为十进制数1转换为十六进制的数值。
  • 多条数据上报消息 如果该烟感设备需要支持同时上报烟雾报警(火灾等级)和温度,也支持单独上报温度,则按照以下步骤创建消息。 编解码插件开发 在烟感产品的开发空间,选择“编解码插件开发”。 配置数据上报消息,上报火灾等级和温度。 添加messageId字段,表示消息种类。 在本场景中,数据上报消息有两种,所以需要用messageId来标识消息种类。 “数据类型”根据数据上报消息种类的数量进行配置。在本场景中,仅有两种数据上报消息,配置为“int8u”即可满足需求。 “默认值”可以修改,但必须为十六进制格式,且数据上报消息的对应字段必须和默认值保持一致。在本场景中,用0x0标识上报火灾等级和温度的消息。 添加level字段,表示火灾级别。 “字段名”只能输入包含字母、数字、_和$,且不能以数字开头的字符。 “数据类型”根据设备上报数据的实际情况进行配置,需要和Profile相应字段的定义相匹配。 “长度”和“偏移值”根据“数据类型”的配置自动填充。 添加temperature字段,表示温度。在Profile中,temperature属性最大值1000,因此在插件中定义temperature字段的“数据类型”为“int16u”,以满足temperature属性的取值范围。 配置数据上报消息,只上报温度。 添加messageId字段,表示消息种类。在本场景中,用0x1标识只上报温度的消息。 添加temperature字段,表示温度。 配置命令下发消息。 添加value字段,表示下发命令的参数值。 拖动右侧“设备模型”区域的属性字段和命令字段,与数据上报消息和命令下发消息的相应字段建立映射关系。 level字段和temperature字段分别与Profile中的对应属性建立映射关系,messageId用于帮插件识别消息种类,不需要建立映射关系。 点击“保存”,并在插件保存成功后点击“部署”,将编解码插件部署到物联网平台。 调测编解码插件 在烟感产品的开发空间,选择“在线调测”,使用虚拟设备调试编解码插件。 勾选“没有真实的物理设备”,点击“创建”。 使用设备模拟器进行数据上报。 十六进制码流示例:000100F1。00表示messageId,此消息上报火灾等级和温度;01表示火灾级别,长度为1个字节;00F1表示温度,长度为2个字节。 在“应用模拟器”区域查看数据上报的结果:{level=1, temperature=241}。1为十六进制数01转换为十进制的数值;241为十六进制数00F1转换为十进制的数值。 十六进制码流示例:0100F1。01表示messageId,此消息只上报火灾温度;00F1表示温度,长度为2个字节。 在“应用模拟器”区域查看数据上报的结果:{temperature=241}。241为十六进制数00F1转换为十进制的数值。 使用应用模拟器进行命令下发:{ "serviceId": "Smoke", "method": "SET_ALARM", "paras": "{\"value\":1}" }。 在“设备模拟器”区域查看命令接收的结果:01。01为十进制数1转换为十六进制的数值。
  • AT指令集 AT指令用于控制设备。如下AT命令仅供参考,具体命令集请向相应的模组厂商获取。 AT命令 作用 备注 AT+CMEE=1 报错查询。 标准AT指令 AT+CFUN=0 关机。设置IMEI和平台IP端口前要先关机。 标准AT指令 AT+CGSN=1 查询IMEI。IMEI为设备标识,应用服务器调用API接口注册设备时,nodeId/verifyCode都需要设置为IMEI。 标准AT指令 AT+NTSETID=1,xxxx xxxx为IMEI。如果查询不到可自行设置IMEI,IMEI必须是唯一的,不能与其他设备重复,且只能设置一次。 IMEI为设备标识,应用服务器调用API接口注册设备时,如果设备使用海思芯片,则nodeId/verifyCode都需要设置成IMEI;如果设备使用高通芯片,则nodeId/verifyCode都需要设置成urn:imei:IMEI。 海思芯片私有AT指令,在flash中保存IMEI。应用服务器在向平台进行设备注册时,使用此参数,其他芯片或模组厂商可参考实现。 AT+NCDP="IP","port" 设置设备对接的物联网平台的IP地址和端口号,5683为非加密端口,5684为DTLS加密端口。 海思芯片私有AT指令,在flash中保存IP和端口。应用服务器在向平台进行设备注册时,使用此参数,其他芯片或模组厂商可参考实现。 AT+CFUN=1 开机。 标准AT指令 AT+NBAND=频段 设置频段。 海思芯片私有AT指令,在flash中保存频段。设备在入网时,使用此参数,其他芯片或模组厂商可参考实现。 AT+CGDCONT=1,"IP","CTNB" 设置核心网APN。APN与设备的休眠、保活等模式有关,需要与运营商确认。 标准AT指令 AT+CGATT=1 入网。 标准AT指令 AT+CGPADDR 获取终端IP地址。 标准AT指令 AT+NMGS=x,xxxx 发送上行数据。第1个参数为字节数,第2个参数为上报的16进制业务码流。 海思芯片私有AT指令,初次发送数据时,完成设备注册;后续发送数据时,仅发送数据。其他芯片或模组厂商可参考实现。 AT+NQMGR 接收下行数据。 海思芯片私有AT指令,查询接收buffer中可以接收的数据量,以及当前总共接收的消息数和丢弃的消息数。其他芯片或模组厂商可参考实现。 AT+NMGR 读取数据。 海思芯片私有AT指令,读取从物联网平台(LWM2M SERVER)接收到的数据。其他芯片或模组厂商可参考实现。
  • 接入流程 测试场景:平台提供LoRaWAN协议的测试环境,多个用户共用一个Network Server,您可以通过提工单的方式获取测试账号,目前账号使用期限为7天,到期回收。 商用场景:LoRa服务商在华为云为每个客户部署一个Network Server。 前置条件: 在LoRaWAN设备接入物联网平台前,您需要完成以下前置条件: 选择LoRa服务商:选择一个LoRa服务商并与其达成合作关系,您可以通过提交工单咨询华为云物联网平台当前支持的LoRa服务商。 完成LoRa网络的对接调试:在选择LoRa服务商后,您需要根据LoRa服务商的要求和指导,完成LoRaWAN设备、LoRa网关和LoRa Server的对接调试。 接入流程: 步骤 说明 对接LoRa Server LoRa Server作为一个MQTT设备在物联网平台上注册并上线。 创建LoRa网关 LoRa网关作为LoRa Server下的一个子设备,在物联网平台上注册。 创建LoRaWAN设备 LoRaWAN设备作为LoRa Server下的一个子设备,在物联网平台上注册。 业务调试 对接入物联网平台的LoRaWAN设备进行数据上报和命令下发测试,具体操作可参考数据上报和命令下发。
  • 概述 LoRa(Long Range Radio)是当前应用较广的一种物联网无线接入技术,它最大的特点就是在同样功耗条件下比其他无线接入方式传播的距离更远,实现了低功耗和远距离的统一,它在同样的功耗下比传统的无线射频通信距离扩大3-5倍。而LoRaWAN是为LoRa远距离通信网络设计的一套通讯协议和系统架构。 物联网平台支持设备通过LoRa网络接入,但LoRaWAN设备不能直连物联网平台,需要经过LoRa服务商提供的LoRa Server接入物联网平台,如下图所示。 LoRa Server:由LoRa服务商提供的LoRa接入服务器,LoRa Server与物联网平台之间通过MQTT协议对接,与LoRa网关之间通过标准IP网络对接。 LoRa网关:LoRa网关向设备提供LoRa网络接入,设备通过LoRa网关对接到LoRa Server。LoRa网关通常也由LoRa服务商提供。 LoRaWAN设备:LoRaWAN设备即LoRa节点,其通过LoRa网络接入LoRa网关,然后通过LoRa Server最终接入到物联网平台。LoRaWAN设备可以通过以下几种方式获取: 直接购买合适的LoRaWAN设备。 购买LoRa模组,并集成到设备中。 LoRaWAN设备和LoRa网关并无一一对应关系,LoRaWAN设备可通过LoRa网络向任一个LoRa网关发送数据。若多个LoRa网关同时接收到一个LoRaWAN设备的数据并上报到LoRa Server,LoRa Server会进行数据去重。
  • OpenLab现场测试 合作伙伴在物联网平台上完成产品开发(包括平台侧开发、设备侧开发和应用侧开发)后,然后才可以进行OpenLab技术认证,认证流程如下。 关键操作 说明 相关资源 成为合作伙伴 提交企业相关信息,成为合作伙伴,可以申请合作伙伴的权益。 注:如果未 注册华为账号 ,需先进行华为账号注册。 成为合作伙伴 合作方案构建 合作伙伴根据华为提供的构建指导书,提交合作方案资料。通过专业检测服务完成该方案的构建和优化。 - 合作方案技术认证 合作方案完成构建后,合作伙伴可以申请华为技术认证。通过认证的方案,将获得华为颁发的技术认证证书,同时该技术认证结果将公布到华为技术认证证书网站供合作伙伴和客户查询。 华为IoT应用认证指导(Enabled) 华为NB-IoT终端认证指导(Compatible) 华为IoT Agent Lite终端认证指导(Compatible) 华为IoT Agent Tiny终端认证指导(Compatible)
  • 认证概述 华为IoT技术认证是华为面向合作伙伴提供的IoT技术认证服务,旨在通过严谨而专业的检测技术帮助合作伙伴发现并解决自身产品的不足,缩短产品上市周期,同时联合合作伙伴向共同的客户提供经过验证的方案。通过该认证的伙伴产品将获得华为颁发的IoT技术认证证书,该证书标志着华为对双方物联网产品预集成的技术认可。 技术认证特点: 权威性:提供华为商业化平台认证服务、国家/区域重要法规认证服务、重要行业安全标准认证服务,得到许多行业客户以及运营商的认可。 全面性:完备的测试环境和专业的测试服务,从功能、性能、可靠性、安全、可维护性等为物联网产品提供端到端的软硬件能力测试,高效打造优质产品。 多渠道推广:达到一定标准的产品可以在产品中心发布,获得证书的产品不仅可以在产品中心、华为云市场发布,而且还可以享受华为提供的商业推广机会,例如展会活动、联合营销等。 方便快捷 :OpenLab认证实验室全球覆盖、线上一站式申请、线下专业人员指导,为全球合作伙伴提供贴身的技术认证服务。 华为会针对行业特点对认证产品的安全进行必要的验证,但不承担合作伙伴所属产品的安全责任。
共100000条
提示

您即将访问非华为云网站,请注意账号财产安全