airflow.providers.neo4j.hooks.neo4j

此模块允许连接到 Neo4j 数据库。

类

Neo4jHook

与 Neo4j 交互。

模块内容

class airflow.providers.neo4j.hooks.neo4j.Neo4jHook(conn_id=default_conn_name, *args, **kwargs)[source]

基类: airflow.hooks.base.BaseHook

与 Neo4j 交互。

执行到 Neo4j 的连接并运行查询。

参数:

neo4j_conn_id – Neo4j 连接 ID 的引用。

conn_name_attr = 'neo4j_conn_id'[source]
default_conn_name = 'neo4j_default'[source]
conn_type = 'neo4j'[source]
hook_name = 'Neo4j'[source]
neo4j_conn_id = 'neo4j_default'[source]
connection[source]
client: neo4j.Driver | None = None[source]
get_conn()[source]

使用用户名、密码和数据库模式初始化新的 Neo4j 连接。

get_client(conn, encrypted, uri)[source]

根据 extras 确定相关的驱动程序。

参数:

  • conn (airflow.models.Connection) – 连接对象。

  • encrypted (bool) – 是否为加密连接的布尔值。

  • uri (str) – 连接的 URI 字符串。

返回:

驱动程序

返回类型:

neo4j.Driver

get_uri(conn)[source]

根据 extras 构建 URI。

  • 默认 - 使用 bolt 方案 (bolt://)

  • neo4j_scheme - neo4j://

  • certs_self_signed - neo4j+ssc://

  • certs_trusted_ca - neo4j+s://

参数:

conn (airflow.models.Connection) – 连接对象。

返回:

uri

返回类型:

str

run(query)[source]

创建 neo4j 会话并在会话中执行查询。

参数:

query – Neo4j 查询。

返回:

结果

返回类型:

list[Any]

本条目有帮助吗？