本文介绍了时序数据流官方模板。时序数据流模板表示从设备实例或视频数据流实例获取时序数据并执行一系列 SQL 语句，然后将处理结果推送到虚拟时序设备或 Kafka 服务器。

基本信息

您可以在边缘智能控制台的官方模板列表访问本模板。下图展示了本模板的基本信息。

版本列表

本模板提供如下可用版本。

使用说明

v1-设备输入-虚拟设备输出

版本说明
v1 版本的数据流如下图所示。

使用前提
在即将部署数据流实例的边缘节点上，您需要完成以下准备工作：

• 接入一个物联网设备。
  该版本使用物联网设备的属性数据作为输入。您需要提前获取设备的属性名称及属性类型。
• 接入一个虚拟时序设备。
  该版本将时序数据处理后的结果推送到虚拟时序设备。虚拟时序设备的属性必须名包含输出数据中的所有参数名。

使用 v1 版本

1. 基于数据流版本创建一个数据流实例。

   • 模板：选择 官方模板/视频数据流/时序数据流官方模板。
   • 版本：选择 v1-设备输入-虚拟设备输出。
   • 节点：选择一个节点以部署该数据流实例。您选择的节点需要满足使用前提中的要求。

2. 在数据流实例中进行数据流编排，为各个算子设置控制参数。

   算子	控制参数	类型	是否必须	说明
   设备输入源	device	String	是	物联网设备实例的 ID。
   	properties	String	否	显示了已选择设备的所有属性。
   	output	String	是	输出表的名称。 在该算子后的 SQL执行过程 算子中，您可以使用 SQL 语句（select <属性名> from output）从设备输出表中提取设备的属性数据。
   SQL执行过程	sql	String	是	要执行的 SQL 语句。
   	output	String	是	输出表的名称。 在该算子后的 SQL执行过程 算子中，您可以使用 SQL 语句对输出表进行操作。SQL 语句中可以使用您在此处设置的输出表的名称。
   虚拟时序设备输出	device	String	是	从边缘节点已经接入的设备实例中选择一个虚拟时序设备。
   	properties	String	否	显示了已选择设备的所有属性。

v2-视频流分析结果元数据输入-kafka输出

版本说明
v2 版本的数据流如下图所示。

使用前提

• 您已经获取了 Kafka 服务器的访问地址。
• 在即将部署数据流实例的边缘节点上，您需要完成以下准备工作：
  • 部署一个视频数据流实例，并且视频数据流同时满足以下条件：
    • 使用 Ekuiper推送 作为输出算子。
      Ekuiper推送 算子将视频数据流的元数据发送到 Ekuiper 服务器，时序数据流从 Ekuiper 服务器读取元数据后继续分析。
    • 状态是 运行中。

使用 v2 版本

1. 基于数据流版本创建一个数据流实例。

   • 模板：选择 官方模板/视频数据流/时序数据流官方模板。
   • 版本：选择 v2-视频流分析结果元数据输入-kafka输出。
   • 节点：选择一个节点以部署该数据流实例。您选择的节点需要满足使用前提中的要求。

2. 在数据流实例中进行数据流编排，为各个算子设置控制参数。

   算子	控制参数	类型	是否必须	说明
   视频流输入源	instance-id	String	是	视频数据流实例的 ID。
   	output	String	是	输出表的名称。 在该算子后的 SQL执行过程 算子中，您可以使用 SQL 语句（select <属性名> from output）从设备输出表中提取设备的属性数据。
   SQL执行过程	sql	String	是	要执行的 SQL 语句。
   	output	String	是	输出表的名称。 在该算子后的 SQL执行过程 算子中，您可以使用 SQL 语句对输出表进行操作。SQL 语句中可以使用您在此处设置的输出表的名称。
   Kafka输出	kafka-brokers	String	是	设置 Kafka 服务器的访问地址（包含端口号）。
   	topic	String	是	设置消息的主题。
   	sasl-auth	String	否	选择 Kafka 服务器启用的 SASL 认证的类型。取值： none plain scram-256 scram-512
   	sasl-username	String	否	SASL 认证使用的用户名。
   	sasl-password	String	否	SASL 认证使用的密码。
   	enable-tls	Boolean	否	Kafka 服务器是否启用了 TLS 认证。
   	insecure-skip-verify	Boolean	否	在启用 TLS 认证的基础上，是否跳过安全认证。

v3-多处理分支-多输出

版本说明
v3 版本的数据流如下图所示。

使用前提

• 您已经获取了 Kafka 服务器的访问地址。
• 在即将部署数据流实例的边缘节点上，您需要完成以下准备工作：
  • 接入一个物联网设备。
    该版本使用物联网设备的属性数据作为输入。您需要提前获取设备的属性名称及属性类型。
  • 接入一个虚拟时序设备。
    该版本将时序数据处理后的结果推送到虚拟时序设备。虚拟时序设备的属性必须名包含输出数据中的所有参数名。

使用 v3 版本

1. 基于数据流版本创建一个数据流实例。

   • 模板：选择 官方模板/视频数据流/时序数据流官方模板。
   • 版本：选择 v3-多处理分支-多输出。
   • 节点：选择一个节点以部署该数据流实例。您选择的节点需要满足使用前提中的要求。

2. 在数据流实例中进行数据流编排，为各个算子设置控制参数。

   算子	控制参数	类型	是否必须	说明
   设备输入源	device	String	是	物联网设备实例的 ID。
   	properties	String	否	显示了已选择设备的所有属性。
   	output	String	是	输出表的名称。 在该算子后的 SQL执行过程 算子中，您可以使用 SQL 语句对输出表进行操作。SQL 语句中可以使用您在此处设置的输出表的名称。
   SQL执行过程	sql	String	是	要执行的 SQL 语句。
   	output	String	是	输出表的名称。 在该算子后的 SQL执行过程 算子中，您可以使用 SQL 语句对输出表进行操作。SQL 语句中可以使用您在此处设置的输出表的名称。
   虚拟时序设备输出	device	String	是	从边缘节点已经接入的设备实例中选择一个虚拟时序设备。
   	properties	String	否	显示了已选择设备的所有属性。
   Kafka输出	kafka-brokers	String	是	设置 Kafka 服务器的访问地址（包含端口号）。
   	topic	String	是	设置消息的主题。
   	sasl-auth	String	否	选择 Kafka 服务器启用的 SASL 认证的类型。取值： none plain scram-256 scram-512
   	sasl-username	String	否	SASL 认证使用的用户名。
   	sasl-password	String	否	SASL 认证使用的密码。
   	enable-tls	Boolean	否	Kafka 服务器是否启用了 TLS 认证。
   	insecure-skip-verify	Boolean	否	在启用 TLS 认证的基础上，是否跳过安全认证。

最佳实践

如果直接使用官方模板创建数据流实例，您将无法修改数据流的结构。而在实际使用过程中，官方模板版本中的数据流结构可能并不适合您的业务需求。这种情况下，您可以按如下方式来使用官方模板：

1. 复制官方模板生成一个新的自定义模板。（新的自定义模板包含官方模板下的所有版本。）
2. 在自定义模板中，找到适合您场景的版本，然后通过数据流编排，修改版本的数据流（如增删算子等）。
3. 使用自定义模板创建数据流实例。