Method infinity_polling

telebot/async_telebot.py:335–396

Wrap polling with infinite loop and exception handling to avoid bot stops polling. .. note:: Install watchdog and psutil before using restart_on_change option. :param timeout: Timeout in seconds for get_updates(Defaults to None) :type timeout: :obj:`int

(self, timeout: Optional[int]=20, skip_pending: Optional[bool]=False, request_timeout: Optional[int]=None,
            logger_level: Optional[int]=logging.ERROR, allowed_updates: Optional[List[str]]=None,
            restart_on_change: Optional[bool]=False, path_to_watch: Optional[str]=None, *args, **kwargs)

        await self._process_polling(non_stop, interval, timeout, request_timeout, allowed_updates)

    async def infinity_polling(self, timeout: Optional[int]=20, skip_pending: Optional[bool]=False, request_timeout: Optional[int]=None,
            logger_level: Optional[int]=logging.ERROR, allowed_updates: Optional[List[str]]=None,
            restart_on_change: Optional[bool]=False, path_to_watch: Optional[str]=None, *args, **kwargs):
        """
        Wrap polling with infinite loop and exception handling to avoid bot stops polling.

        .. note::
            Install watchdog and psutil before using restart_on_change option.

        :param timeout: Timeout in seconds for get_updates(Defaults to None)
        :type timeout: :obj:`int`

        :param skip_pending: skip old updates
        :type skip_pending: :obj:`bool`

        :param request_timeout: Aiohttp's request timeout. Defaults to 5 minutes(aiohttp.ClientTimeout).
        :type request_timeout: :obj:`int`

        :param logger_level: Custom logging level for infinity_polling logging.
            Use logger levels from logging as a value. None/NOTSET = no error logging
        :type logger_level: :obj:`int`

        :param allowed_updates: A list of the update types you want your bot to receive.
            For example, specify [“message”, “edited_channel_post”, “callback_query”] to only receive updates of these types.
            See util.update_types for a complete list of available update types.
            Specify an empty list to receive all update types except chat_member (default).
            If not specified, the previous setting will be used.

            Please note that this parameter doesn't affect updates created before the call to the get_updates,
            so unwanted updates may be received for a short period of time.
        :type allowed_updates: :obj:`list` of :obj:`str`

        :param restart_on_change: Restart a file on file(s) change. Defaults to False
        :type restart_on_change: :obj:`bool`

        :param path_to_watch: Path to watch for changes. Defaults to current directory
        :type path_to_watch: :obj:`str`

        :return: None
        """
        if skip_pending:
            await self.skip_updates()
        self._polling = True

        if restart_on_change:
            self._setup_change_detector(path_to_watch)

        while self._polling:
            try:
                await self._process_polling(non_stop=True, timeout=timeout, request_timeout=request_timeout,
                             allowed_updates=allowed_updates, *args, **kwargs)
            except Exception as e:
                if logger_level and logger_level >= logging.ERROR:
                    logger.error("Infinity polling exception: %s", self.__hide_token(str(e)))
                if logger_level and logger_level >= logging.DEBUG:
                    logger.error("Exception traceback:\n%s", self.__hide_token(traceback.format_exc()))
                await asyncio.sleep(3)
                continue