TelegramOperator¶

使用 TelegramOperator 傳送訊息到 Telegram 群組或特定聊天。

使用 Operator¶

使用 telegram_conn_id 引數連線到 Telegram 客戶端，其連線元資料結構如下

Telegram 連線元資料¶
引數	輸入
密碼: 字串	Telegram Bot API Token
主機: 字串	Telegram 群組/聊天的 Chat ID
連線型別: 字串	telegram 作為連線型別

TelegramOperator 的一個示例用法如下

tests/system/telegram/example_telegram.py

    send_message_telegram_task = TelegramOperator(
        task_id="send_message_telegram",
        telegram_conn_id=CONN_ID,
        chat_id=CHAT_ID,
        text="Hello from Airflow!",
        dag=dag,
    )

注意

可以傳遞給 operator 的引數將優先於 Airflow 連線元資料中已給定的引數（例如 Host、Password 等）。