airflow.providers.arangodb.operators.arangodb¶

Classes¶

`AQLOperator`	Executes AQL query in a ArangoDB database.
`ArangoDBCollectionOperator`	Executes collection operations in a ArangoDB database.

Module Contents¶

class airflow.providers.arangodb.operators.arangodb.AQLOperator(*, query, arangodb_conn_id='arangodb_default', result_processor=None, **kwargs)[source]¶

Bases: airflow.models.BaseOperator

Executes AQL query in a ArangoDB database.

See also

For more information on how to use this operator, take a look at the guide: Operators

Parameters:

query (str) – the AQL query to be executed. Can receive a str representing a AQL statement, or you can provide .sql file having the query
result_processor (Callable | None) – function to further process the Result from ArangoDB
arangodb_conn_id (str) – Reference to ArangoDB connection id.

template_fields: collections.abc.Sequence[str] = ('query',)[source]¶

template_ext: collections.abc.Sequence[str] = ('.sql',)[source]¶

template_fields_renderers[source]¶

arangodb_conn_id = 'arangodb_default'[source]¶

query[source]¶

result_processor = None[source]¶

execute(context)[source]¶

Derive when creating an operator.

Context is the same dictionary used as when rendering jinja templates.

Refer to get_template_context for more context.

class 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]¶