普元数据集成平台 普元数据集成平台
产品介绍
安装部署
快速入门
操作指南
FAQ
  • RabbitMQ Source组件使用说明
  • 组件说明
  • 配置项说明
  • FAQ

# RabbitMQ Source组件使用说明

  • 组件说明
  • 配置项说明
  • 使用示例 -实时读取RabbitMQ写入Argo库中
  • FAQ

# 组件说明

RabbitMQ Source连接器。用于从 RabbitMQ 读取数据。

# 配置项说明

配置名称 数据类型 是否必填 默认值 描述
节点名 称 String 是 - 当前创建的节点名称,由用户自定义且不可为空。命名可包含字母、数字、下划线。
节点编码 String 是 - 当前创建的节点编码,以此标识此组件,由用户自定义且不可为空。命名可包含字母、数字、下划线。
选择数据源 String 是 - 从下拉选项中选择列出的当前项目已经关联的数据源。
队列名称 String 是 - RabbitMQ队列名称。
数据结构 List 是 - 字段的数据结构(包括字段名称和字段类型)。 详见FAQ-Q1
自动恢复 String 否 否 当RabbitMQ客户端由于网络问题、代理故障或其他问题而失去与代理的连接时,客户端将重新连接。
拓扑恢复 String 否 否 一旦连接重新建立,RabbitMQ将自动恢复消息拓扑。
网络恢复间隔 Int 否 5000 动态发现主题和分区的时间间隔。单位为毫秒。
可选参数 否 - 其他参数,用户可以根据需求进行配置。

# FAQ

Q1:数据结构都包含什么,都支持什么类型?

  • 包括字段名称和字段类型:
  • 字段类型:
    • string
    • boolean
    • tinyint
    • smallint
    • int
    • bigint
    • float
    • double
    • decimal
    • bytes
    • date
    • timestamp
    • map (map<string, int>,map<string, string>,map<string, boolean>,map<string, tinyint>,map<string, smallint>,map<string, bigint>,map<string, float>,map<string, double>,map<string, decimal>,map<string, date>,map<string, time>,map<string, timestamp>,map<string, null>,map<string, array>,map<string, map> )
    • array

← Neo4j StarRocks →