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

This module allows to connect to a Neo4j database.

Module Contents¶

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

Bases: airflow.hooks.base.BaseHook

Interact with Neo4j.

Performs a connection to Neo4j and runs the query.

conn_name_attr = neo4j_conn_id[source]¶

default_conn_name = neo4j_default[source]¶

conn_type = neo4j[source]¶

hook_name = Neo4j[source]¶

get_conn(self)[source]¶: Function that initiates a new Neo4j connection with username, password and database schema.

get_uri(self, conn: Connection)[source]¶: Build the uri based on extras - Default - uses bolt scheme(bolt://) - neo4j_scheme - neo4j:// - certs_self_signed - neo4j+ssc:// - certs_trusted_ca - neo4j+s:// :param conn: connection object. :return: uri

run(self, query)[source]¶

Function to create a neo4j session and execute the query in the session.

Parameters: query -- Neo4j query
Returns: Result

Was this entry helpful?