[GitHub] [airflow] tfindlay-au opened a new pull request #6604: [AIRFLOW-5920] *DRAFT* Neo4j operator and hook

[GitBox <gi...@apache.org>]

tfindlay-au opened a new pull request #6604: [AIRFLOW-5920] *DRAFT* Neo4j operator and hook
URL: https://github.com/apache/airflow/pull/6604
 
 
   Make sure you have checked _all_ steps below.
   
   ### Jira
   [AIRFLOW-5920]
   
   ### Description
   These changes add the ability for a pipeline to execute a cypher query as part of a DAG pipeline.
   
   The query is executed against an Airflow managed connection (host, port, username, password) using the Neo4j python library:
   https://neo4j.com/docs/api/python-driver/current/
   
   ### Tests
   
   Unit tests will be submitted shortly.
   
   ### Commits
   
   
   
   ### Documentation
   
   Documentation will be comming shortly. Just waiting proof for a proof read.
   
   Usage will look like:
   ```
   t4 = Neo4JOperator(
       task_id="RunQuery",
       n4j_conn_id="ExampleN4J",
       cypher_query="MATCH (n) RETURN id(n)",
       filename="myfile.csv",
       fail_on_no_results=True,
       dag=dag
   )
   ```

----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
 
For queries about this service, please contact Infrastructure at:
users@infra.apache.org


With regards,
Apache Git Services