操作流程¶

在设备数据集成服务中，可以创建两种类型的流：

云端集成流：在云中创建、运行和管理的流，可用于将数据集成和发送到 EnOS Cloud 或第三方平台。
站端集成流：在云中创建后导出到本地，在本地部署和运行的集成流。由于数据安全或网络限制等原因，本地环境中的数据源无法直接通过云端访问时，可以通过站端集成流将数据转发上云。

创建集成流的操作流程如下图所示。

步骤 1：申请资源¶

资源规格是集成流性能的关键。在开发和发布集成流之前，确保 OU 已通过 EnOS 管理控制台 > 资源管理 请求了相应的数据集成资源。有关请求数据集成资源的更多信息，参见数据集成资源。

步骤 2：创建与设计集成流¶

集成流可从头开始创建，也可通过当前 OU 已有模板快速创建。更多信息，参见创建集成流。

创建集成流后，可使用流设计器设计集成流，其中每个流可以由多个节点组成。节点分为以下几种类型：

Subflow
Input
Logic
Action
EnOS
External
Enterprise
System
Custom

有关节点类型、哪些节点可用于哪种流类型及各节点的更多信息，参见节点概览。

节点都具有入口点和出口点，一个集成流可通过连接一个节点的出口与另一个节点的入口来组合。对于复杂任务或周期性任务，可以使用 Timer 或 Advanced Task Manager 节点实现周期性集成流触发。

下图为一个云端集成流示例。它首先通过 SFTP File 节点连接了一个 SFTP 服务器，定时轮询指定目录，下载包含设备测点的 CSV 文件。接着通过 CSV 节点将 CSV 文件转换为 JSON 文件，并通过 Script 节点对转换后的数据进行校验和过滤。然后通过 Template 节点将设备测点数据转换成标准上传格式。最后通过 Upload Measurement Point 节点上传测点并将其集成到相应的 EnOS 设备测点。

步骤 3：（云端）调试与发布集成流¶

调试云端集成流有两种方法。

发布前：在某些情况下，在发布云端集成流之前可对其进行调试，以确保它能按预期操作。例如，通过 MQTT Sub 等节点或通过连接配置测试服务器的连接性，或使用 Script 节点测试编写的脚本是否有效。
发布后：云端集成流开始运行，可查看运行成功/失败的日志。注意：需要打开 Debug 开关才能显示日志。更多信息，参见查看云端集成流日志。

发布云端集成流时，需要为云端集成流分配已申请的资源。更多信息，参见发布云端集成流。

步骤 4：（云端）监控集成流¶

监控集成流的作用是能够更好地了解集成流的运行状态，确保正常运行，防止下线和故障。你可以通过以下方式来监控集成流的不同方面：

概览：可以在概览页面查看资源使用量和集成流的运行状态，例如已创建的云端集成流总数、总运行次数等，以此了解集成流的整体运行状态。更多信息，参见监控云端集成流。
告警：可以为云端集成流配置告警规则，在发生特殊情况时及时通知操作人员。更多信息，参见配置云端集成流告警。
运行监控：可以监控云端集成流的 CPU 和内存使用情况。更多信息，参见监控云端集成流。

步骤 5：（站端）导出集成流¶

将创建的站端集成流导出为可执行的 JAR 包，将文件保存到本地。更多信息，参见导出为可执行的 JAR 包。

步骤 6：（站端）将集成流部署到本地¶

启动 JAR 包中的脚本，可以选择启动、在云端/本地运行、停止集成流。更多信息，参见部署与停止站端集成流。