普元数据开发平台 普元数据开发平台
产品介绍
安装部署
快速入门
操作指南
应用集成
运维指南
  • Neo4j Source组件使用说明
  • 组件说明
  • 配置项说明
  • 故障排查建议
  • FAQ

# Neo4j Source组件使用说明

  • 组件说明
  • 配置项说明
  • 使用示例
    • 将neo4j数据库数据经过处理后写入Kafka
  • FAQ

# 组件说明

Neo4j Source 连接器用于从 Neo4j 图数据库中读取数据。

Neo4j的版本目前支持4及以上,3版本的可能会导致读取的库不正确。

# 配置项说明

配置名称 数据类型 是否必填 默认值 描述
节点名称 String 是 Neo4j 当前创建的节点名称,由用户自定义且不可为空。命名可包含字母、数字、下划线。确保唯一性。
节点编码 String 是 自动生成 当前创建的节点编码,以此标识此组件,由用户自定义且不可为空。命名可包含字母、数字、下划线。确保唯一性。
选择数据源 String 是 - 从下拉选项中选择列出的当前项目已经关联的数据源。
选择库 String 否 - 从下拉列表中选择数据库。
查询 String 否 - 查询语句。
数据结构 String 否 - 定义返回字段的Schema映射。
最大事务重试时间 Int 否 30 最大事务重试时间(秒)。如果超过,事务将失败。
最大连接超时时间 Int 是 30 等待建立TCP连接的最长时间(秒)。
可选参数 否 - 其他参数,用户可以根据需求进行配置。

# 故障排查建议

连接失败:检查uri格式是否正确,网络是否可达。

认证失败:确认用户名密码正确;若使用token/kerberos,确保Base64编码正确。

Schema错误:确保schema.fields中的字段名与RETURN子句完全一致(含大小写和点号)。

数据类型不匹配:Cypher返回类型需与声明的SeaTunnel类型兼容。

# FAQ

← MinIO RabbitMQ →