airflow.providers.arangodb.sensors.arangodb

Classes

AQLSensor

Checks for the existence of a document which matches the given query in ArangoDB.

Module Contents

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.

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]
poke(context)[source]

Override when deriving this class.

Was this entry helpful?