云端集成流¶

云端集成流，是完全在云端管理的集成流，包括流的创建、设计、发布和删除。

创建集成流后，可以对云端集成流进行以下操作：

云端集成流有以下功能特点。

自定义运行资源

资源的规格将决定云端集成流运行时可用的计算和存储规模。通过自定义运行资源，可以提高流的运行效率和减少资源利用。你可以从以下两个方面分配运行资源，来影响流的运行。

流运行资源：集成流越复杂，需要消耗越多计算资源的情况下，推荐为流分配较大的单实例运行资源。流中连接数较多的情况下，推荐为流分配多个运行实例数，提高系统并发量。更多信息，参见分配运行资源。
代理运行资源：需要连接 MQTT 代理服务器的流，可以通过分配合理的代理运行资源和流运行资源，优化流的运行。更多信息，参见代理配置-分配资源。

在 设备数据集成 > 概览 页面，你可以查看当前 OU 所有云端集成流的资源使用量。有关资源的更多信息，参见 EnOS 上的资源。

实时监控运行状态

你可以对每一条云端集成流的实时运行情况和当前 OU 所有云端集成流的整体运行情况进行监控。

追溯流日志和节点日志

为云端集成流打开 Debug 开关后，正常运行的云端集成流将产生流日志和节点日志，每次触发产生的日志对应一个 Trace ID。

流日志：用于展示每次触发时流的 运行状态（成功/错误） 和 运行时长。你可以在流运行错误时查看错误日志，也可以通过查看流的 运行时长 来监测流的运行速度，以此作为资源分配的依据。
节点日志：用于展示节点在触发时的 运行状态（成功/错误）、运行时长、输入和输出日志。你可以通过流日志中的 Trace ID 查询对应的节点日志。

通过添加和连接不同功能的节点，你可以在云端集成流中实现网关连接、数据处理、数据路由等多种操作。例如：

连接不同协议的网关：可以使用 HTTP Server、MQTT Sub 或 Kafka Sub 等节点连接不同协议的网关并接收消息。
调用 API：通过 Open API 节点调用 EnOS Cloud 的 open API，访问 EnOS Cloud 的信息。或通过 HTTP Client 节点向第三方 HTTP 服务器发起请求，获取数据。
离线数据集成：使用 SFTP File 或 S3 File 节点定时轮询 SFTP 或 S3 服务器目录，下载 CSV 文件。
数据处理：通过 CSV 节点将 CSV 文件解析成 JSON 格式。或通过 Script 节点编写脚本，将不同来源的数据格式转换为 EnOS 标准格式。
数据映射：使用 Lookup Asset、Lookup Model 或 Lookup Product 等节点查找产品、模型或设备，并通过 Lookup Mapping 节点建立其映射关系。后续即可通过 Upload Measurement Point 或 Upload Asset File 节点上传测点，实现设备测点、属性等数据的映射和集成。
转发指令：使用 Command 节点接收应用下发的控制指令，通过 MQTT Pub 节点向设备发送指令。设备执行指令后，MQTT Server 节点可接收指令执行状态，通过 Respond Command 节点上报执行状态并更新指令。