TelegramOperator

Use the TelegramOperator to send message to a Telegram group or a specific chat.

Using the Operator

Use the telegram_conn_id argument to connect to Telegram client where the connection metadata is structured as follows:

Telegram Connection Metadata

Parameter

Input

Password: string

Telegram Bot API Token

Host: string

Chat ID of the Telegram group/chat

Connection Type: string

http as connection type

An example usage of the TelegramOperator is as follows:

tests/system/providers/telegram/example_telegram.py[source]


    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,
    )

Note

Parameters that can be passed onto the operator will be given priority over the parameters already given in the Airflow connection metadata (such as Host, Password and so forth).

Was this entry helpful?