airflow-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "ASF GitHub Bot (Jira)" <j...@apache.org>
Subject [jira] [Commented] (AIRFLOW-5920) Add support to execute OpenCypher query against Neo4j
Date Mon, 18 Nov 2019 22:00:00 GMT

    [ https://issues.apache.org/jira/browse/AIRFLOW-5920?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16976927#comment-16976927
] 

ASF GitHub Bot commented on AIRFLOW-5920:
-----------------------------------------

tfindlay-au commented on 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


> Add support to execute OpenCypher query against Neo4j
> -----------------------------------------------------
>
>                 Key: AIRFLOW-5920
>                 URL: https://issues.apache.org/jira/browse/AIRFLOW-5920
>             Project: Apache Airflow
>          Issue Type: New Feature
>          Components: hooks, operators
>    Affects Versions: 1.10.7
>            Reporter: Timothy Findlay
>            Assignee: Timothy Findlay
>            Priority: Minor
>   Original Estimate: 48h
>  Remaining Estimate: 48h
>
> As a DAG developer
> I want to create DAG tasks to execute OpenCypher queries against a graph database
> So that the output can be used elsewhere in a DAG / business



--
This message was sent by Atlassian Jira
(v8.3.4#803005)

Mime
View raw message