釘釘開發(fā)者文檔
https://ding-doc.dingtalk.com/doc#/serverapi2/qf2nxq

1、創(chuàng)建 自定義機器人，獲取webhook。我這里安全設(shè)置選了關(guān)鍵詞方式。

1.1

1.2

1.3

至此我們獲取webhook, https://oapi.dingtalk.com/robot/send?access_token=14c405e24d249e6f43a4b0e4d70f59dd0bb92be349a9e597a42a93cbaxxxxxxx

2、創(chuàng)建airflow的連接

2.1

2.2

3、編寫dag.py

from datetime import timedelta

import airflow
from airflow import DAG
from airflow.operators.bash_operator import BashOperator
from airflow.contrib.operators.dingding_operator import DingdingOperator

default_args = {
    'owner': 'airflow',
    'depends_on_past': False,
    'start_date': airflow.utils.dates.days_ago(2),
    'email': ['xxx@163.com'],
    'email_on_failure': True,
    'email_on_retry': True,
    'retries': 1,
    'retry_delay': timedelta(minutes=1),
}

dag = DAG(
    'dingding-test',
    default_args=default_args,
    description='A simple tutorial DAG',
    schedule_interval='12 * * * *',
)

dd=DingdingOperator(
    task_id='dingding',
    dingding_conn_id='dingding_default',
    message_type='text',
    message='DingTalk airflow dingding test yanxin',
    at_mobiles=['釘釘手機號'],
    dag=dag,
)


ninecho = BashOperator(
    task_id='ninecho',
    bash_command='echo the-9 賽高',
    dag=dag,
)

ninecho >> dd

3.1 消息發(fā)出來了