From commits-return-76113-archive-asf-public=cust-asf.ponee.io@airflow.apache.org Mon Nov 18 22:00:10 2019 Return-Path: X-Original-To: archive-asf-public@cust-asf.ponee.io Delivered-To: archive-asf-public@cust-asf.ponee.io Received: from mail.apache.org (hermes.apache.org [207.244.88.153]) by mx-eu-01.ponee.io (Postfix) with SMTP id 6C24A180657 for ; Mon, 18 Nov 2019 23:00:10 +0100 (CET) Received: (qmail 47938 invoked by uid 500); 18 Nov 2019 22:00:09 -0000 Mailing-List: contact commits-help@airflow.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: dev@airflow.apache.org Delivered-To: mailing list commits@airflow.apache.org Received: (qmail 47929 invoked by uid 99); 18 Nov 2019 22:00:09 -0000 Received: from pnap-us-west-generic-nat.apache.org (HELO spamd3-us-west.apache.org) (209.188.14.142) by apache.org (qpsmtpd/0.29) with ESMTP; Mon, 18 Nov 2019 22:00:09 +0000 Received: from localhost (localhost [127.0.0.1]) by spamd3-us-west.apache.org (ASF Mail Server at spamd3-us-west.apache.org) with ESMTP id 1F99C180668 for ; Mon, 18 Nov 2019 22:00:09 +0000 (UTC) X-Virus-Scanned: Debian amavisd-new at spamd3-us-west.apache.org X-Spam-Flag: NO X-Spam-Score: -112.199 X-Spam-Level: X-Spam-Status: No, score=-112.199 tagged_above=-999 required=6.31 tests=[ENV_AND_HDR_SPF_MATCH=-0.5, KAM_ASCII_DIVIDERS=0.8, RCVD_IN_DNSWL_HI=-5, SPF_HELO_NONE=0.001, SPF_PASS=-0.001, URIBL_BLOCKED=0.001, USER_IN_DEF_SPF_WL=-7.5, USER_IN_WHITELIST=-100] autolearn=disabled Received: from mx1-he-de.apache.org ([10.40.0.8]) by localhost (spamd3-us-west.apache.org [10.40.0.10]) (amavisd-new, port 10024) with ESMTP id AnHuOdCsRgXJ for ; Mon, 18 Nov 2019 22:00:05 +0000 (UTC) Received-SPF: Pass (mailfrom) identity=mailfrom; client-ip=207.244.88.153; helo=mail.apache.org; envelope-from=jira@apache.org; receiver= Received: from mail.apache.org (hermes.apache.org [207.244.88.153]) by mx1-he-de.apache.org (ASF Mail Server at mx1-he-de.apache.org) with SMTP id 63C587DC1D for ; Mon, 18 Nov 2019 22:00:04 +0000 (UTC) Received: (qmail 47603 invoked by uid 99); 18 Nov 2019 22:00:03 -0000 Received: from mailrelay1-us-west.apache.org (HELO mailrelay1-us-west.apache.org) (209.188.14.139) by apache.org (qpsmtpd/0.29) with ESMTP; Mon, 18 Nov 2019 22:00:03 +0000 Received: from jira-he-de.apache.org (static.172.67.40.188.clients.your-server.de [188.40.67.172]) by mailrelay1-us-west.apache.org (ASF Mail Server at mailrelay1-us-west.apache.org) with ESMTP id E3F97E2F4F for ; Mon, 18 Nov 2019 22:00:01 +0000 (UTC) Received: from jira-he-de.apache.org (localhost.localdomain [127.0.0.1]) by jira-he-de.apache.org (ASF Mail Server at jira-he-de.apache.org) with ESMTP id 9127D78087B for ; Mon, 18 Nov 2019 22:00:00 +0000 (UTC) Date: Mon, 18 Nov 2019 22:00:00 +0000 (UTC) From: "ASF GitHub Bot (Jira)" To: commits@airflow.incubator.apache.org Message-ID: In-Reply-To: References: Subject: [jira] [Commented] (AIRFLOW-5920) Add support to execute OpenCypher query against Neo4j MIME-Version: 1.0 Content-Type: text/plain; charset=utf-8 Content-Transfer-Encoding: 7bit X-JIRA-FingerPrint: 30527f35849b9dde25b450d4833f0394 [ 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)