Neo4jOperator
Neo4jExecutes sql code in a specific Neo4j database
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
sqlRequiredthe sql code to be executed. Can receive a str representing a sql statement
neo4j_conn_idReference to Neo4j connection id.
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