Neo4j

Neo4j 源连接器器

描述

从 Neo4j 读取数据

neo4j-java-driver 版本 4.4.9

主要功能

• 批处理
• 流处理
• 精确一次
• 列投影
• 并行度
• 支持用户定义拆分

配置选项

名称	类型	是否必须	默认值
uri	String	是	-
username	String	否	-
password	String	否	-
bearer_token	String	否	-
kerberos_ticket	String	否	-
database	String	是	-
query	String	是	-
schema	Object	是	-
max_transaction_retry_time	Long	否	30
max_connection_timeout	Long	否	30

uri [string]

Neo4j数据库的URI，参考配置： neo4j://localhost:7687。

username [string]

Neo4j用户名。

password [string]

Neo4j密码。如果提供了“用户名”，则需要。

bearer_token [string]

Neo4j的base64编码bearer token用于鉴权。

kerberos_ticket [string]

Neo4j的base64编码kerberos ticket用于鉴权。

database [string]

数据库名。

query [string]

查询语句。

schema.fields [string]

返回query 的字段。

查看 列投影

max_transaction_retry_time [long]

最大事务重试时间（秒）。如果超过，则事务失败。

max_connection_timeout [long]

等待TCP连接建立的最长时间（秒）。

示例

source {
    Neo4j {
        uri = "neo4j://localhost:7687"
        username = "neo4j"
        password = "1234"
        database = "neo4j"
        max_transaction_retry_time = 1
        max_connection_timeout = 1
        query = "MATCH (a:Person) RETURN a.name, a.age"
        schema {
            fields {
                a.age=INT
                a.name=STRING
            }
        }
    }
}