airflow.providers.arangodb.hooks.arangodb

This module allows connecting to a ArangoDB.

Classes

ArangoDBHook

Interact with ArangoDB.

Module Contents

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

Bases: airflow.hooks.base.BaseHook

Interact with ArangoDB.

Performs a connection to ArangoDB and retrieves client.

Parameters:

arangodb_conn_id (str) – Reference to ArangoDB connection 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]

Initiates a new ArangoDB connection (cached).

property db_conn: arango.database.StandardDatabase[source]

Connect to an ArangoDB database and return the database API wrapper.

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

Initiate a new ArangoDB connection (cached).

query(query, **kwargs)[source]

Create an ArangoDB session and execute the AQL query in the session.

Parameters:

query – AQL query

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]

Was this entry helpful?