airflow.providers.arangodb.sensors.arangodb

Module Contents

Classes

AQLSensor

Checks for the existence of a document which

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. Example:

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 :Sequence[str] = ['query'][source]
template_ext :Sequence[str] = ['.sql'][source]
template_fields_renderers[source]
poke(self, context)[source]

Function that the sensors defined while deriving this class should override.

Was this entry helpful?