airflow.providers.arangodb.operators.arangodb¶
类¶
在 ArangoDB 数据库中执行 AQL 查询。 |
|
在 ArangoDB 数据库中执行集合操作。 |
模块内容¶
- 类 airflow.providers.arangodb.operators.arangodb.AQLOperator(*, query, arangodb_conn_id='arangodb_default', result_processor=None, **kwargs)[source]¶
基类:
airflow.models.BaseOperator在 ArangoDB 数据库中执行 AQL 查询。
另请参阅
有关如何使用此 Operator 的更多信息，请参阅指南：Operator
- 参数:
query (str) – 要执行的 AQL 查询。可以是表示 AQL 语句的字符串，也可以提供包含查询的 .sql 文件
result_processor (Callable | None) – 用于进一步处理 ArangoDB 结果的函数
arangodb_conn_id (str) – ArangoDB 连接 ID 的引用。
- template_fields: collections.abc.Sequence[str] = ('query',)[source]¶
- template_ext: collections.abc.Sequence[str] = ('.sql',)[source]¶
- 类 airflow.providers.arangodb.operators.arangodb.ArangoDBCollectionOperator(*, arangodb_conn_id='arangodb_default', collection_name, documents_to_insert=None, documents_to_update=None, documents_to_replace=None, documents_to_delete=None, delete_collection=False, **kwargs)[source]¶
基类:
airflow.models.BaseOperator在 ArangoDB 数据库中执行集合操作。
- 参数:
arangodb_conn_id (str) – ArangoDB 的连接 ID，默认为“arangodb_default”。
collection_name (str) – 要操作的集合名称。
documents_to_insert (list[dict[str, Any]] | None) – 要插入到集合中的 Python 字典列表。
documents_to_update (list[dict[str, Any]] | None) – 要在集合中更新的 Python 字典列表。
documents_to_replace (list[dict[str, Any]] | None) – 要在集合中替换的 Python 字典列表。
documents_to_delete (list[dict[str, Any]] | None) – 要从集合中删除的 Python 字典列表。
delete_collection (bool) – 如果为 True，将删除指定的集合。