企业SaaS应用-配置示例:配置RabbitMQ类型的数据连接器

时间:2025-01-26 10:44:18

配置RabbitMQ类型的数据连接器

前提条件

  • 数据图书馆中已经创建用于存放RabbitMQ即时数据的数据资产,目前只支持将数据存放在数据库类型的资产中,本案例的资产字段包括姓名(文本类型),年龄(数值类型)和描述(文本类型),如下图所示。
    图44 数据资产
  • 已经在RabbitMQ管理平台中创建好订阅主题,本样例以"userSync"为例,创建订阅主题步骤如下图所示。
    图45 创建订阅主题

操作步骤

  1. 以账号登录unidaten系统。
  2. 光标放置在系统左上角,在功能导航中单击选择“数据连接器”,进入数据连接器页面。
  3. 选择目标目录,单击“新增数据连接器”,进入“输入配置”页面。
  4. 输入连接器名称,配置“输入配置”中的参数,如下所示。

    图46 输入配置

  5. 配置“数据处理”,此处以“JSON”为例,如下图所示(此处的输出字段与输出配置中的资产中的字段类型保持一致)。

    图47 数据处理

  6. 配置“输出配置”,选择存放数据的图书馆资产,类型选择“新增”,配置输出映射关系,如下图所示。

    图48 输出配置

  7. 单击“保存”,完成数据连接器的配置。
  8. 登录RabbitMQ管理平台,选在“Queues”,单击目标订阅主题,进入主题。

    图49 登录RabbitMQ管理平台

  9. 在“Publish message”输入消息体内容,此处以“JSON”为例,单击“Publish message”发布消息,如下所示。

    图50 输入消息体内容

验证步骤

以账号登录unidaten系统,光标放置在系统左上角,在功能导航中单击选择“数据图书馆”,进入数据图书馆页面,选择资产,查看即时数据是否刷新成功。

图51 数据图书馆
support.huaweicloud.com/nscf-saasapp/nscf_18.html