You need to enable JavaScript to run this app.
导航

时序数据流节点

最近更新时间2024.01.12 10:26:31

首次发布时间2023.11.20 15:18:11

本文主要介绍了时序数据流编排中可供选择的输入、处理和输出节点。您可以参考本文,查看不同节点的具体用途及其所包含的控制参数的解释,以协助您进行视频数据流的编排。

说明

  • 时序数据流基于 eKuiper。您可以参考 eKuiper 官方文档了解更多信息。

  • 时序数据流节点的输入和输出口包含以下类型:stream(流数据,包含视频和音频)。

  • “是否必选”是在本文介绍控制参数时使用的标注,表明在部署数据流过程中,是否必须为这些控制参数设定具体的值。在部署数据流过程中,有以下情形需要进行数据流编排:

    • 编辑数据流模板的版本:该方式下,您可以增删节点、连接节点,以及设置节点的控制参数。
    • 编辑数据流实例:该方式下,您只可以设置节点的部分控制参数。(如果您在版本中已经设置了控制参数的值,取决于具体的设置,您可以在实例中再次编辑该参数值,也可以禁止进一步的修改。)

    更多信息,请参见数据流编排指南

节点列表

输入节点

输出节点

处理节点

输入节点

视频流输入源

节点说明

  • 描述:以视频数据流的元数据作为输入。
  • 输入:无
  • 输出:stream_out

使用前提
同一台一体机上已经部署了视频数据流,并且视频数据流同时满足以下条件:

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

控制参数

名称类型是否必选说明示例值
instance-idString选择一个视频数据流实例 ID。

output

String

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

table1

设备输入源

节点说明

  • 描述:以设备实例的属性数据作为输入。
  • 输入:无
  • 输出:stream_out

使用前提

  • 设备已经接入到一体机。

控制参数

名称类型是否必选说明示例值
deviceString选择一个设备实例 ID。

properties

String

表示设备的属性字段。
您选择设备实例后,该参数会展示设备物模型中定义的属性字段。格式为:<属性名称><数据类型>。单击 复制全部,可以将所有的属性名称复制到剪贴板,属性名称间以半角逗号(,)分隔。

以右图为例,设备 device01 包含两个属性:float_testall,它们分别是 Float 类型和 Text 类型。单击 复制全部,可以得到如下字符串:float_test,all

alt

output

String

设置输出表的名称。
在该节点后的 SQL执行过程 节点中,您可以使用 SQL 语句(select <属性名称> from output )从设备输出表中提取设备的属性数据。

table1

输出节点

Kafka输出

节点说明

  • 描述:将处理结果数据推送到 Kafka 服务器。
  • 输入:stream_in
  • 输出:无

控制参数

名称类型是否必选说明示例值
kafka-brokersString设置 Kafka 服务器的访问地址(包含端口号)。foo.bar.com:80
topicString设置消息的主题。doctest

sasl-auth

String

选择 Kafka 服务器启用的 SASL 认证的类型。取值:

  • none
  • plain
  • scram-256
  • scram-512

none

sasl-usernameStringSASL 认证使用的用户名。sasl
sasl-passwordStringSASL 认证使用的密码。sasl123456
enable-tlsBooleanKafka 服务器是否启用了 TLS 认证。false
insecure-skip-verifyBoolean在启用 TLS 认证的基础上,是否跳过安全认证。false

虚拟时序设备输出

节点说明

  • 描述:输出到虚拟的时序设备。
  • 输入:stream_in
  • 输出:无

使用前提

  • 一体机上已经接入虚拟时序设备。相关操作,请参见监控设备的运行状态
  • 虚拟时序设备的属性名称包含输出数据中的所有参数名。

控制参数

名称类型是否必选说明示例值
deviceString从一体机已经接入的设备实例中选择一个虚拟时序设备。virtual-device

properties

String

表示设备的属性字段。
您选择设备实例后,该参数会展示设备物模型中定义的属性字段。格式为:<属性名称><数据类型>。单击 复制全部,可以将所有的属性名称复制到剪贴板,属性名称间以半角逗号(,)分隔。

以右图为例,设备 device01 包含两个属性:float_testall,它们分别是 Float 类型和 Text 类型。单击 复制全部,可以得到如下字符串:float_test,all

alt

处理节点

SQL执行过程

节点说明

  • 描述:对输入的时序数据执行 SQL 语句。
  • 输入:stream_in
  • 输出:stream_out

控制参数

名称类型是否必选说明示例值
sqlString要执行的 SQL 语句。select account_id from table1

output

String

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

table2