airflow.contrib.hooks.opsgenie_alert_hook

Module Contents

class airflow.contrib.hooks.opsgenie_alert_hook.OpsgenieAlertHook(opsgenie_conn_id='opsgenie_default', *args, **kwargs)

Bases: airflow.hooks.http_hook.HttpHook

This hook allows you to post alerts to Opsgenie. Accepts a connection that has an Opsgenie API key as the connection’s password. This hook sets the domain to conn_id.host, and if not set will default to https://api.opsgenie.com.

Each Opsgenie API key can be pre-configured to a team integration. You can override these defaults in this hook.

Parameters

opsgenie_conn_id (str) – The name of the Opsgenie connection to use

_get_api_key(self)

Get Opsgenie api_key for creating alert

get_conn(self, headers=None)

Overwrite HttpHook get_conn because this hook just needs base_url and headers, and does not need generic params

Parameters

headers (dict) – additional headers to be passed through as a dictionary

execute(self, payload={})

Execute the Opsgenie Alert call

Parameters

payload (dict) – Opsgenie API Create Alert payload values See https://docs.opsgenie.com/docs/alert-api#section-create-alert