airflow.providers.telegram.operators.telegram¶

用于 Telegram 的 Operator。

类¶

`TelegramOperator`	此 operator 允许您使用 Telegram Bot API 向 Telegram 发送消息。
`TelegramFileOperator`	此 operator 允许您使用 Telegram Bot API 向 Telegram 发送文件。

模块内容¶

class airflow.providers.telegram.operators.telegram.TelegramOperator(*, telegram_conn_id='telegram_default', token=None, chat_id=None, text='No message has been set.', telegram_kwargs=None, **kwargs)[source]¶

Bases: airflow.models.BaseOperator

此 operator 允许您使用 Telegram Bot API 向 Telegram 发送消息。

可以直接接收 Telegram Bot API token，或接收在密码字段中包含 Telegram token 的连接。如果两者都提供，则 token 参数优先。

另请参阅

有关如何使用此 operator 的更多信息，请参阅指南：TelegramOperator

参数:

telegram_conn_id (str) – Telegram 连接 ID，其密码即为 Telegram API token
token (str | None) – Telegram API Token
chat_id (str | None) – Telegram 聊天/频道/群组的 ID
text (str) – 要发送到 Telegram 的消息
telegram_kwargs (dict | None) – 传递给 Telegram 客户端的额外参数

template_fields: collections.abc.Sequence[str] = ('text', 'chat_id')[source]¶

ui_color = '#FFBA40'[source]¶

chat_id = None[source]¶

token = None[source]¶

telegram_kwargs[source]¶

text = 'No message has been set.'[source]¶

telegram_conn_id = 'telegram_default'[source]¶

execute(context)[source]¶

调用 TelegramHook 发布提供的 Telegram 消息。

class airflow.providers.telegram.operators.telegram.TelegramFileOperator(*, telegram_conn_id='telegram_default', token=None, chat_id=None, file, telegram_kwargs=None, **kwargs)[source]¶

Bases: airflow.models.BaseOperator

此 operator 允许您使用 Telegram Bot API 向 Telegram 发送文件。

可以直接接收 Telegram Bot API token，或接收在密码字段中包含 Telegram token 的连接。如果两者都提供，则 token 参数优先。

另请参阅

有关如何使用此 operator 的更多信息，请参阅指南：TelegramOperator

参数:

telegram_conn_id (str) – Telegram 连接 ID，其密码即为 Telegram API token
token (str | None) – Telegram API Token
chat_id (str | None) – Telegram 聊天/频道/群组的 ID
file (str) – 要通过 Telegram 发送的文件或媒体的路径
telegram_kwargs (dict | None) – 传递给 Telegram 客户端的额外参数

template_fields: collections.abc.Sequence[str] = 'chat_id'[source]¶

ui_color = '#FFBA40'[source]¶

chat_id = None[source]¶

token = None[source]¶

telegram_kwargs[source]¶

file[source]¶

telegram_conn_id = 'telegram_default'[source]¶

execute(context)[source]¶

调用 TelegramHook 发送提供的 Telegram 文件。