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 等）。