Neo4jOperator¶

使用 Neo4jOperator 在 Neo4j 資料庫中執行 SQL 指令。

使用操作器¶

使用 neo4j_conn_id 參數連線至您的 Neo4j 實例，其連線metadata結構如下

Neo4j Airflow 連線 Metadata¶
參數	輸入
主機: 字串	Neo4j 主機名稱
Schema: 字串	資料庫名稱
登入: 字串	Neo4j 使用者
密碼: 字串	Neo4j 使用者密碼
Port: 整數	Neo4j 連接埠

tests/system/neo4j/example_neo4j.py[原始碼]

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,
)