`airflow.providers.neo4j.hooks.neo4j`¶

此模組允許連線至 Neo4j 資料庫。

模組內容¶

類別¶

與 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)[原始碼]¶

根據額外資訊判斷相關的驅動程式。

參數

conn (airflow.models.Connection) – 連線物件。
encrypted (bool) – 布林值，表示是否為加密連線。
uri (str) – 連線的 uri 字串。

返回

驅動程式

返回類型

neo4j.Driver

get_uri(conn)[原始碼]¶

根據額外資訊建立 uri。

預設 - 使用 bolt scheme(bolt://)
neo4j_scheme - neo4j://
certs_self_signed - neo4j+ssc://
certs_trusted_ca - neo4j+s://

參數: conn (airflow.models.Connection) – 連線物件。
返回: uri
返回類型: 字串

run(query)[原始碼]¶

建立 neo4j 工作階段並在工作階段中執行查詢。

參數: query – Neo4j 查詢
返回: 結果
返回類型: list[Any]

此條目是否有幫助？