时序数据流算子--边缘智能-火山引擎

文档中心

导航

时序数据流算子

最近更新时间：2024.08.07 11:18:27首次发布时间：2023.11.20 15:18:11

本文介绍了时序数据流编排中可供选择的输入、处理和输出算子。编排时序数据流的过程中，您可以参考本文了解不同算子的用途及其所包含控制参数的含义。

使用前须知

时序数据流基于 eKuiper。您可以参考 eKuiper 官方文档了解更多信息。
“是否必选”是在本文介绍控制参数时使用的标注，表明在部署数据流过程中，是否必须为这些控制参数设定具体的值。在部署数据流过程中，有以下情形需要进行数据流编排：
- 编辑数据流模板的版本：该方式下，您可以增删算子、连接算子，以及设置算子的控制参数。
- 编辑数据流实例：该方式下，您只可以设置算子的部分控制参数。（如果您在版本中已经设置了控制参数的值，取决于具体的设置，您可以在实例中再次编辑该参数值，也可以禁止进一步的修改。）
  更多信息，请参见数据流编排指南。

输入算子

输出算子

处理算子

算子描述
以视频数据流的元数据作为输入。

使用说明
要使用该算子，您需要确保同一个边缘节点上已经部署了视频数据流实例，并且视频数据流实例满足以下所有条件：

使用 Ekuiper推送 作为输出算子。
Ekuiper推送 算子将视频数据流的元数据发送到 Ekuiper 服务器，时序数据流从 Ekuiper 服务器读取元数据后继续分析。下图展示了一个包含 Ekuiper推送 算子的视频数据流的示例。
数据流实例的状态是 运行中。

控制参数

名称	类型	是否必选	说明	示例值
instance-id	String	是	选择一个视频数据流实例 ID。	无
output	String	是	设置输出表的名称。在该算子后的 SQL执行过程算子中，您可以使用 SQL 语句对输出表进行操作。SQL 语句中可以使用您在此处设置的输出表的名称。	`table1`

算子描述
以设备实例的属性数据作为输入。

使用说明
要使用该算子，您需要先在边缘节点上接入设备。

控制参数

名称	类型	是否必选	说明	示例值
device	String	是	选择一个设备实例 ID。	无
properties	String	否	表示设备的属性字段。您选择设备实例后，该参数会展示设备物模型中定义的属性字段。格式为：`<属性名称><数据类型>`。单击复制全部，可以将所有的属性名称复制到剪贴板，属性名称间以半角逗号（,）分隔。以右图为例，设备 `device01` 包含两个属性：`float_test` 和 `all`，它们分别是 Float 类型和 Text 类型。单击 `复制全部`，可以得到如下字符串：`float_test,all`。
output	String	是	设置输出表的名称。在该算子后的 SQL执行过程算子中，您可以使用 SQL 语句（`select <属性名称> from output` ）从设备输出表中提取设备的属性数据。	`table1`

算子描述
将处理结果数据推送到 Kafka 服务器。

控制参数

名称	类型	是否必选	说明	示例值
kafka-brokers	String	是	设置 Kafka 服务器的访问地址（包含端口号）。	`foo.bar.com:80`
topic	String	是	设置消息的主题。	`doctest`
sasl-auth	String	否	选择 Kafka 服务器启用的 SASL 认证的类型。取值： none plain scram-256 scram-512	`none`
sasl-username	String	否	SASL 认证使用的用户名。	sasl
sasl-password	String	否	SASL 认证使用的密码。	sasl123456
enable-tls	Boolean	否	Kafka 服务器是否启用了 TLS 认证。	false
insecure-skip-verify	Boolean	否	在启用 TLS 认证的基础上，是否跳过安全认证。	false

算子描述
输出到虚拟的时序设备。

使用说明
要使用该算子，您需要先在边缘节点上接入虚拟时序设备，并确保虚拟时序设备的属性名称包含输出数据中的所有参数名。

控制参数

名称	类型	是否必选	说明	示例值
device	String	否	从边缘节点已经接入的设备实例中选择一个虚拟时序设备。	`virtual-device`
properties	String	否	表示设备的属性字段。您选择设备实例后，该参数会展示设备物模型中定义的属性字段。格式为：`<属性名称><数据类型>`。单击复制全部，可以将所有的属性名称复制到剪贴板，属性名称间以半角逗号（,）分隔。以右图为例，设备 `device01` 包含两个属性：`float_test` 和 `all`，它们分别是 Float 类型和 Text 类型。单击 `复制全部`，可以得到如下字符串：`float_test,all`。

算子描述
对输入的时序数据执行 SQL 语句。

控制参数

名称	类型	是否必选	说明	示例值
sql	String	否	要执行的 SQL 语句。	`select account_id from table1`
output	String	否	设置输出表的名称。在该算子后的 SQL执行过程算子中，您可以使用 SQL 语句对输出表进行操作。SQL 语句中可以使用您在此处设置的输出表的名称。	`table2`