您可以基于StreamSQL编写业务逻辑,在SQL中定义多种数据处理函数和操作符,保存为任务,对数据进行处理。

操作步骤

  1. 任务管理页面,单击右上角的创建任务

    任务类型选择SQL,输入任务名称和描述,选择在云端或边缘端执行任务。

    单击确定,新建一个SQL类型的实时数据分析任务。


    创建SQL任务
  2. 在任务名称右侧操作栏中单击查看

    查看SQL任务
  3. 在SQL编辑器页面右侧的view页签中单击添加,对产品进行建表,方便在SQL中引用,如下图pm_test.wet表名.属性)所示。

    设置view名称并选择产品和设备后单击确定


    添加view

    添加完成view后,在SQL中引用。


    SQL中引用view
  4. 在SQL编写页面,输入SQL之后,单击SQL校验,会对SQL的正确性进行初步校验。
    • 如果校验通过,则可以进行下一步。
    • 如果检验失败,则会提示失败。

      请根据提示信息更改SQL内容,若对提示信息有疑问或不知道如何修改,则可以从实时数据分析页面,选择一个组件编排任务,单击该任务后的查看,进入组件编排,单击SQL预览,参考SQL语句。

      根据参考内容重新编写SQL后,再次进行校验,直至校验通过后,进行下一步操作。


      SQL预览
  5. 任务设置完毕后,单击发布即可进行任务发布。

    发布之后,后台会开启实时数据任务进行实时计算,将计算结果不断的输出到设置的数据源的数据表中。

    说明 若任务在边缘端执行,您还需参考边缘端流数据分析,完成边缘任务部署。