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]

本條目有幫助嗎？