Integration with PagerDuty and Slack in Apache Airflow - Interactive Code Practice

Practice - 5 Tasks

1fill in blank

easy

Complete the code to import the SlackWebhookOperator in Airflow.

Apache Airflow

from airflow.providers.slack.operators.slack_webhook import [1]

Drag options to blanks, or click blank then click option'

ASlackOperator

BSlackWebhookOperator

CSlackHook

DSlackWebhookHook

Attempts:

3 left

💡 Hint

Common Mistakes

Using SlackOperator which is deprecated.

Confusing Hook and Operator classes.

The correct import for sending Slack messages in Airflow is SlackWebhookOperator.

2fill in blank

medium

Complete the code to create a SlackWebhookOperator task that sends a message to Slack.

Apache Airflow

notify_slack = SlackWebhookOperator(task_id='notify_slack', http_conn_id='[1]', message='Task completed!')

Drag options to blanks, or click blank then click option'

Aslack_webhook_default

Bslack_connection

Cpagerduty_connection

Dhttp_default

Attempts:

3 left

💡 Hint

Common Mistakes

Using the PagerDuty connection ID instead of Slack.

Using a generic HTTP connection ID.

The http_conn_id should match the Airflow connection ID for the Slack webhook, commonly named slack_webhook_default.

3fill in blank

hard

Fix the error in the PagerDuty incident creation code by completing the operator name.

Apache Airflow

pagerduty_alert = [1](task_id='pagerduty_alert', routing_key='your_routing_key', event_action='trigger')

Drag options to blanks, or click blank then click option'

APagerDutyHook

BPagerDutyAlertOperator

CPagerDutyOperator

DPagerDutyIncidentOperator

Attempts:

3 left

💡 Hint

Common Mistakes

Using PagerDutyHook which is not an operator.

Using incorrect operator names that do not exist.

The correct operator to create PagerDuty incidents in Airflow is PagerDutyOperator.

4fill in blank

hard

Fill both blanks to create a DAG that sends a Slack notification and triggers a PagerDuty alert.

Apache Airflow

with DAG('alert_dag', start_date=days_ago(1), schedule_interval='@daily') as dag:
    slack_task = SlackWebhookOperator(task_id='slack_notify', http_conn_id='[1]', message='Alert from DAG')
    pagerduty_task = [2](task_id='pagerduty_alert', routing_key='your_routing_key', event_action='trigger')
    slack_task >> pagerduty_task

Drag options to blanks, or click blank then click option'

Aslack_webhook_default

BPagerDutyHook

CPagerDutyOperator

Dslack_connection

Attempts:

3 left

💡 Hint

Common Mistakes

Using PagerDutyHook instead of PagerDutyOperator.

Using wrong Slack connection ID.

The Slack task uses the connection ID slack_webhook_default, and the PagerDuty task uses the PagerDutyOperator.

5fill in blank

hard

Fill all three blanks to create a dictionary comprehension that filters PagerDuty events with status 'triggered' and formats Slack messages.

Apache Airflow

messages = {event['id']: f"Alert: {event['description']}" for event in events if event['status'] [1] '[2]' and event['type'] [3] 'incident'}

Drag options to blanks, or click blank then click option'

A==

Btriggered

D!=

Attempts:

3 left

💡 Hint

Common Mistakes

Using '!=' instead of '==' for filtering.

Using wrong status or type values.

The comprehension filters events where status == 'triggered' and type == 'incident'.

Practice

1. What is the main purpose of integrating Airflow with PagerDuty and Slack?

easy

A. To store Airflow logs in PagerDuty and Slack

B. To schedule Airflow DAGs automatically

C. To replace Airflow's scheduler with PagerDuty

D. To receive fast alerts and notifications about workflow issues

Solution

1. Step 1: Understand the role of PagerDuty and Slack in Airflow

   PagerDuty and Slack are used to send alerts and notifications when Airflow workflows have issues or important events.

2. Step 2: Identify the main benefit of integration

   The integration helps teams respond quickly by notifying them immediately about failures or important status updates.

3. Final Answer:

   To receive fast alerts and notifications about workflow issues -> Option D

4. Quick Check:

   Alerts and notifications = C [OK]

Hint: Think: Why notify teams fast? Alerts! [OK]

Common Mistakes:

• Confusing scheduling with alerting
• Thinking logs are stored in PagerDuty or Slack
• Assuming PagerDuty replaces Airflow scheduler

2. Which Airflow operator is used to send alerts to PagerDuty within a DAG?

easy

A. PagerDutyIncidentOperator

B. SlackAPIPostOperator

C. EmailOperator

D. HttpSensor

Solution

1. Step 1: Identify operators for PagerDuty and Slack

   SlackAPIPostOperator sends messages to Slack, PagerDutyIncidentOperator sends incidents to PagerDuty.

2. Step 2: Match operator to PagerDuty alerts

   PagerDutyIncidentOperator is designed specifically for PagerDuty integration.

3. Final Answer:

   PagerDutyIncidentOperator -> Option A

4. Quick Check:

   PagerDuty alerts = PagerDutyIncidentOperator A [OK]

Hint: PagerDuty operator name includes 'PagerDuty' [OK]

Common Mistakes:

• Choosing SlackAPIPostOperator for PagerDuty alerts
• Confusing EmailOperator with PagerDuty integration
• Selecting HttpSensor which is unrelated

3. Given this Airflow DAG snippet, what will be the output when the task notify_slack runs successfully?

notify_slack = SlackAPIPostOperator(
    task_id='notify_slack',
    token='xoxb-1234',
    channel='#alerts',
    text='DAG completed successfully!'
)

medium

A. No message is sent because the channel name is incorrect

B. An error occurs because the token is invalid

C. A message 'DAG completed successfully!' is posted to the #alerts Slack channel

D. The DAG fails to run because SlackAPIPostOperator is deprecated

Solution

1. Step 1: Understand SlackAPIPostOperator parameters

   The operator sends a message to the specified Slack channel using the provided token and text.

2. Step 2: Analyze the given snippet

   The token and channel are set, and the text is 'DAG completed successfully!'. If the token is valid, the message posts successfully.

3. Final Answer:

   A message 'DAG completed successfully!' is posted to the #alerts Slack channel -> Option C

4. Quick Check:

   Slack message sent = D [OK]

Hint: SlackAPIPostOperator posts text to channel if token valid [OK]

Common Mistakes:

• Assuming token is invalid without evidence
• Thinking SlackAPIPostOperator is deprecated
• Confusing channel name format

4. You wrote this task to send a PagerDuty alert but it fails with an authentication error:

pagerduty_alert = PagerDutyIncidentOperator(
    task_id='pagerduty_alert',
    routing_key='invalid_key',
    title='Airflow failure',
    severity='critical'
)

What is the most likely cause of the failure?

medium

A. The routing_key is incorrect or invalid

B. The severity value must be 'low' instead of 'critical'

C. PagerDutyIncidentOperator does not support the title parameter

D. The task_id must be 'pagerduty_incident' exactly

Solution

1. Step 1: Check the routing_key parameter

   The routing_key is a secret token that must be valid for PagerDuty API authentication.

2. Step 2: Understand authentication errors

   An invalid routing_key causes authentication failure, blocking alert creation.

3. Final Answer:

   The routing_key is incorrect or invalid -> Option A

4. Quick Check:

   Authentication error = invalid routing_key A [OK]

Hint: Authentication errors usually mean bad keys or tokens [OK]

Common Mistakes:

• Changing severity to fix authentication
• Removing title parameter incorrectly
• Changing task_id unnecessarily

5. You want to create an Airflow DAG that sends a Slack message only if a PagerDuty incident is triggered. Which approach correctly integrates both operators to achieve this?

hard

A. Use PagerDutyIncidentOperator first, then SlackAPIPostOperator with a trigger rule 'all_done' to send Slack message regardless of PagerDuty success

B. Use PagerDutyIncidentOperator first, then SlackAPIPostOperator with trigger rule 'all_success' to send Slack message only if PagerDuty alert succeeds

C. Use SlackAPIPostOperator first, then PagerDutyIncidentOperator with trigger rule 'one_failed' to send PagerDuty alert only if Slack fails

D. Use both operators in parallel without dependencies to send alerts simultaneously

Solution

1. Step 1: Define the desired workflow

   Slack message should be sent only if PagerDuty incident is successfully triggered.

2. Step 2: Set operator order and trigger rules

   Run PagerDutyIncidentOperator first. Set SlackAPIPostOperator to run after it with trigger_rule='all_success' to ensure Slack message only sends if PagerDuty alert succeeds.

3. Final Answer:

   Use PagerDutyIncidentOperator first, then SlackAPIPostOperator with trigger rule 'all_success' to send Slack message only if PagerDuty alert succeeds -> Option B

4. Quick Check:

   Slack after PagerDuty success = B [OK]

Hint: Slack depends on PagerDuty success with 'all_success' trigger [OK]

Common Mistakes:

• Sending Slack message regardless of PagerDuty result
• Reversing operator order
• Running both operators in parallel without dependency