airflow.providers.arangodb.operators.arangodb
¶
Module Contents¶
Classes¶
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.