您可以使用规则引擎,将处理后的数据转发至函数计算(Function Compute)中。



操作流程概述:
  1. 函数计算控制台创建好服务、函数。
  2. 创建规则,将IoT数据处理并转发到函数计算中,启动规则。
  3. 使用配置了规则的Topic发送一条消息。
  4. 查看函数计算服务实时监控大盘查询函数执行情况,或者根据函数的具体业务逻辑查看结果是否正确。

操作步骤

  1. 登录函数计算控制台,创建服务与函数。
    1. 创建服务。其中,服务名称必须填写,其余参数请根据您的需求设置。

    2. 创建服务成功后,创建函数。

    3. 选择函数模板,此处以空白函数模板为示例。

    4. 设置函数参数。

      此处设置函数的逻辑为直接在函数计算中显示获取的数据。

      其中,

      所在服务:选择1.a中创建的服务。

      函数名称:设置您的函数名称。

      运行环境:设置函数运行的环境,此示例中选择java8。

      代码配置:上传您的代码。

      函数入口:设置您的函数在函数计算系统运行的调用入口,此示例中必须设置为com.aliyun.fc.FcDemo::handleRequest

      其余参数的值请根据您的需求,参见函数计算设置。

    5. 函数执行验证。

      函数成功创建后,可以直接在函数计算的控制台执行,以验证函数执行情况。函数计算会直接将函数的输出和请求的相关信息打印在控制台上。

  2. 函数正常执行后,配置IoT规则引擎。
  3. 在设置转发之前,您需要参考设置规则引擎编写SQL完成对数据的处理。
    说明
    JSON格式和二进制格式都支持转发到函数计算中
  4. 单击规则名称,进入规则详情页面。
  5. 单击数据转发一栏的添加操作,并在弹出的添加操作页面中设置参数。

    • 选择操作:发送数据到函数计算(FC)中。
    • 地域:根据您的业务选择将处理后的数据转发至某个地域。如果该地域没有对应资源,需要到函数计算控制台创建相应的资源。
      说明
      目前只支持华东2节点
    • 服务:根据您的地域选择服务。若没有服务,请单击创建服务
    • 函数:根据您的地域选择函数。若没有函数,请单击创建函数
    • 角色:授权物联网平台操作函数的权限。此处需要您先创建一个具有执行函数权限的角色,然后将该角色赋予给规则引擎。
  6. 启动规则。规则运行后,IoT将根据编写的SQL,将处理后的数据转发到函数计算中。函数计算根据您函数定义的逻辑,直接将接收到的数据显示在函数计算控制台上。

结果验证

函数计算控制台针对函数的执行情况有监控统计。统计有大概5分钟的延时,可以通过监控大盘查询函数的执行情况。