Slack

class airflow_plugins.operators.slack.hooks.SlackHook(token=None, method='chat.postMessage', api_params=None, channel=None, username=None, text=None, attachments=None, *args, **kwargs)

Slack hook

get_channel_id(name)

Returns channel id by name

get_file_content(url)

Returns file content

run(**kwargs)

SlackAPIOperator calls will not fail even if the call is not unsuccessful. It should not prevent a DAG from completing in success.

class airflow_plugins.operators.slack.operators.Message(channel=None, username=None, *args, **kwargs)

Slack message operator

class airflow_plugins.operators.slack.sensors.SlackMessageSensor(channel, username=None, text_contains=None, callback=None, params=None, headers=None, extra_options=None, *args, **kwargs)

Executes a HTTP get statement and returns False on failure:

404 not found or response_check function returned False

Parameters:

• http_conn_id (string) – The connection to run the sensor against
• endpoint (string) – The relative part of the full url
• params (a dictionary of string key/value pairs) – The parameters to be added to the GET url
• headers (a dictionary of string key/value pairs) – The HTTP headers to be added to the GET request
• response_check (A lambda or defined function.) – A check against the ‘requests’ response object. Returns True for ‘pass’ and False otherwise.
• extra_options (A dictionary of options, where key is string and value depends on the option that's being modified.) – Extra options for the ‘requests’ library, see the ‘requests’ documentation (options to modify timeout, ssl, etc.)