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