Atlassian Jira 通知操作指南¶

简介¶

Atlassian Jira 通知器 (airflow.providers.atlassian.jira.notifications.jira.JiraNotifier) 允许用户在 Jira 实例中创建问题，使用 DAG 级别和任务级别提供的各种 on_*_callbacks

示例代码¶

from datetime import datetime
from airflow import DAG
from airflow.operators.bash import BashOperator
from airflow.providers.atlassian.jira.notifications.jira import send_jira_notification

with DAG(
    "test-dag",
    start_date=datetime(2023, 11, 3),
    on_failure_callback=[
        send_jira_notification(
            jira_conn_id="my-jira-conn",
            description="Failure in the DAG {{ dag.dag_id }}",
            summary="Airflow DAG Issue",
            project_id=10000,
            issue_type_id=10003,
            labels=["airflow-dag-failure"],
        )
    ],
):
    BashOperator(
        task_id="mytask",
        on_failure_callback=[
            send_jira_notification(
                jira_conn_id="my-jira-conn",
                description="The task {{ ti.task_id }} failed",
                summary="Airflow Task Issue",
                project_id=10000,
                issue_type_id=10003,
                labels=["airflow-task-failure"],
            )
        ],
        bash_command="fail",
        retries=0,
    )