Ограничения частоты запросов
В этом руководстве показано, как решить проблемы с ограничением частоты запросов (Error code 429, Error: Too many requests: retry later) от Telegram Bot API.
В общем, если вы избегаете поведения, напоминающего массовую рассылку в вашем боте, то беспокоиться об ограничениях частоты запросов не нужно. Но лучше на всякий случай использовать плагин auto-retry. Если вы достигаете этих ограничений без рассылки, то, скорее всего, что-то не так на вашей стороне.
Как делать рассылку
Для начала мы можем решить проблемы с ограничением частоты запросов при рассылке без использования очередей.
Давайте воспользуемся встроенной функцией withRetries которая ловит ошибки с полем retry_after (ошибки ограничения частоты запросов), ждет указанное время и повторяет запрос к API.
Затем нам нужно создать цикл и настроить задержку так, чтобы мы с наименьшей вероятностью попали на ошибку rate-limit, а если мы её поймаем, мы будем ждать указанное время (и плагин withRetries повторит запрос)
// экспериментальное API, доступное с Node.js@16.14.0
import { scheduler } from "node:timers/promises";
import { Bot, TelegramError } from "gramio";
import { withRetries } from "gramio/utils";
const bot = new Bot(process.env.BOT_TOKEN as string);
const chatIds: number[] = [
/** идентификаторы чатов */
];
for (const chatId of chatIds) {
const result = await withRetries(() =>
bot.api.sendMessage({
chat_id: chatId,
text: "Привет!",
})
);
await scheduler.wait(100); // Базовая задержка между успешными запросами чтобы не попасть на ошибку `rate-limit`
}Реализация с очередью (@gramio/broadcast)
Пример рассылки, которая сохраняется даже при перезапуске сервера и готова к горизонтальному масштабированию.
GramIO имеет в своей экосистеме удобную библиотеку для работы с рассылками - @gramio/broadcast
Предварительные требования:
import { Bot, InlineKeyboard } from "gramio";
import Redis from "ioredis";
import { Broadcast } from "@gramio/broadcast";
const redis = new Redis({
maxRetriesPerRequest: null,
});
const bot = new Bot(process.env.BOT_TOKEN as string);
const broadcast = new Broadcast(redis).type("test", (chatId: number) =>
bot.api.sendMessage({
chat_id: chatId,
text: "test",
})
);
console.log("prepared to start");
const chatIds = [617580375];
await broadcast.start(
"test",
chatIds.map((x) => [x])
);
// graceful shutdown
async function gracefulShutdown() {
console.log(`Process ${process.pid} go to sleep`);
await broadcast.job.queue.close();
console.log("closed");
process.exit(0);
}
process.on("SIGTERM", gracefulShutdown);
process.on("SIGINT", gracefulShutdown);Эта библиотека предоставляет удобный интерфейс для работы с рассылками не теряя типизации. Вы создаёте типы рассылок и принимаете в функции данные, а затем вызываете broadcast.start с массивом аргументов.
Своя реализация
Или вы можете написать свою логику:
Предварительные требования:
// TODO: больше информации об этом
import { Worker } from "bullmq";
import { Bot, TelegramError } from "gramio";
import { Redis } from "ioredis";
import { initJobify } from "jobify";
const bot = new Bot(process.env.BOT_TOKEN as string);
const redis = new Redis({
maxRetriesPerRequest: null,
});
const defineJob = initJobify(redis);
const text = "Привет, мир!";
const sendMailing = defineJob("send-mailing")
.input<{ chatId: number }>()
.options({
limiter: {
max: 20,
duration: 1000,
},
})
.action(async ({ data: { chatId } }) => {
const response = await bot.api.sendMessage({
chat_id: chatId,
suppress: true,
text,
});
if (response instanceof TelegramError) {
if (response.payload?.retry_after) {
await sendMailing.worker.rateLimit(
response.payload.retry_after * 1000
);
// используйте это только если вы не используете auto-retry
// потому что это запускает эту задачу заново
throw Worker.RateLimitError();
} else throw response;
}
});
const chats: number[] = []; // получите чаты из базы данных
await sendMailing.addBulk(
chats.map((x) => ({
name: "mailing",
data: {
chatId: x,
},
}))
);