airflow.providers.arangodb.hooks.arangodb

该模块允许连接到 ArangoDB。

类

ArangoDBHook

与 ArangoDB 交互。

模块内容

class airflow.providers.arangodb.hooks.arangodb.ArangoDBHook(arangodb_conn_id=default_conn_name, *args, **kwargs)[source]

基类: airflow.hooks.base.BaseHook

与 ArangoDB 交互。

执行与 ArangoDB 的连接并检索客户端。

参数:

arangodb_conn_id (str) – 引用 ArangoDB 连接 ID。

conn_name_attr = 'arangodb_conn_id'[source]
default_conn_name = 'arangodb_default'[source]
conn_type = 'arangodb'[source]
hook_name = 'ArangoDB'[source]
arangodb_conn_id = 'arangodb_default'[source]
property client: arango.ArangoClient[source]

初始化一个新的 ArangoDB 连接 (已缓存)。

property db_conn: arango.database.StandardDatabase[source]

连接到 ArangoDB 数据库并返回数据库 API 包装器。

property hosts: list[str][source]
property database: str[source]
property username: str[source]
property password: str[source]
get_conn()[source]

初始化一个新的 ArangoDB 连接 (已缓存)。

query(query, **kwargs)[source]

创建一个 ArangoDB 会话并在该会话中执行 AQL 查询。

参数:

query – AQL 查询

create_collection(name)[source]
delete_collection(name)[source]
create_database(name)[source]
create_graph(name)[source]
insert_documents(collection_name, documents)[source]
update_documents(collection_name, documents)[source]
replace_documents(collection_name, documents)[source]
delete_documents(collection_name, documents)[source]
classmethod get_ui_field_behaviour()[source]

此条目是否有帮助？