Separar o envio para o Telegram em uma fila

[jjpaulo2]

Hoje, o projeto é um único repositório monolítico (noticias-phb). Mas, como queremos expandir o projeto para outras cidades, começamos a nos deparar com alguns desafios.

Introdução

A API do Telegram limita a taxa de envio de mensagens por um bot. Caso eles detectem que o bot está mandando muitas mensagens, a API pode retornar um 400 FloodWait. Neste caso, não temos o que fazer, apenas esperar o tempo que eles retornam na API. Para fazer isso usando o pyrogram, é bem simples.

try:
    await telegram.send_message(...)

except FloodWait as exc:
    await asyncio.sleep(exc.value)

Motivado por isso, temos 4 bots, que podem ser rotacionados caso haja o bloqueio de um deles. Como a intenção é que tenhamos vários canais, para várias cidades, iremos precisar aumentar a quantidade de bots reservas.

Proposta

Vamos criar uma fila para centralizar o envio das notícias ao Telegram. Assim, iremos conseguir ter mais controle sobre a rotação dos bots, e sobre o intervalo entre os envios, para diminuir a chance de FloodWait.

Dessa forma, a pipeline de envio ao Telegram dos projetos, apenas irá adicionar uma mensagem em uma fila.

[jjpaulo2]

Feito!