通过消息转发的云产品流转功能,物联网平台可将指定Topic的数据,流转至 其他Topic 和 其他数据目的 中。本文介绍设置数据流转解析器的完整操作步骤,依次是创建解析器、关联数据源和数据目的、配置流转数据的解析脚本。

前提条件

已添加数据源和数据目的,请参见:

创建解析器

  1. 在具备权限的前提下,登录 云鲸AIoT开发者平台

  2. 点击 消息流转 > 解析器,然后点击 创建解析器

  3. 输入解析器名称和描述,点击确定即可完成创建。

  1. 点击查看,可直接进入 解析器详情 页面。您可单击左上角编辑,修改解析器名称和描述。

关联数据源和数据目的

  1. 在解析器详情页面,单击关联数据源

  2. 在弹出的对话框中,单击数据源下拉列表,选择已创建的数据源,单击确定。

  3. 在解析器详情页面,单击关联数据目的页签。

  4. 点击 关联数据目的 按钮,在弹出的对话框中,单击数据目的下拉列表,选择已创建的数据目的,单击确定。

  5. 单击异常数据目的下的关联数据目的,将重试失败的错误消息转发至指定位置。

    重要

    • 最多支持添加一个错误操作。
    • 正常操作和错误操作的转发目的地不能是相同的数据源。例如,不能同时转发到一个HTTP请求内。
    • 错误消息转发失败后,不会再进行重试。
    • 这里的错误消息仅针对因解析脚本报错导致的规则引擎转发失败错误。

消息转发至云产品失败后,会进行重试。若重试失败,将根据错误操作数据转发的设置转发错误消息。

错误消息格式:

{}

错误消息参数说明如下:

参数 说明

配置并启动解析器

  1. 在解析器详情页面,单击解析脚本

  2. 在脚本输入框,输入解析脚本。脚本编辑方法,请参见脚本示例。数据转发函数和脚本的使用示例,请参见数据流转使用示例目录下的具体文档。

  3. 单击调试,可根据数据源类型,设置不同的参数验证脚本是否可执行。

    1)MQTT类型数据源:选择产品和设备后,输入Topic和Payload数据,验证脚本是否可执行。

    • Topic:输入的Topic,其数据格式与脚本解析逻辑相符即可。
    • Payload数据:输入数据的格式需符合规则引擎的数据格式。其中:
      • 自定义Topic数据的格式,是设备上报的原始数据格式。
      • 基础通信Topic和物模型通信Topic数据的格式说明,请参见数据格式

    2)HTTP类型数据源:选择产品和设备后,输入Headers、URL参数、Payload数据,验证脚本是否可执行。

    • Headers:请求头中剩余内容。
    • URL参数:请求链接中附带的参数和值。
    • Payload参数:请求参数正文,输入的数据格式需要符合解析器可解析的数据格式。
    • 运行结果中会显示脚本中声明的变量值和执行的数据流转函数。
    • 调试成功后,会直接将调试数据写入对应数据目的。您可在对应数据目的内查看流转的数据。
  4. 单击发布

  5. 所有设置完成后,返回至消息流转页面解析器页签,单击解析器对应的启动。解析器启动后,数据即可按照解析脚本进行转发。

可选操作

您也在消息流转页面的解析器页签,执行以下操作:

警告:删除、停止解析器,或删除数据转发目的地成功后,如果用户在其他业务中使用了流转的设备数据,会导致服务不可用或影响用户的业务。请谨慎操作。

操作 说明
查看 解析器详情页面,更新解析器的具体设置,查询解析器的运行日志。例如,修改或删除数据源Topic、数据转发的目的地。
删除 删除对应解析器。注意:运行中的解析器不可删除。
停止 停止对应解析器转发数据。
 创建时间:2023-10-17 10:41
最后编辑:陈勇琦  更新时间:2024-10-18 10:58