Module Contents

class airflow.contrib.sensors.datadog_sensor.DatadogSensor(datadog_conn_id='datadog_default', from_seconds_ago=3600, up_to_seconds_from_now=0, priority=None, sources=None, tags=None, response_check=None, *args, **kwargs)[source]

Bases: airflow.sensors.base_sensor_operator.BaseSensorOperator

A sensor to listen, with a filter, to datadog event streams and determine if some event was emitted.

Depends on the datadog API, which has to be deployed on the same server where Airflow runs.

  • datadog_conn_id – The connection to datadog, containing metadata for api keys.

  • datadog_conn_id – str

ui_color = #66c3dd[source]
poke(self, context)[source]

Was this entry helpful?