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

操作步骤

  1. 登录数据分析控制台,在顶部导航栏上选择任务开发
  2. 流数据任务开发页面,单击新建流数据任务

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

    创建SQL任务
    表 1. 参数说明
    参数 描述
    开发类型 此处选择SQL
    任务名称 设置SQL任务名称。支持中文、英文大小写、数字、下划线(_)、中划线(-)、英文括号、空格,长度不超过40个字符。
    任务描述 填写任务描述,不可为空。支持中文、英文大小写、数字、下划线(_)、中划线(-)、英文括号、空格,长度不超过40个字符。
    运行环境 选择在云端边缘端执行任务
  3. 单击确定
    创建SQL类型的实时数据分析任务后,自动跳转到流数据任务开发SQL工作台
    说明 本文图片所示为默认主题(亮色)。物联网数据分析支持设置工作台主题样式功能,您可单击工作台右上角的设置按钮设置,修改主题为暗色主题
    SQL任务开发工作台
  4. 在SQL编辑器页面右侧的View管理中单击添加View,对产品进行建表,方便在SQL中引用,如下图pm_test.PM25表名.属性)所示。

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

    添加view

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

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

      请根据提示信息更改SQL内容,若对提示信息有疑问或不知道如何修改,则可以从流数据任务分析页面,选择一个节点编程任务,单击该任务卡片,进入节点编程页,单击右上方的SQL预览图标,参考SQL语句。

      SQL预览

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

  6. 任务设置完毕后,单击页面右上角的发布,进行任务发布。

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

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