您可以创建SQL类型的流数据分析任务,并在边缘端执行该任务。

边缘端SQL语法与云端Flink SQL语法完全一致,语法说明请参见Flink SQL

在流数据分析中,数据存储用源表、维表、结果表来表示。但由于运行环境不一样,边缘端与云端支持的数据存储大部分是不相同的。

类型 描述
源表

流式数据存储,驱动流数据分析的运行。每个流数据分析任务必须提供至少一个流式数据存储。

边缘端支持的类型如下:

  • EdgeBus:边缘端消息总线(边缘端跨进程通信机制),EdgeBus的数据作为输入源,会根据消息路由(管理控边缘端消息流向)的配置将数据输入到流作业中,目前支持设备数据流向流作业。
结果表

目的数据存储,用于存储流数据分析的计算结果。每个流数据分析任务必须提供至少一个目的数据存储。

边缘端支持的类型如下:

  • EdgeBusSink:边缘端消息总线,会把流作业的处理结果输出到EdgeBus,可通过消息路由的配置决定流作业处理结果的具体流向,目前支持流向函数计算、IoTHub。
  • RDS:关系型数据库(MySQL),会将流数据分析任务的处理结果输出到阿里云关系型数据库中。
  • File:会将流数据分析任务的处理结果输出到边缘网关的文件中,主要用于本地调试。
维表 关系型数据存储,必须显式定义数据变化周期,常用来做数据连接(Join)。

边缘端支持的类型如下:

  • RDS:会把关系型数据库(MySQL)的数据当成维表输入。