airflow.providers.arangodb.operators.arangodb

Module Contents

Classes

AQLOperator

Executes AQL query in a ArangoDB database.
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: Sequence[str] = ('query',)[source]
template_ext: Sequence[str] = ('.sql',)[source]
template_fields_renderers[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.

Was this entry helpful?