Neo4jOperator¶

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

使用運算子¶

使用 neo4j_conn_id 引數連線到你的 Neo4j 例項，連線元資料結構如下

Neo4j Airflow 連線元資料¶
引數	輸入
主機: 字串	Neo4j 主機名
模式: 字串	資料庫名稱
登入: 字串	Neo4j 使用者
密碼: 字串	Neo4j 使用者密碼
埠: 整數	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,
)