Neo4jOperator¶

Use the Neo4jOperator to execute SQL commands in a Neo4j database.

Using the Operator¶

Use the neo4j_conn_id argument to connect to your Neo4j instance where the connection metadata is structured as follows:

Neo4j Airflow Connection Metadata¶
Parameter	Input
Host: string	Neo4j hostname
Schema: string	Database name
Login: string	Neo4j user
Password: string	Neo4j user password
Port: int	Neo4j port

tests/system/neo4j/example_neo4j.py[source]

neo4j_task = Neo4jOperator(
    task_id="run_neo4j_query",
    neo4j_conn_id="neo4j_conn_id",
    sql='MATCH (tom {name: "Tom Hanks", date: "{{ds}}"}) RETURN tom',
    dag=dag,
)