Inject


Inject 节点可输入自定义 msg 或上传 CSV 文件,手动触发流或定时触发流,用于调试和功能扩展。

节点类型

Input。

输入和输出能力

该节点没有入口点,仅有 1 个出口点。输出格式为 JSON 格式。

节点属性

../../_images/inject.png


名称

该节点的名称。


Msg 数据格式

用于触发流的数据格式,目前支持 JSON文件

  • JSON

    Msg 有效负载

    用于触发流的自定义 msg。所编写代码将输出至 msg 中。


  • 文件

    文件(.csv)

    用于触发流的 CSV 文件,最大文件大小为 16M。选择 上传 图标 upload 上传文件、或者选择 下载 图标 download 下载已上传的文件。文件信息将输出至 metadata 中,可供下个节点通过表达式 ${metadata.files} 使用。


重发

定义集成流的触发频率。可用选项如下所述。

  • : 手动触发流。集成流发布并运行后,可以通过选择 执行 按钮来手动触发流。
  • 间隔: 在指定的时间段(分钟/小时/天)内以指定的间隔(分钟/小时)自动触发流。计时在你发布集成流之后开始。例如,如果设置为每 10 分钟触发一次,为期 1 天,则从发布之日起到 1 天后每 10 分钟触发一次。


描述

该节点的描述。

使用限制

  • 用于触发流的数据格式目前仅支持 JSON 和 CSV 文件。
  • CSV 文件最大文件大小为 16M。
  • CSV 文件最大支持 15 万条数据。

示例

输入示例

该节点不接收任何输入消息。

输出示例

JSON

输出 msg 是 Msg 有效负载 中的自定义 msg。


{
  "MetaData": {},
  "Body": [
    {
      "externalId": "externalId",
      "timestamp": 24214324324,
      "measurepoints": {
        "speed": 32,
        "heat": 40
      }
    }
  ]
}

文件

输出 msg 是文件的信息,包含在 metadata 中。后续可通过 File 节点或 CSV 节点获取文件的具体内容。

{
  "MetaData": {
    "files": "[\"/tmp/CSV File.csv1713481347581904.inject\"]"
  },
  "Body": {}
}

相关节点