Как сделать рассылку в телеграм боте?

Question

[sXfTeR]

Суть вопроса.. Как сделать или можно ли это вообще сделать’ Рассылку определенному пользователю или пользователям к примеру (1, 2, 3) людям ? Код Aiogram для рассылки всем пользователям которые есть в БД:

@dp.message_handler(content_types=['text'], text='Рассылка')
async def spam(message: Message):
    if message.from_user.id == ADMIN:
        await admin.send.set()
        await message.answer('Напиши текст рассылки')
    else:
        await message.answer('Вы не являетесь админом')


@dp.message_handler(state=admin.send)
async def start_spam(message: Message, state: FSMContext):
    if message.text == 'Назад':
        await message.answer('Главное меню')
        await state.finish()
    else:
        cur = conn.cursor()
        cur.execute(f'''SELECT user_id FROM users''')
        spam_base = cur.fetchall()
        print(spam_base)
        for z in range(len(spam_base)):
            print(spam_base[z][0])
        for z in range(len(spam_base)):
            await bot.send_message(spam_base[z][0], message.text)
        await message.answer('Рассылка завершена')
        await state.finish()

Буду благодарен за ответ.

Answer 1

[IKIQ]

Боты писать могут только тем людям, которые писали боту

Comments

[sXfTeR]

Я так и написал в вопросе - "пользователям которые есть в БД". Мне нужно именно определённому пользователю или пользователям которые есть в БД’ прислать рассылку.
Мне это нужно узнать.

[IKIQ]

У вас SELECT user_id FROM users
А нужно message.chat.id

[sXfTeR]

IKIQ, Я знаю что нужно messg.chat.id, и у меня вообще другой метод рассылки без FSM и работает также, просто я взял этот код потому что давно лежал в файлах и решил его прикрепить.

[sXfTeR]

IKIQ, так вы сможете мне помочь ?

[IKIQ]

sXfTeR, чем помочь то? Бота написать?
P.s. sleep добавьте https://pythonist.ru/sleep-function/

Answer 2

[User]

сделать’ Рассылку определенному пользователю или пользователям к примеру (1, 2, 3)

Можно добавить еще одно состояние в admin.select_receivers, а после получения текста рассылки уточнять кому его рассылать. И в зависимости от этого брать из таблицы нужное кол-во данных.

for z in range(len(spam_base)):
    await bot.send_message(spam_base[z][0], message.text)

- без сна\кулдауна очень быстро получите FloodWaitError если получателей будет больше 20-30

Comments

[sXfTeR]

Спасибо, попробую как то так сделать..
И ещё.. как обойти лимит рассылки в 30 сообщений в секунду если к примеру ботом пользуется человек (100, 1000, 10000) как правильно сделать кулдаун (sleep) ?

[User]

sXfTeR, Подойдет обычный asyncio.sleep(X) через каждые N пользователей.

spoiler

>>> users_id = [100, 101, 102, 103, 104, 105, 106, 107, 108, 109]
>>> users_count = len(users_id)
>>> max_send = 2 # За итерацию
>>> for i in list(range(users_count)):
...   print("Sent to ", users_id[i])
...   if i % max_send == 0:
...     print("Sleeping")
...
Sent to  100
Sleeping
Sent to  101
Sent to  102
Sleeping
Sent to  103
Sent to  104
Sleeping
Sent to  105
Sent to  106
Sleeping
Sent to  107
Sent to  108
Sleeping
Sent to  109

При max_send = 5, asyncio.sleep(1) и 10,000 пользователях рассылка будет длиться примерно 33 мин.

[sXfTeR]

User, Спасибо.