airflow.providers.neo4j.operators.neo4j¶

类¶

Neo4jOperator

在指定的 Neo4j 数据库中执行 sql 代码。

模块内容¶

class airflow.providers.neo4j.operators.neo4j.Neo4jOperator(*, sql, neo4j_conn_id='neo4j_default', parameters=None, **kwargs)[源代码]¶

基类: airflow.models.BaseOperator

在指定的 Neo4j 数据库中执行 sql 代码。

另请参阅

有关如何使用此操作符的更多信息，请参阅以下指南： Neo4jOperator

参数:

sql (str) – 要执行的 sql 代码。可以接收一个表示 sql 语句的字符串
neo4j_conn_id (str) – 引用 Neo4j 连接 ID。

template_fields: collections.abc.Sequence[str] = ('sql',)[源代码]¶

neo4j_conn_id = 'neo4j_default'[源代码]¶

sql[源代码]¶

parameters = None[源代码]¶

execute(context)[源代码]¶

创建操作符时需派生此方法。

上下文与渲染 Jinja 模板时使用的字典相同。

有关更多上下文，请参阅 get_template_context。

此条目有帮助吗？