图9 设置环境变量
图10 查看预测接口信息
3.单击“代码>配置测试事件>创建新的测试事件>空白模板”。内容示例如下：
{
"resource": "device.message",
"event": "report",
"event_time": "20231227T082702Z",
"event_time_ms": "2023-12-27T08:27:02.944Z",
"request_id": "1d041aa3-29b8-43d3-aae3-3905de130537",
"notify_data": {
"header": {
"app_id": "dc12bf47e95c4723a00f4a007073fc7e",
"device_id": "658bdb475d3bc3372c99feb9_12345484121",
"node_id": "12345484121",
"product_id": "658bdb475d3bc3372c99feb9",
"gateway_id": "658bdb475d3bc3372c99feb9_12345484121"
},
"body": {
"topic": "$oc/devices/658bdb475d3bc3372c99feb9_12345484121/sys/messages/up",
"content": {
"age": "34",
"profession": "blue-collar",
"maritalStatus": "single",
"educationalStatus": "tertiary",
"realEstateSituation": "no",
"loanStatus": "tertiary"
}
}
}
}
图11 配置测试事件
4.配置完测试事件后，单击“测试”，执行结果返回success（以实际函数返回结果为准），则表示成功。配置的HTTP服务器则能收到对应的预测结果。
图12 预测结果
创建产品和设备
1.访问设备接入服务，单击“管理控制台”进入设备接入控制台。
2.选择左侧导航栏的“产品”，单击“创建产品”，创建一个基于MQTT协议的产品，填写参数后，单击“确定”。
图13 创建产品-MQTT
3.导入产品模型，请参考导入产品模型。
在该产品下注册设备，请参考注册单个设备。
说明：本文中使用的产品模型和设备仅为示例，您可以使用自己的产品模型和设备进行操作。
数据转发规则配置
1.选择左侧导航栏的“规则>数据转发”，单击“创建规则”。
2.参考下表参数说明，填写规则内容。以下参数取值仅为示例，您可参考用户指南创建自己的规则，填写完成后单击“创建规则”。
图14 新建消息上报流转规则-数据转发至FunctionGraph
表2 参数说明
参数名
参数说明
规则名称
自定义，如iotda-functiongraph。
规则描述
自定义，如数据转发至FunctionGraph服务。
数据来源
选择“设备消息”。
触发事件
自动匹配“设备消息上报”。
资源空间
和上一步创建的产品所在的资源空间保持一致。
数据过滤语句
通过编写SQL来解析和处理上报的JSON数据。
3.单击“设置转发目标”页签，单击“添加”，设置转发目标。
图15 新建转发目标-转发至FunctionGraph
参考下表参数说明，填写转发目标。填写完成后单击“确定”。
表3 参数说明
参数名
参数说明
转发目标
选择“函数工作流（FunctionGraph）”
区域
选择“函数工作流”区域。
目标函数
选择已配置的函数工作流。
4.单击“启动”，激活配置好的数据转发规则。
图16 启动规则-消息上报-转发至FunctionGraph
模拟数据上报及结果验证
1.使用MQTT模拟器连接到平台（模拟器使用请参考：使用MQTT.fx调测）。
2.使用模拟器进行消息上报，详情请参考：设备消息上报。
上报内容如下：
{
"age": "34",
"profession": "blue-collar",
"maritalStatus": "single",
"educationalStatus": "tertiary",
"realEstateSituation": "no",
"loanStatus": "tertiary"
}
3.查看HTTP服务器是否收到预测结果。
图17 查看消息
点击关注，第一时间了解华为云新鲜技术~