You need to enable JavaScript to run this app.
导航
边缘智能
  • 文档首页
    • /
  • 边缘智能

时序数据流节点

最近更新时间：2024.04.10 10:24:29

首次发布时间：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 服务器。

控制参数

名称

类型

是否必选

说明

示例值

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 语句。

控制参数

名称

类型

是否必选

说明

示例值

sql

String

否

要执行的 SQL 语句。

select account_id from table1

output

String

否

设置输出表的名称。
在该节点后的 SQL执行过程 节点中，您可以使用 SQL 语句对输出表进行操作。SQL 语句中可以使用您在此处设置的输出表的名称。

table2