您可基于StreamSQL编写业务逻辑,在SQL中定义多种数据处理函数和操作符,保存为任务,对数据进行处理。
操作步骤
- 登录数据分析控制台,在顶部导航栏上选择任务开发。
- 在流数据任务开发页面,单击新建流数据任务。
任务类型选择SQL,输入任务名称和描述,选择在云端或边缘端执行任务。
表 1. 参数说明 参数 描述 开发类型 此处选择SQL。 任务名称 设置SQL任务名称。支持中文、英文大小写、数字、下划线(_)、中划线(-)、英文括号、空格,长度不超过40个字符。 任务描述 填写任务描述,不可为空。支持中文、英文大小写、数字、下划线(_)、中划线(-)、英文括号、空格,长度不超过40个字符。 运行环境 选择在云端或边缘端执行任务 - 单击确定。创建SQL类型的实时数据分析任务后,自动跳转到流数据任务开发SQL工作台。说明 本文图片所示为默认主题(亮色)。物联网数据分析支持设置工作台主题样式功能,您可单击工作台右上角的设置按钮,修改主题为暗色主题。
- 在SQL编辑器页面右侧的View管理中单击添加View,对产品进行建表,方便在SQL中引用,如下图
pm_test.PM25
(表名.属性
)所示。设置view名称并选择产品和设备后单击确定。
添加完成view后,在SQL中引用。
- 在SQL编写页面,输入SQL之后,单击SQL校验图标,会对SQL的正确性进行初步校验。
- 如果校验通过,则可以进行下一步。
- 如果检验失败,则会提示失败。
请根据提示信息更改SQL内容,若对提示信息有疑问或不知道如何修改,则可以从流数据任务分析页面,选择一个节点编程任务,单击该任务卡片,进入节点编程页,单击右上方的SQL预览图标,参考SQL语句。
根据参考内容重新编写SQL后,再次进行校验,直至校验通过后,进行下一步操作。
- 任务设置完毕后,单击页面右上角的发布,进行任务发布。
发布之后,后台会开启实时数据任务进行实时计算,将计算结果不断的输出到设置的数据源的数据表中。
说明 若任务在边缘端执行,您还需参考边缘端流数据分析,完成边缘任务部署。