Как использовать Jobqueue в Python-телеграмме-боте

Я смог очень легко создать бота, прочитав docs, но Jobqueue не работает, как написано. Метод run_daily использует объект datetime.time для отправки сообщения в определенное время, но этот код не выполняет свою работу по отправке сообщения и не показывает никаких ошибок. Он просто продолжает работать

    import datetime
    from telegram import bot
    from telegram.ext import Updater
    def callback_minute(bot, job):
        bot.send_message(chat_id=475838704, text='PlEaSe wOrK!')

    def main():
        updater = Updater()
        bot = updater.bot
        job = updater.job_queue

        dispatcher = updater.dispatcher

        job.run_daily(callback_minute, time=datetime.time(6,33,00))

        updater.start_polling()
        updater.idle()

    if __name__ == '__main__':
        main()

python-3.x python telegram-bot python-telegram-bot job-queue
person Rajas Rasam    schedule 28.09.2018    source источник

Ответы (3)


arrow_upward
4
arrow_downward

Возможно, это поможет:

from telegram.ext import Updater, CommandHandler

def daily_job(bot, update, job_queue):
    """ Running on Mon, Tue, Wed, Thu, Fri = tuple(range(5)) """
    bot.send_message(chat_id=<YOUR CHAT ID>, text='Setting a daily notifications!')
    t = datetime.time(10, 00, 00, 000000)
    job_queue.run_daily(notify_assignees, t, days=tuple(range(5)), context=update)

def notify_assignees(bot, job):
    bot.send_message(chat_id=<CHAT ID>, text="Some text!")

updater = Updater(<BOT_TOKEN>)
updater.dispatcher.add_handler(CommandHandler('notify', daily_job, pass_job_queue=True))
updater.start_polling()

и сказать боту /notify

person Oleksii Dubniak    schedule 20.04.2019

arrow_upward
2
arrow_downward

Простой пример использования JobQueue Расширение от python-telegram-bot

from telegram.ext import Updater, CommandHandler

def callback_alarm(bot, job):
    bot.send_message(chat_id=job.context, text='Wait for another 10 Seconds')

def callback_timer(bot, update, job_queue):
    bot.send_message(chat_id=update.message.chat_id,
                      text='Wait for 10 seconds')
    job_queue.run_repeating(callback_alarm, 10, context=update.message.chat_id)

def Stop_timer(bot, update, job_queue):
    bot.send_message(chat_id=update.message.chat_id,
                      text='Stopped!')
    job_queue.stop()

updater = Updater("YOUR_TOKEN")
updater.dispatcher.add_handler(CommandHandler('start', callback_timer, pass_job_queue=True))
updater.dispatcher.add_handler(CommandHandler('stop', Stop_timer, pass_job_queue=True))

updater.start_polling()

команда /start запустит JobQueue и отправит сообщение с интервалом в 5 секунд, а очередь может быть остановлена ​​командой /stop.

person Sumithran    schedule 05.01.2020
comment
Привет, вы смогли решить эту проблему, tzinfo по умолчанию - это UTC, поэтому он не совпадает с IST? - person Shubh; 17.04.2020
comment
@Shubh добавьте к этому 5 часов 30 минут :) - person pentexnyx; 08.01.2021

arrow_upward
0
arrow_downward

используйте следующие коды:

from telegram.ext import CommandHandler, Updater

my_token = 'YOUR TOKEN'
updater = Updater(my_token, use_context=True)
job_queue = updater.job_queue

def send_message_job(context):
    context.bot.send_message(chat_id='@YOUR CHANELL ID',text='job executed')

job_queue.run_repeating(send_message_job,interval=10.0,first=0.0)
person hamed    schedule 22.01.2021