检测到您已登录华为云国际站账号,为了您更好的体验,建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
用户进入函数详情页,选择“event-property”测试事件,单击“测试”,测试函数。 图10 配置测试事件 函数执行成功后,可在函数详情页右侧通过日志查看函数执行情况。 图11 函数执行结果 配置设备接入服务 在设备接入服务中设置数据转发规则,实现当设备上报数据时将数据转发至FunctionGraph。
Connect应用与数据集成平台 x x √ - FunctionGraph函数工作流服务 x √ √ - MRS Kafka流式集群 x x √ - MySQL数据库 x √ √ - InfluxDB时序数据库 x √ √ - BCS区块链服务 x x √ - MongoDB数据库 x x √ -
environment variables CLOUD_SDK_AK and CLOUD_SDK_SK in the local environment ak = os.environ["CLOUD_SDK_AK"] sk = os.environ["CLOUD_SDK_SK"]
environment variables CLOUD_SDK_AK and CLOUD_SDK_SK in the local environment ak = os.environ["CLOUD_SDK_AK"] sk = os.environ["CLOUD_SDK_SK"]
strapUri为上述终端节点。 运行DEMO程序,看到如下日志,代表设备发放成功,并且已经收到设备发放下发的设备接入地址。如果程序运行没报错,在对应的设备接入平台可以看到设备,并已在线。 收到设备发放下发的设备接入地址后,需要关闭设备侧的设备发放的连接,用的新的URL地址与设备接入通信,进行相关业务。
keyStore, “”, scopeId)。 运行DEMO程序,看到如下日志,代表设备发放成功,并且已经收到设备发放下发的设备接入地址。如果程序运行没报错,在对应的设备接入平台可以看到设备,并已在线。 父主题: MQTT场景--使用华为SDK接入设备发放示例
说明。 设备发放对返回参数的约束 表1 TdpFuncResult 名称 说明 类型 statusCode String 函数执行状态码,用于标识函数执行过程是否出现异常,遵循HTTP状态码含义。 body String 字符串,但格式为JSON,结构为TdpFuncBody。 表2
-L/home/test/openssl/lib -lrt 把195行、197行、199行、201行都改成对应的地址 编译 执行清空命令 make clean 执行编译命令 make 编译完成后,可以在build/output目录下看到编译成功的库。 复制paho库文件。 当前SDK
把如下图的CCDLAGS_SO、LDFLAGS_CS、LDFLAGS_AS、FLAGS_EXES的openssl地址都改成对应的地址 编译 执行清空命令 make clean 执行编译命令 make 编译完成后,可以在build/output目录下看到编译成功的库。 复制paho库文件。 当前SDK
1中的代码生成的JAR包上传至函数中。 图13 创建函数-上传JAR包 单击“设置>常规设置”,修改函数执行入口,设置为代码的执行入口函数路径。 图14 创建函数-修改函数执行入口 在同一页面,单击左侧菜单“环境变量”,设置环境变量信息如下。 表1 环境变量说明 环境变量 说明
SQL语句 创建数据转发规则时,需要编写SQL来解析和处理设备上报的JSON数据,JSON数据具体格式参考流转数据。本文主要介绍如何编写数据转发规则的SQL表达式。 SQL语句 SQL语句由SELECT子句和WHERE子句组成,每个子句不能大于500个字符,暂不支持中文等其他字符
物联网平台接收设备上报日志内容的事件 物联网平台下发配置的通知的事件 物联网平台接收设备上报配置响应的事件 物联网平台接收设备下载升级包的事件 批量任务 批量任务的子任务执行结果,详细请参考表2 批量任务运行日志格式 设备自注册 设备自动注册的结果,详细请参考设备自注册 设备鉴权 设备自定义鉴权结果,详细请参考自定义鉴权,自定义模板鉴权
添加messageId,表示消息种类。命令执行结果为上行消息,需要通过messageId和数据上报消息进行区分。 图15 插件开发-添加响应字段messageId 添加mid字段,用于将下发的命令和命令执行结果进行关联。 图16 插件开发-添加响应字段mid 添加errcode字段,用于表示命令执行状态:00表
拥有该权限的用户拥有除IAM外,其他所有服务的所有执行权限。 系统角色 Tenant Guest 拥有该权限的用户拥有除IAM外,其他所有服务的只读权限。 系统角色 IoTDA FullAccess 拥有该权限的用户拥有访问IoTDA资源的所有执行权限。 系统策略 IoTDA ReadOnlyAccess
如工程依赖第三方Jar包,则需将工程Jar包和所有第三方Jar包打包成一个zip包,如下图所示。 进入函数工作流服务控制台,创建函数。函数执行入口以[包名].[类名].[执行函数名]格式填写。 配置测试事件,调试函数。 创建并配置测试事件,调试函数,如下图所示。 控制台开发 登录设备发放控制台。
DELIVERED表示命令已送达设备 SUCCESSFUL表示命令已经成功执行 FAILED表示命令执行失败 TIMEOUT表示命令下发之后,没有收到设备确认或者响应结果而超时。 result 否 Object 参数说明:设备命令执行的详细结果,由设备返回,Json格式。 响应参数 无 请求示例
environment variables CLOUD_SDK_AK and CLOUD_SDK_SK in the local environment ak = os.environ["CLOUD_SDK_AK"] sk = os.environ["CLOUD_SDK_SK"]
应用平台调用同步命令接口下发命令A。 IoTDA收到同步命令A的请求后,会将命令转换为MQTT消息下发给设备,下发请求后平台会阻塞等待,等待设备返回命令A的执行结果。 设备收到命令A的请求,执行完对应操作后,返回命令A的响应。 IoTDA收到命令A的响应后返回命令结果给应用侧。 应用平台收到命令A的响应后再下发命令B。
取值范围: 结果码定义如下: 0:处理成功。 其他整数:设备自定义异常。 description 可选 String 参数解释: 设备配置执行结果信息,可以返回具体配置失败原因。 示例 Topic: $oc/devices/{device_id}/sys/events/up 数据格式:
# 当平台响应连接请求时,执行self._on_connect() self.__paho_client.on_connect = self._on_connect # 当与平台断开连接时,执行self._on_disconnect()