airflow.providers.arangodb.sensors.arangodb
¶
Module Contents¶
Classes¶
Checks for the existence of a document which matches the given query in ArangoDB. |
- class airflow.providers.arangodb.sensors.arangodb.AQLSensor(*, query, arangodb_conn_id='arangodb_default', **kwargs)[source]¶
Bases:
airflow.sensors.base.BaseSensorOperator
Checks for the existence of a document which matches the given query in ArangoDB.
- Parameters
collection – Target DB collection.
query (str) – The query to poke, or you can provide .sql file having the query
arangodb_conn_id (str) – The ArangoDB connection id to use when connecting to ArangoDB.
arangodb_db – Target ArangoDB name.