Neo4jOperator

Neo4j

Executes sql code in a specific Neo4j database

View Source

Last Updated: May. 7, 2021

Access Instructions

Install the Neo4j provider package into your Airflow environment.

Import the module into your DAG file and instantiate it with your desired params.

Parameters

sqlstr or list[str]the sql code to be executed. Can receive a str representing a sql statement, a list of str (sql statements)
neo4j_conn_idstrreference to a specific Neo4j database

Documentation

Executes sql code in a specific Neo4j database

See also

For more information on how to use this operator, take a look at the guide: Neo4jOperator

Was this page helpful?