You need to enable JavaScript to run this app.
文档中心
边缘智能

边缘智能

请输入
  • 文档首页
    • 边缘智能边缘智能平台用户指南数据处理数据流编排时序数据流算子
复制全文
下载 pdf
我的收藏
数据流编排
时序数据流算子
复制全文
下载 pdf
我的收藏
时序数据流算子

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

使用前须知

  • 时序数据流基于 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

最近更新时间：2025.07.10 15:39:41
这个页面对您有帮助吗？
有用
有用
无用
无用