TelegramOperator¶

使用 TelegramOperator 向 Telegram 群组或特定聊天发送消息。

使用操作器¶

使用 telegram_conn_id 参数连接到 Telegram 客户端，其中连接元数据结构如下

Telegram 连接元数据¶
参数	输入
密码：字符串	Telegram Bot API 令牌
主机：字符串	Telegram 群组/聊天的聊天 ID
连接类型：字符串	telegram 作为连接类型

以下是 TelegramOperator 的一个使用示例

tests/system/providers/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,
    )

注意

可以传递给操作器的参数将优先于 Airflow 连接元数据中已给出的参数（例如 主机、密码 等）。