Почему в ботах телеги желательно использовать Webhook вместо Polling

Привет, коллеги!

Сегодня у нас на повестке дня выбор между двумя технологиями: Polling и Webhook. Почему почему именно Webhook является go-to решением для большинства проектов?

Помните, как в начале 2010-х все разрабы активно юзали Polling? Это был золотой стандарт для многих мессенджер-ботов. Но технологии не стоят на месте. Webhook занял свое место, предлагая свои решения.

Polling

Polling, или опрос, – это процесс, при котором клиентский скрипт периодически отправляет запросы к серверу для проверки наличия новой инфы. В телеге это регулярный запрос к АПИ для получения новых обновлений или сообщений.

При увеличении нагрузки Polling может стать бутылочным горлышком. Такую проблемку можно решить увеличением интервала между запросами в моменты низкой активности и его уменьшение в пиковые часы.

Если бот обрабатывает состояния или сессии пользователей нужно учитывать, что при Polling состояние должно храниться на стороне сервера. Это означает необходимость использования БДшек и т.п

Постоянные запросы к серверу создают дополнительную нагрузку. Необходимо настраивать подходящий баланс, чтобы избежать чрезмерного трафика и потенциального блокирования вашего бота из-за слишком частых запросов. API в телеграме ожидаемо имеет ограничения на количество запросов в секунду. Необходимо убедиться, что бот не превышает эти лимиты.

Согласно документации максимальное количество сообщений, отправляемых ботом, ограничено примерно 30 сообщениями в секунду для обычных сообщений и около 20 сообщений в минуту для групповых чатов.

Если бот достигает этих лимитов, будут вылетать ошибки RetryAfter от API. Постоянные попытки повторной отправки сообщений, игнорируя ошибки API, могут привести к временной блокировке бота.

В python-telegram-bot (с версии 20), существует встроенный механизм BaseRateLimiter, который контролирует количество API запросов, совершаемых ботом за определенный временной интервал

Простейший скрипт Polling бота:

import time
import requests

TOKEN = "токен_бота"
URL = f"https://api.telegram.org/bot{TOKEN}/getUpdates"

def get_updates():
    response = requests.get(URL)
    return response.json()

def main():
    while True:
        updates = get_updates()
        if updates["result"]:
            # Обработка каждого нового сообщения
            for item in updates["result"]:
                print(f"Сообщение от пользователя: {item['message']['text']}")
        time.sleep(2)  # Задержка в 2 секунды между запросами

if __name__ == "__main__":
    main()

Бот каждые две секунды спрашивает у сервера Telegram, не пришло ли новых сообщений. В реальности тут конечно должна быть обработка ошибок, логирование и другие элементы

С Polling было связано множество трудностей. Во-первых, нагрузка на сервера. Каждый бот постоянно что то запрашивал у сервера. Представьте себе тысячи ботов, делающих это каждую секунду. Это было не только неэффективно с точки зрения трафика, но и могло вызывать задержки в доставке сообщений.

Во-вторых каждый раз, когда соединение прерывалось или сервер не отвечал, это могло привести к потере апдейтов. Приходилось тщательно продумывать механизмы повторных попыток и логирования, чтобы минимизировать потери данных.

Со временем, когда телега становилась всё более попсовой, разработчики начали искать более эффективные способы взаимодействия с API. И здесь появляются вебхуки. В отличие от Polling, где бот активно запрашивал данные, Webhook позволяет серверу телеграма самому отправлять обновления боту, как только они появляются.

Webhook

Webhook – это, по сути, колллбек. Это URL, который вы предоставляете телеграму, и по которому телеграм будет отправлять обновления в формате JSON каждый раз, когда вашему боту приходит сообщение или происходит другое событие.

В начале вам нужно настроить Webhook. Это делается путем отправки запроса к Telegram API с указанием URL вашего сервера. Телега будет использовать этот URL для отправки обновлений:

from telegram.ext import Updater, CommandHandler
from telegram import Bot
import logging

# логирование
logging.basicConfig(format='%(asctime)s - %(name)s - %(levelname)s - %(message)s',
                    level=logging.INFO)
logger = logging.getLogger(__name__)

# функция для обработки команды /start
def start(update, context):
    update.message.reply_text('Привет!')

def main():
    TOKEN = 'token'
    bot = Bot(TOKEN)

    # Updater и передача токена вашего бота
    updater = Updater(token=TOKEN, use_context=True)

    # диспетчер для регистрации обработчиков
    dp = updater.dispatcher

    # регистрация команды /start
    dp.add_handler(CommandHandler("start", start))

    # настроим вебхук
    updater.start_webhook(listen='0.0.0.0',
                          port=8443,
                          url_path=TOKEN,
                          key='YOUR_PRIVATE.key',
                          cert='YOUR_PUBLIC.pem',
                          webhook_url='https://YOUR.SERVER.IP.ADDRESS:8443/' + TOKEN)

    updater.idle()

if __name__ == '__main__':
    main()

YOUR_PRIVATE.key и YOUR_PUBLIC.pem это путь к ключу SSL, и YOUR.SERVER.IP.ADDRESS адрес сервера.

Для Webhook необходим SSL-сертификат. Telegram требует, чтобы обмен данными был защищен. Телеграм поддерживает ограниченное количество портов для Webhook: 443, 80, 88, 8443.

Для настройки SSL-терминации на веб-сервере нужно установить и настроить Nginx или Apache. На Nginx:

server {
    listen 443 ssl;
    server_name YOUR.SERVER.IP.ADDRESS;

    ssl_certificate /path/to/YOUR_PUBLIC.pem;
    ssl_certificate_key /path/to/YOUR_PRIVATE.key;

    location / {
        proxy_pass http://localhost:8443;
        proxy_set_header Host $host;
        proxy_set_header X-Real-IP $remote_addr;
        proxy_set_header X-Forwarded-For $proxy_add_x_forwarded_for;
        proxy_set_header X-Forwarded-Proto $scheme;
    }
}

Как только кто-то взаимодействует с ботом (например, отправляет ему сообщение), телеграм делает запрос на юрл вебхук с деталями этого события. Эти данные приходят в виде JSON-объекта, который содержат информацию, к примеру:

{
    "update_id": 123456789,
    "message": {
        "message_id": 111,
        "from": {
            "id": 222,
            "is_bot": false,
            "first_name": "viktor",
            "username": "viktor12313"
        },
        "chat": {
            "id": 333,
            "first_name": "viktor",
            "username": "viktor12313",
            "type": "private"
        },
        "date": 1609459200,
        "text": "ку"
    }
}

Сервер затем обрабатывает этот запрос, парсит полученный JSON и выполняет необходимые действия, например, отвечает на сообщение пользователя.

Следующий шаг - это создание обработчика для входящих сообщений. В коде это обычно реализуется через определение функций с декораторами, указывающими на типы обрабатываемых сообщений (например, текст, изображения и т.д.). В качестве примера, можно использовать библиотеку fastapi вместе с telebot. Создаётся экземпляр класса AsyncTeleBot, затем настраивается webhook и определяются функции для обработки команд (/start, /help) и обычных текстовых сообщений. При получении обновления, бот использует await для асинхронной обработки сообщения и отправляет ответ:

import fastapi
from telebot.async_telebot import AsyncTeleBot
import telebot

API_TOKEN = 'токен'
WEBHOOK_URL = 'вебхук'

bot = AsyncTeleBot(API_TOKEN)
app = fastapi.FastAPI()

@app.post('/')  
async def process_webhook(update: dict):  
    if update:  
        update = telebot.types.Update.de_json(update)  
        await bot.process_new_updates([update])  

@bot.message_handler(commands=['help', 'start'])  
async def send_welcome(message):  
    await bot.reply_to(message, "Бот запущен...")  

@bot.message_handler(func=lambda message: True, content_types=['text'])  
async def echo_message(message):  
    await bot.reply_to(message, message.text)  

Итого в таблице сравнение выглядит так:

Webhook хоть и немного сложнее в настройке, имеет гораздо больше плюсов по сравнению с Polling.

В завершение хочу порекомендовать бесплатный урок на котором коллеги из OTUS разберут практические подходы, которые помогут вам писать чистый, поддерживаемый код на Python.

• Зарегистрироваться на бесплатный урок