airflow.providers.neo4j.hooks.neo4j

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

模块内容

类

Neo4jHook

与 Neo4j 交互。
class airflow.providers.neo4j.hooks.neo4j.Neo4jHook(conn_id=default_conn_name, *args, **kwargs)[源代码]

基类: airflow.hooks.base.BaseHook

与 Neo4j 交互。

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

参数

neo4j_conn_id – 引用 Neo4j 连接 ID。

conn_name_attr = 'neo4j_conn_id'[源代码]
default_conn_name = 'neo4j_default'[源代码]
conn_type = 'neo4j'[源代码]
hook_name = 'Neo4j'[源代码]
get_conn()[源代码]

使用用户名、密码和数据库模式启动新的 Neo4j 连接。

get_client(conn, encrypted, uri)[源代码]

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

参数

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

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

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

返回

驱动程序

返回类型

neo4j.Driver

get_uri(conn)[源代码]

根据 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)[源代码]

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

参数

query – Neo4j 查询

返回

结果

返回类型

list[Any]

此条目是否有帮助？